Я хочу экспортировать таблицу в oracle, содержащую пространственное поле, в виде файла shp.Эта ошибка возникает, когда я запускаю программу экспорта. Я думаю, что длина поля в таблице, сохраненной в файле shp, вызывает эту проблему.Самая длинная длина поля в таблице - NVARCHAR2(200). Но странно то, что я вручную установил информацию о длине поля, сохраненную в файле shp в программе, но, похоже, она не работает.
здесьважный код:
public static void doShp(String table) {
JDBCDataStore jds = null;
Connection conn = null;
Transaction tran = new DefaultTransaction();
String newTable = null;
try {
//获取连接
jds = connOra();
conn = jds.getConnection(tran);
newTable = createTempTableOrNotByConfig(table, conn);
//根据表名获取所有列的结果集
ResultSet rs = conn.getMetaData().getColumns(null, null, newTable,
null);
List<Map<String, Object>> metalist = new ArrayList<Map<String, Object>>();
//循环将列信息放入List<map>中
while (rs.next()) {
String columnName = rs.getString("COLUMN_NAME"); // 列名
String dataTypeName = rs.getString("TYPE_NAME"); // java.sql.Types类型名称(列类型名称)
int columnSize = rs.getInt("COLUMN_SIZE"); // 列大小
int decimalDigits = rs.getInt("DECIMAL_DIGITS"); // 小数位数
String isNullAble = rs.getString("IS_NULLABLE");
Map<String, Object> map = new HashMap<String, Object>();
map.put("columnName", columnName);
map.put("dataTypeName", dataTypeName);
map.put("columnSize", columnSize);
map.put("decimalDigits", decimalDigits);
map.put("isNullAble", isNullAble);
metalist.add(map);
}
rs.close();
//根据表名获取主键信息
ResultSet res1 = conn.getMetaData()
.getPrimaryKeys(null, null, newTable);
String columnName = "";
while (res1.next()) {
columnName = res1.getString("COLUMN_NAME");
}
res1.close();
Query q = new Query();
q.setTypeName(newTable);
//如果有导出的条件，则拼接
if (cmap.get("filter") != null && !cmap.get("filter").isEmpty()) {
q.setFilter(CQL.toFilter(cmap.get("filter")));
}
// SortBy sb=new SortByImpl("",SortOrder.ASCENDING);
q.setSortBy(new SortBy[]{SortBy.NATURAL_ORDER});
//根据query对象获取FeatureReader对象，读取oracle数据,sfs是每行数据的集合体
FeatureReader<SimpleFeatureType, SimpleFeature> sfs = jds
.getFeatureReader(q, null);
//输出文件对象
File newFile = new File(BASE_PATH + "/map/output/" + newTable + ".shp");
Map<String, Serializable> params = new HashMap<String, Serializable>();
params.put("url", (Serializable) newFile.toURI().toURL());
params.put("create spatial index", (Serializable) Boolean.TRUE);
ShapefileDataStoreFactory factory = new ShapefileDataStoreFactory();
//根据params参数获取ShapefileDataStore数据源对象
ShapefileDataStore dataStore = (ShapefileDataStore) factory
.createNewDataStore(params);
//columnName-主键 metalist-列相关信息 table-表名
SimpleFeatureType type = getType(columnName, metalist, newTable);
//设置列相关信息-----------------------
dataStore.createSchema(type);
//设置编码
dataStore.setCharset(Charset.forName(cmap.get("charset")));
//设置事务
Transaction transaction = new DefaultTransaction("Reproject");
//获取指定typename和transaction的writer对象(typename为表名)
String typeName = type.getTypeName();
FeatureWriter<SimpleFeatureType, SimpleFeature> writer = dataStore.getFeatureWriterAppend(typeName, transaction);
//获取表中的属性->集合
List<AttributeDescriptor> list = type.getAttributeDescriptors();
//获取空间信息字段名
String the_geom = getGeomCol(newTable, conn);
// 创建一个事务
int i = 0;
try {
//如果读取不到了就跳出循环
while (sfs.hasNext()) {
SimpleFeature feature = sfs.next();
SimpleFeature copy = writer.next();
//表中的属性->集合
for (int j = 0; j < list.size(); j++) {
AttributeDescriptor dr = list.get(j);
//如果不是空间信息字段
if (!dr.getLocalName().equals(the_geom)) {
if (isContainChinese(dr.getLocalName())) {
//包含中文
copy.setAttribute(j, feature.getAttribute(j));
} else {
copy.setAttribute(dr.getName(), feature.getAttribute(dr.getName()));
}
}
}
Geometry geometry = (Geometry) feature.getDefaultGeometry();
copy.setDefaultGeometry(geometry);
writer.write();
i++;
}
tran.commit();
transaction.commit();
log.info("导出shp文件成功,共导出数据" + i + "条,请在" + BASE_PATH
+ "/output/目录下查看结果");
} catch (Exception problem) {
log.error(problem);
transaction.rollback();
tran.rollback();
problem.printStackTrace();
} finally {
jds.dispose();
writer.close();
}
} catch (Exception e) {
log.error(e);
e.printStackTrace();
} finally {
if (jds != null)
jds.dispose();
}
updateOutFileName(table.toUpperCase());
saveTempTableNameToConf(newTable);
}
private static SimpleFeatureType getType(String pkcol, List<Map<String, Object>> list, String newTable) {
//定义图形信息和属性信息
SimpleFeatureTypeBuilder builder = new SimpleFeatureTypeBuilder();
//设置表名
builder.setName(newTable);
//根据配置设置二维坐标参考系统
try {
crs = CRS.decode("EPSG:" + cmap.get("epsg"));
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
builder.setCRS(crs);
//循环设置列的列名及其类型(不设置主键)
for (Map<String, Object> m : list) {
if (m.get("columnName").toString().equals(pkcol)) {
continue;
}
//获取类型为空间属性类型的列
if (m.get("dataTypeName").equals("SDO_GEOMETRY")) {
builder.add(m.get("columnName").toString(), Polygon.class);
}
if (m.get("dataTypeName").toString().equals("NUMBER")) {
//decimalDigits-小数位数
if (Integer.parseInt(m.get("decimalDigits").toString()) > 0) {
builder.add(m.get("columnName").toString(), Double.class);
} else {
builder.add(m.get("columnName").toString(), Integer.class);
}
}
if (m.get("dataTypeName").toString().equals("FLOAT") || m.get("dataTypeName").toString().equals("DOUBLE")) {
builder.add(m.get("columnName").toString(), Double.class);
}
if (m.get("dataTypeName").toString().equals("VARCHAR2") || m.get("dataTypeName").toString().equals("NVARCHAR2")) {
builder.length(2 * (Integer.parseInt(m.get("columnSize").toString())))
.add(m.get("columnName").toString(), String.class);
}
if (m.get("dataTypeName").toString().equals("DATE")) {
builder.add(m.get("columnName").toString(), Date.class);
}
}
return builder.buildFeatureType();
}
Ошибка:
java.io.IOException: Текущий индекс fid равен нулю, следующий должен быть вызван перед write () в org.geotools.data.shapefile.fid.IndexedFidWriter.write (IndexedFidWriter.java:243) в org.geotools.data.shapefile.IndexedShapefileFeatureWriter.write (IndexedShapefileFeatureWriter.java:97) в org.geriteFile.FileFile.FileFileFileFileFileFileFileFileFile244) в org.geotools.data.shapefile.IndexedShapefileFeatureWriter.close (IndexedShapefileFeatureWriter.java:103) в org.geotools.data.InProcessLockingManager $ 1.close (InProcessLockingManaction.iffata.ata3. Atata3g.commit (DiffTransactionState.java:196) в org.geotools.data.DefaultTransaction.commit (DefaultTransaction.java:166) в com.bitservice.map.Ora2shpFile.doShp (Ora2shpFile.java:269) в com.bitservice.map.Ora2shpFile.main (Ora2shpFile.java:140), вызванный: java.lang.StringIndexOutOfBoundsException диапазон: выходная строка: исключение строки:253 по адресу java.lang.StringBuffer.charAt (StringBuffer.java:202) по адресу org.geotools.data.shapefile.dbf.DbaseFileWriter $ FieldFormatter.getFieldString (DbaseFileWriter.java:361) в org.geotofata.ata.DbaseFileWriter.fieldBytes (DbaseFileWriter.java:225) в org.geotools.data.shapefile.dbf.DbaseFileWriter.write (DbaseFileWriter.java:196) в org.geotools.data.shapefile.SavaehapefileFileпо адресу org.geotools.data.shapefile.IndexedShapefileFeatureWriter.write (IndexedShapefileFeatureWriter.java:98) по адресу org.geotools.data.InProcessLockingManager $ 1.write (InProcessLockingManager.java:30Tegate.com (). org).DiffTransactionState.java:180) ... еще 3
вот информация о типе:
FID INTEGER
THE_GEOM MDSYS.SDO_GEOMETRY
BSM NUMBER(10)
YSDM VARCHAR2(10)
ZDDM VARCHAR2(19)
BDCDYH VARCHAR2(28)
ZDTZM VARCHAR2(2)
ZL VARCHAR2(200)
ZDMJ NUMBER(15,4)
MJDW VARCHAR2(2)
YT VARCHAR2(4)
DJ VARCHAR2(2)
JG NUMBER(15,4)
QLLX VARCHAR2(2)
QLXZ VARCHAR2(4)
QLSDFS VARCHAR2(2)
RJL VARCHAR2(200)
JZMD NUMBER(3,2)
JZXG NUMBER(5,2)
ZDSZD NVARCHAR2(200)
ZDSZN VARCHAR2(200)
ZDSZX VARCHAR2(200)
ZDSZB VARCHAR2(200)
ZDT VARCHAR2(200)
TFH VARCHAR2(50)
BZ VARCHAR2(200)
YTMC VARCHAR2(200)
QXDM VARCHAR2(6)