test():企业入驻时创库创表修改
parent
dc26138929
commit
e2fc097b14
|
@ -0,0 +1,44 @@
|
||||||
|
package com.muyu.cloud.common.many.datasource;
|
||||||
|
|
||||||
|
import com.muyu.cloud.common.many.datasource.constents.DatasourceContent;
|
||||||
|
import lombok.extern.log4j.Log4j2;
|
||||||
|
|
||||||
|
import java.sql.Connection;
|
||||||
|
import java.sql.DriverManager;
|
||||||
|
import java.sql.SQLException;
|
||||||
|
import java.sql.Statement;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 测试添加数据源
|
||||||
|
* @author 袁子龙
|
||||||
|
* @package com.muyu.cloud.common.many.datasource
|
||||||
|
* @name JDBCDemo
|
||||||
|
* @date 2024/9/30 18:14
|
||||||
|
*/
|
||||||
|
@Log4j2
|
||||||
|
public class JDBCDemo {
|
||||||
|
public static void main(String[] args) {
|
||||||
|
String databaseName = "my_database";
|
||||||
|
|
||||||
|
String connectUrl = DatasourceContent.getDatasourceUrl("mysql");
|
||||||
|
|
||||||
|
String createDatabaseUrl = "jdbc:mysql://" + DatasourceContent.IP + ":" + DatasourceContent.PORT + "?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8";
|
||||||
|
String createDatabaseSql = "CREATE DATABASE IF NOT EXISTS " + databaseName + ";";
|
||||||
|
|
||||||
|
try (Connection adminConn = DriverManager.getConnection(createDatabaseUrl, DatasourceContent.USER_NAME, DatasourceContent.PASSWORD);
|
||||||
|
Statement stmt = adminConn.createStatement()) {
|
||||||
|
|
||||||
|
boolean success = stmt.execute(createDatabaseSql);
|
||||||
|
if (success) {
|
||||||
|
log.info("数据库 {} 创建成功", databaseName);
|
||||||
|
|
||||||
|
} else {
|
||||||
|
log.warn("数据库 {} 创建失败,可能已存在或权限不足", databaseName);
|
||||||
|
}
|
||||||
|
|
||||||
|
} catch (SQLException e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
log.error("连接数据库时发生错误或创建数据库失败", e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
|
@ -1,3 +0,0 @@
|
||||||
com.muyu.cloud.common.saas.interceptor.WebMvcSaaSConfig
|
|
||||||
com.muyu.cloud.common.many.datasource.ManyDataSource
|
|
||||||
com.muyu.cloud.common.many.datasource.factory.DruidDataSourceFactory
|
|
Loading…
Reference in New Issue