main
黄海 9 months ago
parent b7b916aadc
commit 63dd87242d

@ -15,7 +15,7 @@ public class ChangUrlLink {
public static DataEaseModel dm = new DataEaseModel();
public static void main(String[] args) throws IOException, JSchException {
LocalMysqlConnectUtil.Init();
LocalMysqlConnectUtil.Init(null);
//原地址
String sourceHost = "http://10.10.21.20:9000/dsBase/";
//目标地址

@ -16,7 +16,7 @@ public class DataSetAddXzqh {
public static DataEaseModel dm = new DataEaseModel();
public static void main(String[] args) throws IOException, JSchException {
LocalMysqlConnectUtil.Init();
LocalMysqlConnectUtil.Init(null);
//遍历所有以excel_开头的表找出这些表中是不是存在行政区划,上级行政区划的列名
for (int identity_id : new int[]{1, 2, 3}) {

@ -28,7 +28,7 @@ public class DataSetFakeData {
}
public static void main(String[] args) throws IOException {
LocalMysqlConnectUtil.Init();
LocalMysqlConnectUtil.Init("dataease_huanghai");
DataEaseModel dm = new DataEaseModel();
//这几个是要保留的地名

@ -9,7 +9,7 @@ public class DataSetInit {
public static DataEaseModel dm = new DataEaseModel();
public static void main(String[] args) throws IOException {
LocalMysqlConnectUtil.Init();
LocalMysqlConnectUtil.Init(null);
//1、添加到数据集表中
dm.collectDataSet();
//2、加上主键

@ -24,7 +24,7 @@ public class InitOrgPerson {
public static Prop PropKit;
public static void main(String[] args) throws Exception {
LocalMysqlConnectUtil.Init();
LocalMysqlConnectUtil.Init(null);
// 用于缓存模块的redis服务
RedisPlugin redis = new RedisPlugin("myRedis", PropKit.get("redis.ip"), PropKit.getInt("redis.port"), 10 * 1000);

@ -14,7 +14,7 @@ public class ExportExcel {
public static DataEaseModel dm = new DataEaseModel();
public static void main(String[] args) throws IOException, JSchException {
LocalMysqlConnectUtil.Init();
LocalMysqlConnectUtil.Init(null);
//Excel的保存目录
String exportPath = "D:/360Downloads/Excel";

@ -4,6 +4,7 @@ import com.dsideal.base.DataEase.Model.DataEaseModel;
import com.dsideal.base.Plugin.YamlProp;
import com.dsideal.base.Tools.DataSetInit;
import com.jfinal.kit.Prop;
import com.jfinal.kit.StrKit;
import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
import com.jfinal.plugin.hikaricp.HikariCpPlugin;
@ -13,14 +14,15 @@ import java.io.File;
public class LocalMysqlConnectUtil {
public static Prop PropKit;
public static void Init() {
public static void Init(String database_dbName) {
//加载配置文件
String configFile = "application.yaml";
PropKit = new YamlProp(configFile);
if (StrKit.isBlank(database_dbName)) database_dbName = "dataease";
HikariCpPlugin masterPlugin = new HikariCpPlugin(PropKit.get("mysql.jdbcUrl"), PropKit.get("mysql.user"),
PropKit.get("mysql.password").trim(), PropKit.get("mysql.driverClassName"));
HikariCpPlugin dataEasePlugin = new HikariCpPlugin(PropKit.get("mysql.jdbcUrl").replace("ds_db", "dataease"), PropKit.get("mysql.user"),
HikariCpPlugin dataEasePlugin = new HikariCpPlugin(PropKit.get("mysql.jdbcUrl").replace("ds_db", database_dbName), PropKit.get("mysql.user"),
PropKit.get("mysql.password").trim(), PropKit.get("mysql.driverClassName"));
masterPlugin.start();

Loading…
Cancel
Save