package com.cn.javaEE.dataSource;
import
java.sql.Connection;
import
java.sql.DriverManager;
import j
ava.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;
c
onn = 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;
}
}