java操作mysql数据库

java操作mysql数据库

学习到数据库操作这一章,遇到了很多问题,只能说无论什么时候,用什么工具来操作数据库,都不是一件简单的事情。

简单记录一下

数据库连接

先看代码界面

java操作mysql数据库

要连接数据库,首先需要导入mysql依赖包,在左侧项目文件内我新建了一个lib文件夹,然后在里面放了一个mysql的依赖包,这个依赖包的版本很重要,如果安装的mysql版本过高,而这个依赖包版本过低,就会各种报错。这里我折腾了好几次,找了一个与mysql版本一致的依赖包,加载依赖包的方式可以参考这篇博客,写的很好,我一次就成功了。

我先放一下代码

package Number;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class Conn {
    public static void main(String[] args) {
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            String url = "jdbc:mysql://127.0.0.1:3306/test?serverTimezone=GMT";
            String username = "root";
            String password = "我是马赛克";
            Connection c = DriverManager.getConnection(url, username, password);
            System.out.println(c);
            c.close();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }
}

来解释代码

  • ```Class.forName(“com.mysql.cj.jdbc.Driver”);这一行代码是用来加载驱动程序的,书本上使用的是下面这句代码Class.forName(“com.mysql.jdbc.Driver”);`没有cj,我运行了一下,虽然没有报错,但提示不赞成这么写,百度了一下,说是因为高版本的mysql依赖包不赞成这种写法,所以换成了程序中的写法;

  • String url = "jdbc:mysql://127.0.0.1:3306/test?serverTimezone=GMT";这是另外一个坑点,重点解释一下:

    1. 127.0.0.1:3306这是主机名和mysql默认的端口号,一般访问本机的mysql就这么写没毛病;

    2. test是数据库名;

    3. ?serverTimezone=GMT这个接口参数很重要,看参数名字说的是服务器的时区,必须得加上,不加上也是一直报错

      UTC代表的是全球标准时间,是以原子时计时,更加精准,适应现代社会的精确计时。GMT格林威治标准时间,是指位于伦敦郊区的皇家格林尼治天文台的标准时间。但是我们使用的时间是北京时区也就是东八区,领先UTC和GMT八个小时。

暂时就这么多,待补充后续。

数据库查询

连接上了,查询就相对简单多了,直接记录代码:

package Number;

import java.sql.*;

public class Conn {
    public static void main(String[] args) {
        Statement st;
        ResultSet rs;
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            String url = "jdbc:mysql://127.0.0.1:3306/test?serverTimezone=GMT";
            String username = "root";
            String password = "我是马赛克";
            Connection c = DriverManager.getConnection(url, username, password);
            st = c.createStatement();
            rs = st.executeQuery("select * from stu_stu");
//            System.out.println(c);
            while(rs.next()){
                System.out.println(rs.getInt("id")
                + rs.getString(2) + rs.getString("sex"));
            }
            c.close();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }
}

查询的逻辑是:

  1. 创建一个连接数据库的对象c
  2. 对象c实现createStatement()方法获得Statement对象st
  3. Statement对象执行查询语句,结果保存在ResultSet结果集中
  4. 用next()方法可以遍历结果集

增改删操作

与查询很类似,只不过用的都是executeUpdate()方法,返回的是一个int值,告诉你有几行数据被修改,上面的查询返回的是一个ResultSet结果集,看代码

package Number;

import java.sql.*;

public class Conn {
    public static void main(String[] args) {
        Statement st;
        ResultSet rs;
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
            String url = "jdbc:mysql://127.0.0.1:3306/test?serverTimezone=GMT";
            String username = "root";
            String password = "我是马赛克";
            Connection c = DriverManager.getConnection(url, username, password);
            st = c.createStatement();
//            rs = st.executeQuery("select * from stu_stu");
//            System.out.println(c);
//            while(rs.next()){
//                System.out.println(rs.getInt("id")
//                + rs.getString(2) + rs.getString("sex"));
//            }
            // 插入数据
//            String insert = "insert into stu_stu(name, sex) values('tom','男'), ('mary', '女')" ;
//            int result1 = st.executeUpdate(insert);
//            System.out.println(result1 + "行数据被插入");
            // 修改数据
//            String modify = "update stu_stu set id = 4 where name = 'tom'";
//            int result2 = st.executeUpdate(modify);
//            System.out.println(result2 + "行数据被修改");
            // 删除数据
            String remove = "delete from stu_stu where name = 'mary'";
            int result3 = st.executeUpdate(remove);
            System.out.println(result3 + "行数据被删除");
//            System.out.println(insert);
            c.close();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    }
}

修改数据后的结果:
java操作mysql数据库
删除数据后的结果:

java操作mysql数据库

上一篇:齐博x1标签实例:做模板组图单图无图混排的处理


下一篇:JDBC调用存储过程