使用Java實現(xiàn)動態(tài)生成MySQL數(shù)據(jù)庫
Java 動態(tài)生成 MYsql 數(shù)據(jù)庫
首先準備一個類,表示用于生成數(shù)據(jù)庫等操作。
/*
TenantDatabaseDTO 用于傳遞租戶數(shù)據(jù)庫相關的信息。
*/
public class TenantDatabaseDTO {
// 數(shù)據(jù)庫名稱
private String tenantDatabase;
// 數(shù)據(jù)庫用戶
private String dbUser;
// 數(shù)據(jù)庫密碼
private String dbPass;
// 管理員名稱
private String adminName;
// 管理員密碼
private String adminPass;
// 名稱
private String tenantName;
// 數(shù)據(jù)庫連接 URL
private String url;
}接下來我們開始連接數(shù)據(jù)庫操作
我們首先創(chuàng)建數(shù)據(jù)庫連接,Statement 是執(zhí)行語句對象,用于執(zhí)行 sql,Connection 是連接對象,可以通過 setAutoCommit 開啟一個事務,也就是不會自動提交。
// url String url = "jdbc:mysql://" + host + ":" + port + "/"; // 數(shù)據(jù)庫賬戶密碼 String username = "root"; String password = "1234"; // 獲取數(shù)據(jù)庫連接 Connection conn = DriverManager.getConnection(url, username, password); // 執(zhí)行語句對象 Statement stmt = null; // 關閉自動提交事務 conn.setAutoCommit(false); // 創(chuàng)建執(zhí)行語句對象 stmt = conn.createStatement();
創(chuàng)建數(shù)據(jù)庫
我們拼接一個 SQL 用于創(chuàng)建一個數(shù)據(jù)庫,通過執(zhí)行語句的 execute 方法執(zhí)行,由于我們開啟了事務,最后提交事務才能完成創(chuàng)建。
// 數(shù)據(jù)庫名稱 String database = "newDataBase"; // 創(chuàng)建庫 String createDatabaseSQL = "CREATE DATABASE IF NOT EXISTS `" + database + "` DEFAULT CHARSET utf8mb4 COLLATE utf8mb4_general_ci;"; // 執(zhí)行語句 stmt.execute(createDatabaseSQL);
這里由于我的業(yè)務需要給特定的數(shù)據(jù)庫做專門的賬戶密碼,所以下面需要再次執(zhí)行兩個,創(chuàng)建用戶以及分配該數(shù)據(jù)的權限
String databasePassword = "1234"; // 在這里要創(chuàng)建用戶,并且存入相應用戶和密碼 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);
切換到剛剛的數(shù)據(jù)庫
// 切換到數(shù)據(jù)庫 conn.setCatalog(tenantDatabase);
執(zhí)行 SQL 腳本
ScriptRunner 類用于執(zhí)行SQL腳本,需要和數(shù)據(jù)庫連接 Connection 一起使用。因為需要傳遞連接器。
ScriptRunner runner = new ScriptRunner(connection);
// 禁用一般日志
runner.setLogWriter(null);
// 禁用錯誤日志
runner.setErrorLogWriter(null);
// 從資源中獲取 SQL 腳本的 Reader,位于 resources 目錄下 init-sql-script下的文件,讀取之后并執(zhí)行。
Reader reader = Resources.getResourceAsReader("init-sql-script/erp-crm-tenant-sample.sql");
// 最后記得將事務提交
conn.commit();
小技巧
這樣也可以更好的提交數(shù)據(jù)。
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);
到此這篇關于使用Java實現(xiàn)動態(tài)生成MySQL數(shù)據(jù)庫的文章就介紹到這了,更多相關Java生成MySQL數(shù)據(jù)庫內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
oracle+mybatis-plus+springboot實現(xiàn)分頁查詢的實例
本文主要介紹了oracle+mybatis-plus+springboot實現(xiàn)分頁查詢,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2021-08-08

