java怎么连接mysql数据库

下载mysql的JDBC驱动包，引入JDBC驱动包

public class TestMySql {

  static Connection con = null;

  static Statement sql = null;

  static ResultSet res = null;

  public static void main(String[] args) {

    TestMySql c = new TestMySql();

    con = cgetConnection();

    try {

      sql = concreateStatement();

      res = sqlexecuteQuery("select  from dept");

      while (resnext()) {

        Systemoutprint(resgetString(1) + "<——>");

        Systemoutprint(resgetString(2) + "<——>");

        Systemoutprint(resgetString(3) );

        Systemoutprintln();

      }

    } catch (SQLException e) {

      eprintStackTrace();

    } finally {

      try {

        if (res != null) {

          resclose();

          res =null;

        }

        if (sql != null) {

          sqlclose();

          sql =null;

        }

        if (con != null) {

          conclose();

          con =null;

        }

      } catch (SQLException e) {

        eprintStackTrace();

      }

    }

  }

  public Connection getConnection() {

    try {

      ClassforName("commysqljdbcDriver");

      // 加载mysqlJDBC驱动

      Systemoutprintln("数据库驱动加载成功");

    } catch (ClassNotFoundException e) {

      eprintStackTrace();

    }

    try {// 通过访问数据库的URL获取数据库连接对象

      con = DriverManagergetConnection(

          "jdbc:mysql://localhost:3306/mydata", "root", "qwer1234");

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

    } catch (SQLException e) {

      eprintStackTrace();

    }

    return con; // 按方法要求返回一个Connection对象

  }

}

参考代码：

package 数据库编程;

import javasql;

public class 数据库连接 {

public static void main(String[] args) throws SQLException{

//1加载驱动程序

try {

ClassforName("commysqljdbcDriver");

} catch (ClassNotFoundException e) {

// TODO Auto-generated catch block

eprintStackTrace();

}

//2创建与DB数据库的连接

//连接字符串

String url="jdbc:mysql://1921681101:3306/java数据库user=root&password=humin";

Connection con=DriverManagergetConnection(url);

//进行读写

if(!conisClosed()){

Systemoutprint("欢迎访问数据库！\n想做什么啊………………\n");

Statement st=concreateStatement();

ResultSet rs= stexecuteQuery("select from stu");

while(rsnext()){

Systemoutprint( rsgetString("stuid")+","+rsgetString("name")+","+rsgetString("sex")+","+rsgetString("age")+","+rsgetString("address")+","+rsgetString("tel")+"\n");

}

}

//关闭数据库

conclose();

}

}

工具：eclipse

MySQL56

MySQL连接驱动：mysql-connector-java-5127jar

加载驱动：

1 在工程目录中创建lib文件夹，将下载好的JDBC放到该文件夹下，如下图所示：

2 右键工程名，在java build path中的Libraries分页中选择Add JARs，选择刚才添加的JDBC，如下图：

数据包准备：

在数据库sqltestdb中创建如下数据表emp:

1

2

3

4

5

6

7

CREATE TABLE emp(

empno INT(4) PRIMARY KEY,

ename VARCHAR(10),

job VARCHAR(9),

hiredate DATE,

sal FLOAT(7,2)

) ;

添加数据：

连接数据库并读取数据：

数据库名称：sqltestdb

数据包名称：emp

端口号：3306

用户名：root

密码：root

1 package sqldemo;

2

3 import javasqlConnection;

4 import javasqlDriverManager;

5 import javasqlResultSet;

6 import javasqlSQLException;

7 import javasqlStatement;

8

9 public class main {

10

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

12 //声明Connection对象

13 Connection con;

14 //驱动程序名

15 String driver = "commysqljdbcDriver";

16 //URL指向要访问的数据库名mydata

17 String url = "jdbc:mysql://localhost:3306/sqltestdb";

18 //MySQL配置时的用户名

19 String user = "root";

20 //MySQL配置时的密码

21 String password = "123456";

22 //遍历查询结果集

23 try {

24 //加载驱动程序

25 ClassforName(driver);

26 //1getConnection()方法，连接MySQL数据库！！

27 con = DriverManagergetConnection(url,user,password);

28 if(!conisClosed())

29 Systemoutprintln("Succeeded connecting to the Database!");

30 //2创建statement类对象，用来执行SQL语句！！

31 Statement statement = concreateStatement();

32 //要执行的SQL语句

33 String sql = "select from emp";

34 //3ResultSet类，用来存放获取的结果集！！

35 ResultSet rs = statementexecuteQuery(sql);

36 Systemoutprintln("-----------------");

37 Systemoutprintln("执行结果如下所示:");

38 Systemoutprintln("-----------------");

39 Systemoutprintln("姓名" + "\t" + "职称");

40 Systemoutprintln("-----------------");

41

42 String job = null;

43 String id = null;

44 while(rsnext()){

45 //获取stuname这列数据

46 job = rsgetString("job");

47 //获取stuid这列数据

48 id = rsgetString("ename");

49

50 //输出结果

51 Systemoutprintln(id + "\t" + job);

52 }

53 rsclose();

54 conclose();

55 } catch(ClassNotFoundException e) {

56 //数据库驱动类异常处理

57 Systemoutprintln("Sorry,can`t find the Driver!");

58 eprintStackTrace();

59 } catch(SQLException e) {

60 //数据库连接失败异常处理

61 eprintStackTrace();

62 }catch (Exception e) {

63 // TODO: handle exception

64 eprintStackTrace();

65 }finally{

66 Systemoutprintln("数据库数据成功获取！！");

67 }

68 }

69

70 }

运行结果：

1

2

3

4

5

6

7

8

9

10

11

12

13

14

Succeeded connecting to the Database!

-----------------

执行结果如下所示:

-----------------

姓名 职称

-----------------

李兴华 经理

张三 总监

王五 厂长

齐秦 书记

张刚 组长

曹 *** 财务

李四 总裁

数据库数据成功获取！！

增加、删除和修改数据：

增加数据：

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

String name;

String id;

PreparedStatement psql;

ResultSet res;

//预处理添加数据，其中有两个参数--“？”

psql = conprepareStatement("insert into emp (empno,ename,job,hiredate,sal) "

+ "values(,,,,)");

psqlsetInt(1, 3212); //设置参数1，创建id为3212的数据

psqlsetString(2, "王刚"); //设置参数2，name 为王刚

psqlsetString(3, "总裁");

DateFormat dateFormat2 = new SimpleDateFormat("yyyy-MM-dd");

Date myDate2 = dateFormat2parse("2010-09-13");

psqlsetDate(4,new javasqlDate(myDate2getTime()));

psqlsetFloat(5, (float) 20003);

psqlexecuteUpdate(); //执行更新

运行结果：

更新数据：

PreparedStatement psql;

//预处理更新（修改）数据，将王刚的sal改为50000

psql = conprepareStatement("update emp set sal = where ename = ");

psqlsetFloat(1,(float) 50000);

psqlsetString(2,"王刚");

psqlexecuteUpdate();

更改结果：

删除数据：

PreparedStatement psql;

//预处理删除数据

psql = conprepareStatement("delete from emp where sal > ");

psqlsetFloat(1, 4500);

psqlexecuteUpdate();

psqlclose();

删除结果：

原因：tomcat找不到MYSQL JAR包

解决方法：如果建的是web工程，把mysql-connector-java-505-binjar导入到tomcat的lib目录下，如果是java工程，请右键build path--add active 那个选项并找到你的文件，点击打开即可

使用java连接MySQL数据库与其他的数据库连接核心是一样的，如果说区别，那就是所需的驱动不一样。

工具/原料

MySQL、JDK

方法/步骤

1、首先需要安装好JDK（配置环境变量）,如图所示：

2、其次要安装好MySQL数据库，可以使用可视化Navicar For MySQL，如图所示：

3、最后通过代码进行连接。

（1）确定连接路径URL：

String url="jdbc:mysql://localhost(可以是本机IP地址):3306(端口号)/mysqltest(数据库名称)？"+"user=用户账号&password=用户密码&useUnicode=字符编码";

（2）加载驱动：

ClassforName("commysqljdbcDriver");

（3）连接，获取Connection对象

Connection conn=DriverManagergetConnection(url)

（4）可以通过conn对象检验连接与否。

以上就是关于java怎么连接mysql数据库全部的内容，包括:java怎么连接mysql数据库、如何在Java程序中访问mysql数据库中的数据并进行简单的 *** 作、java怎么连mysql数据库等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！