JDBC中创建表

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;  } }

转载于:https://www.cnblogs.com/1x-zfd50/p/6282155.html