jdbc怎么动态的创建一个数据库?

发布网友发布时间：2022-04-23 11:30

共1个回答

热心网友时间：2022-05-01 03:45

package com.cn.javaEE.dataSource;
import java.sql.Connection;import java.sql.DriverManager;import
java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;
public class CreateDataSource {
/*** @param args*/public static void main(String[] args) {  // TODO
Auto-generated method stub  String database = "test2";  new
CreateDataSource().getConn(database);}
String mysqlDriver = "com.mysql.jdbc.Driver";String url =
"jdbc:mysql://localhost:3306/test1";String newUrl =
"jdbc:mysql://localhost:3306/";String username = "root";String password =
"root";Connection conn = null;Connection newConn = null;
public Connection getConn(String database) {
  try {   Class.forName(mysqlDriver);  } catch (ClassNotFoundException e) {
// TODO Auto-generated catch block   e.printStackTrace();  }  try {   String
tableSql = "create table t_user (username varchar(50) not null primary key,"
+ "password varchar(20) not null ); ";   String databaseSql = "create database
" + database;
   conn = DriverManager.getConnection(url, username, password);   Statement
smt = conn.createStatement();   if (conn != null) {
System.out.println("数据库连接成功！");
    smt.executeUpdate(databaseSql);
    newConn = DriverManager.getConnection(newUrl + database,      username,
password);    if (newConn != null) {     System.out.println("已经连接到新创建的数据库：" +
database);
     Statement newSmt = newConn.createStatement();     int i =
newSmt.executeUpdate(tableSql);//DDL语句返回值为0;     if (i == 0) {
System.out.println(tableSql + "表已经创建成功！");     }    }   }
  } catch (SQLException e1) {   // TODO Auto-generated catch block
e1.printStackTrace();  }  return conn;}}