code-image-backup-public/fastbee
1
0
Fork 0
mirror of https://gitee.com/beecue/fastbee.git synced 2025-12-17 16:36:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

2022年5月24日14:34:18 增加初始化时创建数据库功能

Browse Source
This commit is contained in:
wxy001
2022-05-24 15:28:39 +08:00
parent 4dde2bd121
commit 14197e7436
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
springboot/wumei-iot/src/main/java/com/ruoyi/iot/tdengine/init/ApplicationStarted.java
View File

@@ -52,9 +52,9 @@ public class ApplicationStarted implements ApplicationRunner {
this.dataSource = applicationContext.getBean("tDengineDataSource", DruidDataSource.class); this.dataSource = applicationContext.getBean("tDengineDataSource", DruidDataSource.class);
this.deviceLogMapper= applicationContext.getBean(TDDeviceLogDAO.class); this.deviceLogMapper= applicationContext.getBean(TDDeviceLogDAO.class);
initTDengine(this.dengineConfig.getDbName()); initTDengine(this.dengineConfig.getDbName());
System.out.println("初始化TDengine成功"); LOGGER.info("使用TDengine存储设备数据，初始化成功");
} else { }else{
System.out.println("MySQL初始化成功"); LOGGER.info("使用MySql存储设备数据，初始化成功");
} }
} }
@@ -72,9 +72,10 @@ public class ApplicationStarted implements ApplicationRunner {
//创建数据库表 //创建数据库表
deviceLogMapper.createSTable(dbName); deviceLogMapper.createSTable(dbName);
System.out.println("完成超级表的创建"); System.out.println("完成超级表的创建");
LOGGER.info("完成超级表的创建");
} catch (Exception e) { } catch (Exception e) {
LOGGER.info("错误",e.getMessage());
e.printStackTrace(); e.printStackTrace();
System.out.println("ERROR");
} }
} }
@@ -109,10 +110,10 @@ public class ApplicationStarted implements ApplicationRunner {
Connection conn = DriverManager.getConnection(newJdbcUrl, connProps); Connection conn = DriverManager.getConnection(newJdbcUrl, connProps);
conn.createStatement().execute(String.format("create database if not exists %s;",dbName)); conn.createStatement().execute(String.format("create database if not exists %s;",dbName));
conn.close(); conn.close();
System.out.println("完成数据库创建"); LOGGER.info("完成数据库创建");
} catch (Exception e) { } catch (Exception e) {
LOGGER.info("错误",e.getMessage());
e.printStackTrace(); e.printStackTrace();
System.out.println("ERROR");
} }
} }