1 /*** @param args */ 2 public static void main(String[] args) { 3 // TODO Auto-generated method stub 4 String database = "test2"; 5 new CreateDataSource().getConn(database); 6 } 7 8 String mysqlDriver = "com.mysql.jdbc.Driver"; 9 // String url = "jdbc:mysql://localhost:3306/test"; 10 String newUrl = "jdbc:mysql://localhost:3306/"; 11 String username = "root"; 12 String password = "root"; 13 Connection conn = null; 14 // Connection newConn = null; 15 16 public Connection getConn(String database) { 17 try { 18 Class.forName(mysqlDriver); 19 } catch (ClassNotFoundException e) { 20 // TODO Auto-generated catch block 21 e.printStackTrace(); 22 } 23 try { 24 String tableSql = "create table t_user (username varchar(50) not null primary key," 25 + "password varchar(20) not null ); "; 26 String databaseSql = "create database " + database; 27 conn = DriverManager.getConnection(newUrl, username, password); 28 Statement smt = conn.createStatement(); 29 if (conn != null) { 30 System.out.println("数据库连接成功!"); 31 smt.executeUpdate(databaseSql); 32 conn = DriverManager.getConnection(newUrl + database, username, password); 33 if (conn != null) { 34 System.out.println("已经连接到新创建的数据库:" + database); 35 Statement newSmt = conn.createStatement(); 36 int i = newSmt.executeUpdate(tableSql);// DDL语句返回值为0; 37 if (i == 0) { 38 System.out.println(tableSql + "表已经创建成功!"); 39 } 40 } 41 } 42 } catch (SQLException e1) { 43 // TODO Auto-generated catch block 44 e1.printStackTrace(); 45 } 46 return conn; 47 }
原文:https://www.cnblogs.com/clearsice/p/11484397.html