使用Java实现动态生成MySQL数据库

/*
  TenantDatabaseDTO 用于传递租户数据库相关的信息。
 */
public class TenantDatabaseDTO {
    // 数据库名称
    private String tenantDatabase;
    // 数据库用户
    private String dbUser;
    // 数据库密码
    private String dbPass;
    // 管理员名称
    private String adminName;
    // 管理员密码
    private String adminPass;
    // 名称
    private String tenantName;
    // 数据库连接 URL
    private String url;
}

// url
String url = "jdbc:mysql://" + host + ":" + port + "/";

// 数据库账户密码
String username = "root";
String password = "1234";

// 获取数据库连接
Connection conn = DriverManager.getConnection(url, username, password);
// 执行语句对象
Statement stmt = null;
// 关闭自动提交事务
conn.setAutoCommit(false);
// 创建执行语句对象
stmt = conn.createStatement();

// 数据库名称
String database = "newDataBase";
// 创建库
String createDatabaseSQL = "CREATE DATABASE IF NOT EXISTS `" + database + "` DEFAULT CHARSET utf8mb4 COLLATE utf8mb4_general_ci;";
// 执行语句
stmt.execute(createDatabaseSQL);

String databasePassword = "1234";
// 在这里要创建用户，并且存入相应用户和密码
String userSQL = "CREATE USER '" + database + "'@'localhost' IDENTIFIED BY '" + databasePassword + "';";
stmt.execute(userSQL);

//用户授权
String grantSQL = "GRANT select, insert, update, delete ON " + database + ".* TO '" + database + "'@'localhost'";
stmt.execute(grantSQL);

// 切换到数据库
conn.setCatalog(tenantDatabase);

ScriptRunner runner = new ScriptRunner(connection);
// 禁用一般日志
runner.setLogWriter(null);
// 禁用错误日志
runner.setErrorLogWriter(null);
// 从资源中获取 SQL 脚本的 Reader，位于 resources 目录下 init-sql-script下的文件，读取之后并执行。
Reader reader = Resources.getResourceAsReader("init-sql-script/erp-crm-tenant-sample.sql");
// 最后记得将事务提交
conn.commit();

SqlRunner sqlRunner = new SqlRunner(conn);
//插入部门
String insertSql = "INSERT INTO sys_dept VALUES (100, 0, '0', '" + tenantDatabaseDTO.getTenantName() + "', 0, '" + tenantDatabaseDTO.getTenantName() + "', '00000000000', 'admin@admin.com', '0', '0', 'admin', '" + DateUtils.getTime() + "', 'admin', '" + DateUtils.getTime() + "');";
sqlRunner.run(insertSql);