|
|
|
@ -30,6 +30,16 @@ public class Step3_DataSetFakeData {
|
|
|
|
|
Db.use(DataEaseModel.DB_NAME).batchSave(table_name, list, 100);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 删除某地数据
|
|
|
|
|
* @param table_name
|
|
|
|
|
* @param area_name
|
|
|
|
|
*/
|
|
|
|
|
public static void deleteData(String table_name, String area_name) {
|
|
|
|
|
String sql = "delete from `" + table_name + "` where `行政区划`='" + area_name + "'";
|
|
|
|
|
Db.use(DataEaseModel.DB_NAME).update(sql);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public static void main(String[] args) throws IOException {
|
|
|
|
|
//切换至测试数据库
|
|
|
|
|
//DataEaseModel.DB_NAME = "dataease_huanghai";
|
|
|
|
@ -61,8 +71,7 @@ public class Step3_DataSetFakeData {
|
|
|
|
|
String table_name = record.getStr("table_name");
|
|
|
|
|
System.out.println("正在处理数据集:" + table_name);
|
|
|
|
|
//检查这个行政区划,在本数据表中是不是存在过,判断办法是 列名: `行政区划`= area_name,如果存在则不作处理,否则拷贝昆明市的数据
|
|
|
|
|
String sql = "delete from `" + table_name + "` where `行政区划`='" + area_name + "'";
|
|
|
|
|
Db.use(DataEaseModel.DB_NAME).update(sql);
|
|
|
|
|
deleteData(table_name, area_name);
|
|
|
|
|
CopyData(table_name, "昆明市", area_name, "云南省");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
@ -85,9 +94,8 @@ public class Step3_DataSetFakeData {
|
|
|
|
|
for (Record record : list) {
|
|
|
|
|
String table_name = record.getStr("table_name");
|
|
|
|
|
System.out.println(area_name + "正在处理数据集:" + table_name);
|
|
|
|
|
//检查这个行政区划,在本数据表中是不是存在过,判断办法是 列名: `行政区划`= area_name,如果存在则不作处理,否则拷贝昆明市的数据
|
|
|
|
|
String sql = "delete from `" + table_name + "` where `行政区划`='" + area_name + "'";
|
|
|
|
|
Db.use(DataEaseModel.DB_NAME).update(sql);
|
|
|
|
|
//检查这个行政区划,在本数据表中是不是存在过,判断办法是 列名: `行政区划`= area_name,如果存在则不作处理,否则拷贝寻甸县的数据
|
|
|
|
|
deleteData(table_name, area_name);
|
|
|
|
|
CopyData(table_name, "寻甸县", area_name, parent_name);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|