| | |
| | | Driver driver = null; |
| | | DataSource dataSource = null; |
| | | try { |
| | | driver = ogr.GetDriverByName("OpenFileGDB"); |
| | | driver = ogr.GetDriverByName("FileGDB"); |
| | | if (null == driver) { |
| | | return; |
| | | } |
| | | |
| | | dataSource = driver.CreateDataSource(filePath); |
| | | dataSource = driver.CreateDataSource(filePath, null); |
| | | if (null == dataSource) { |
| | | return; |
| | | } |
| | | |
| | | for (String key : map.keySet()) { |
| | | GeomBaseMapper baseMapper = ClassHelper.getGeoBaseMapper(key); |
| | | if (null == baseMapper) { |
| | | continue; |
| | | } |
| | | Layer layer = createLayer(dataSource, baseMapper); |
| | | if (null == layer) { |
| | | continue; |
| | | } |
| | | Layer layer = null; |
| | | try { |
| | | GeomBaseMapper baseMapper = ClassHelper.getGeoBaseMapper(key); |
| | | if (null == baseMapper) { |
| | | continue; |
| | | } |
| | | layer = createLayer(dataSource, baseMapper); |
| | | if (null == layer) { |
| | | continue; |
| | | } |
| | | |
| | | String className = ClassHelper.getClassName(baseMapper); |
| | | Class clazz = ClassHelper.getEntityClass(className); |
| | | List<Field> fields = new ArrayList<>(); |
| | | getFields(clazz, fields); |
| | | String className = ClassHelper.getClassName(baseMapper); |
| | | Class clazz = ClassHelper.getEntityClass(className); |
| | | if (null == clazz) { |
| | | continue; |
| | | } |
| | | |
| | | Field gField = getGeomField(clazz); |
| | | if (null == gField) { |
| | | continue; |
| | | List<Field> fields = new ArrayList<>(); |
| | | fields.add(getGeomField(clazz)); |
| | | getFields(clazz, fields); |
| | | addLayerField(layer, fields); |
| | | |
| | | setLayerData(layer, fields, map.get(key)); |
| | | } catch (Exception e) { |
| | | log.error(e.getMessage(), e); |
| | | } finally { |
| | | if (null != layer) { |
| | | layer.delete(); |
| | | } |
| | | } |
| | | |
| | | List<?> list = map.get(key); |
| | | } |
| | | |
| | | dataSource.SyncToDisk(); |
| | | dataSource.FlushCache(); |
| | | } catch (Exception ex) { |
| | | log.error(ex.getMessage(), ex); |
| | | } finally { |
| | |
| | | try { |
| | | Field[] fields = clazz.getDeclaredFields(); |
| | | for (Field f : fields) { |
| | | // if ("geom".equals(f.getName())) { |
| | | // continue; |
| | | // } |
| | | |
| | | if (StaticData.READ_EXCLUDE_FIELDS.contains(f.getName())) { |
| | | if (StaticData.GDB_EXCLUDE_FIELDS.contains(f.getName())) { |
| | | continue; |
| | | } |
| | | |
| | |
| | | * 添加图层字段 |
| | | */ |
| | | private static void addLayerField(Layer layer, List<Field> list) { |
| | | for (int i = 0, c = list.size(); i < c; i++) { |
| | | for (int i = 1, c = list.size(); i < c; i++) { |
| | | Field f = list.get(i); |
| | | FieldDefn fd = getLayerField(f); |
| | | |
| | | int fieldType = getFieldType(f); |
| | | FieldDefn fd = new FieldDefn(f.getName(), fieldType); |
| | | |
| | | layer.CreateField(fd, i); |
| | | } |
| | | } |
| | | |
| | | private static FieldDefn getLayerField(Field f ) { |
| | | int fieldType = getFieldType(f); |
| | | FieldDefn fd = new FieldDefn(f.getName(), fieldType); |
| | | if (fieldType == ogr.OFTString) { |
| | | |
| | | } |
| | | |
| | | return fd; |
| | | } |
| | | |
| | | /** |
| | |
| | | return ogr.OFTString; |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 设置图层数据 |
| | | */ |
| | | private static <T> void setLayerData(Layer layer, List<Field> fields, List<T> list) throws Exception { |
| | | for (T t : list) { |
| | | Feature f = new Feature(layer.GetLayerDefn()); |
| | | |
| | | BaseGeoEntity geoEntity = (BaseGeoEntity) t; |
| | | Geometry geom = Geometry.CreateFromWkt(geoEntity.getGeom()); |
| | | f.SetGeometry(geom); |
| | | |
| | | for (int i = 1, c = fields.size(); i < c; i++) { |
| | | Field field = fields.get(i); |
| | | Object val = field.get(t); |
| | | if (null == val) { |
| | | continue; |
| | | } |
| | | |
| | | switch (field.getType().getName()) { |
| | | case "java.math.BigDecimal": |
| | | case "java.lang.Double": |
| | | case "double": |
| | | double d = (double) val; |
| | | f.SetField(i, d); |
| | | break; |
| | | case "java.lang.Long": |
| | | case "long": |
| | | long l = (long) val; |
| | | f.SetField(i, l); |
| | | break; |
| | | case "java.lang.Integer": |
| | | case "int": |
| | | int n = (int) val; |
| | | f.SetField(i, n); |
| | | break; |
| | | case "java.sql.Timestamp": |
| | | Timestamp time = (Timestamp) field.get(t); |
| | | setTimestamp(f, i, time); |
| | | break; |
| | | default: |
| | | String str = (String) val; |
| | | f.SetField(i, str); |
| | | break; |
| | | } |
| | | } |
| | | layer.CreateFeature(f); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 设置Timestamp |
| | | */ |
| | | @SuppressWarnings("AlibabaRemoveCommentedCode") |
| | | private static void setTimestamp(Feature f, int i, Timestamp time) { |
| | | if (null == time) { |
| | | return; |
| | | } |
| | | |
| | | //Calendar now = Calendar.getInstance(); |
| | | //now.setTimeInMillis(time.getTime()); |
| | | // f.SetField(i, now.get(Calendar.YEAR), now.get(Calendar.MONTH) + 1, now.get(Calendar.DATE), now.get(Calendar.HOUR), now.get(Calendar.MINUTE), now.get(Calendar.SECOND), 8); |
| | | |
| | | LocalDateTime local = time.toLocalDateTime(); |
| | | f.SetField(i, local.getYear(), local.getMonthValue(), local.getDayOfMonth(), local.getHour(), local.getMinute(), local.getSecond(), 8); |
| | | } |
| | | } |