ahdoawhfo/netdisk-fast-download
1
0
Fork 0
mirror of https://github.com/qaiu/netdisk-fast-download.git synced 2025-12-16 12:23:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

do db

Browse Source
This commit is contained in:
QAIU
2023-05-12 17:30:10 +08:00
parent bada4d7e4a
commit 9c236d0663
5 changed files with 100 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
core-database/src/main/java/cn/qaiu/db/pool/JDBCPoolInit.java
View File

@@ -88,7 +88,14 @@ public class JDBCPoolInit {
}
private void poolInitExecute(Promise<String> promise) {
// 初始化H2db, 创建本地db文件
// 初始化连接池
pool = JDBCPool.pool(vertx, dbConfig);
CreateTable.createTable(pool, dbConfig.getString("tableClassPath"));
promise.complete("init jdbc pool success");
}
private void checkOrCreateDBFile() {
LOGGER.info("init sql start");
String[] path = url.split("\\./");
path[1] = path[1].split(";")[0];
@@ -109,14 +116,12 @@ public class JDBCPoolInit {
throw new RuntimeException("file create failed");
}
}
// 初始化连接池
pool = JDBCPool.pool(vertx, dbConfig);
CreateTable.createTable(pool, dbConfig.getString("tableClassPath"));
promise.complete("init jdbc pool success");
}
private void h2serverExecute(Promise<String> promise) {
// 初始化H2db, 创建本地db文件
checkOrCreateDBFile();
try {
String url = dbConfig.getString("jdbcUrl");
String[] portStr = url.split(":");