通过java代码如何实现对mysql数据库进行创建新的数据库的 *** 作

1 import javasqlConnection;

2 import javasqlDriverManager;

3 import javasqlResultSet;

4 import javasqlSQLException;

5 import javasqlStatement;

6

7 public class CreateDataSource {

8

9 /

10 @param args

11 /

12 public static void main(String[] args) {

13 // TODO Auto-generated method stub

14 String database = "test2";

15 new CreateDataSource()getConn(database);

16 }

17

18 String mysqlDriver = "commysqljdbcDriver";

19 String url = "jdbc:mysql://localhost:3306/test1";

20 String newUrl = "jdbc:mysql://localhost:3306/";

21 String username = "root";

22 String password = "root";

23 Connection conn = null;

24 Connection newConn = null;

25

26 public Connection getConn(String database) {

27

28 try {

29 ClassforName(mysqlDriver);

30 } catch (ClassNotFoundException e) {

31 // TODO Auto-generated catch block

32 eprintStackTrace();

33 }

34 try {

35 String tableSql = "create table t_user (username varchar(50) not null primary key,"

36 + "password varchar(20) not null ); ";

37 String databaseSql = "create database " + database;

38

39 conn = DriverManagergetConnection(url, username, password);

40 Statement smt = conncreateStatement();

41 if (conn != null) {

42 Systemoutprintln("数据库连接成功!");

43

44 smtexecuteUpdate(databaseSql);

45

46 newConn = DriverManagergetConnection(newUrl + database,

47 username, password);

48 if (newConn != null) {

49 Systemoutprintln("已经连接到新创建的数据库：" + database);

50

51 Statement newSmt = newConncreateStatement();

52 int i = newSmtexecuteUpdate(tableSql);//DDL语句返回值为0;

53 if (i == 0) {

54 Systemoutprintln(tableSql + "表已经创建成功!");

55 }

56 }

57 }

58

59 } catch (SQLException e1) {

60 // TODO Auto-generated catch block

61 e1printStackTrace();

62 }

63 return conn;

64 }

65 }

建立数据库？？

是数据库连接吧？

public static Connection getConnection()

{

try

{

ClassforName("oraclejdbcdriverOracleDriver");

return DriverManagergetConnection("jdbc:oracle:thin:@192168110:1521:数据库实例名", "数据库登录名","数据库登陆密码");

catch (Exception e)

{

eprintStackTrace();

}

return null;

}

你的管理系统上应该有输入框，（比如姓名的输入框），你可以在代码中定义一个变量（比如name）保存姓名输入框上的内容，你在数据库中有一个表叫做user，拼装一个sql，里面包含name信息，比如说是：String sql="insert into user(name) values("+name+")"，执行这个sql，就可已经名称保存到数据库中了

管理系统总该有界面吧，界面上总有输入值的地方吧，把它保存下来放到数据库中就可以了。

我刚写了一个只有插入的，望采纳

import javasql;

import javautil;

public class TestPre {

public static void main(String[] args) {

int i=0,deptno=0;//i只做while循环使用，deptno是表dept2中的一个属性，类型是int

String dname=null,loc=null;//dname和loc也是表dept2的属性，类型是String

Scanner s=new Scanner(Systemin);

Systemoutprintln("请输入3个参数");

while(i<3){

try{

deptno=snextInt();

i++;

dname=snext();

i++;

loc=snext();

i++;

}catch(InputMismatchException e){

Systemoutprintln("输入的类型不符,退出");

Systemexit(-1);

}

}

Connection conn=null;

PreparedStatement pstmt=null;

try {

ClassforName("commysqljdbcDriver");

conn = DriverManagergetConnection("jdbc:mysql://localhost/mydata"+ "user=root&password=root");

pstmt=connprepareStatement("insert into dept2 values(,,)");

pstmtsetInt(1, deptno);

pstmtsetString(2, dname);

pstmtsetString(3, loc);

pstmtexecuteUpdate();

Systemoutprintln("插入完成");

} catch (ClassNotFoundException e) {

Systemoutprintln("连接数据库不成功，程序退出");

Systemexit(-1);

} catch (SQLException e) {

Systemoutprintln("连接数据库不成功，程序退出");

Systemexit(-1);

}

finally{

try{

if(pstmt!=null){

pstmtclose();

pstmt=null;

}

if(conn!=null){

connclose();

conn=null;

}

}catch(SQLException e){

eprintStackTrace();

}

}

}

}

首先需要这个包，添加到工程。

下面给你示例代码

import javasql;public class SQLiteDemo { public static void main(String[] args){ try{ //连接SQLite的JDBC ClassforName("orgsqliteJDBC"); //建立一个数据库名datadb的连接，如果不存在就在当前目录下创建之 Connection conn = DriverManagergetConnection("jdbc:sqlite:datadb"); connsetAutoCommit(false); Statement stat = conncreateStatement(); statexecuteUpdate( "create table if not exists tbl1 (name varchar(20), salary int);" );//创建一个表，两列 statexecuteUpdate( "insert into tbl1 values('ZhangSan',8000);" ); //插入数据 statexecuteUpdate( "insert into tbl1 values('LiSi',7800);" ); statexecuteUpdate( "insert into tbl1 values('WangWu',5800);" ); statexecuteUpdate( "insert into tbl1 values('ZhaoLiu',9100);" ); ResultSet rs = statexecuteQuery("select from tbl1;"); //查询数据 while (rsnext()) { //将查询到的数据打印出来 Systemoutprint("name = " + rsgetString("name") + " "); //列属性一 Systemoutprintln("salary = " + rsgetString("salary")); //列属性二 } rsclose(); conncommit(); connclose(); //结束数据库的连接 } catch( Exception e ) { eprintStackTrace ( ); } }}

Java程序向数据库中插入数据，代码如下：

//首先创建数据库，(access,oracle,mysql,sqlsever)其中之一，其中access,sqlsever需要配置数据源(odbc);

//然后再eclipse中创建类(ConnDb,Test，TestBean)ConnDb功能为连接数据库，查询，插入，删除，修改数据的类，Test为含有main方法的测试类，TestBean为数据表中的字段属性及set,get方法

//以下是ConnDb代码：

package db;

import javasqlConnection;

import javasqlDriverManager;

import 

javasqlResultSet;

import javasqlSQLException;

import 

javasqlStatement;

import javautilArrayList;

public class ConnDb {

public Connection startConn(Connection conn){

  try {

   ClassforName("sunjdbcodbcJdbcOdbcDriver");

   conn = DriverManagergetConnection("jdbc:odbc:数据库","用户名", "密码");

  } catch (Exception e) {

   Systemoutprintln("连接数据库时出现错误");

  }

  return conn;

 }

 

public ArrayList executeQuery(String sql){

  Connection conn = null;

  Statement stmt = null;

  ResultSet rs = null;

  ArrayList list = new ArrayList();

  try {

   conn = startConn(conn);

   stmt = conncreateStatement();

   rs = stmtexecuteQuery(sql);//sql为sql语句例如"select  from 

表名"，从main方法中传进来，这里用的是ArrayList 类将查询结果存储起来

   while(rsnext()){

    TestBean tb = new TestBean();

    tbsetTid(rsgetString("tid"));

    tbsetTname(rsgetString("tname"));

    tbsetTinfo(rsgetString("tinfo"));

    listadd(tb);

   }

  } 

catch (SQLException e) {

   // TODO Auto-generated catch block

   eprintStackTrace();

  }finally{

   closeConn(rs,stmt,conn);

  }

  return list;

 } 

 public void executeUpdate(String sql){

  Connection conn = null;

  Statement stmt = null;

  try {

   conn = 

startConn(conn);

   stmt = conncreateStatement();

   stmtexecuteUpdate(sql);

  } 

catch (SQLException e) {

   Systemoutprintln("修改，插入或者删除数据库数据时发生错误!");

  }finally{

   closeConn(stmt,conn);

  }

 }

 public void closeConn(ResultSet rs,Statement stmt,Connection conn){

  try {

   if(rs != 

null){

    rsclose();

   }

   if(stmt != null){

    stmtclose();

   }

   if(conn != null){

    connclose();

   }

  } 

catch (SQLException e) {

   // TODO Auto-generated catch 

block

   Systemoutprintln("关闭数据库的时候发生错误!");

  }

 }

 public void closeConn(Statement stmt,Connection conn){

  try {

   if(stmt != null){

    stmtclose();

   }

   if(conn != null){

    connclose();

   }

  } 

catch (SQLException e) {

   // TODO Auto-generated catch block

   Systemoutprintln("关闭数据库的时候发生错误!");

  }

 }

}

Connection conn = 链接

Statement stmt = conncreateStatementI();

String sql = "CREATE TABLE PFO_ANALYSE_BRANCH ( "

+" NODE_NAME_S VARCHAR2(50 BYTE), "

+ 其他字段

+")";

stmtexecute(sql)

以上就是关于通过java代码如何实现对mysql数据库进行创建新的数据库的 *** 作全部的内容，包括:通过java代码如何实现对mysql数据库进行创建新的数据库的 *** 作、用Java怎么建立数据库、如何用java写数据库管理系统等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！