• MySQL之JDBC及常见错误


    JDBC

    什么是JDBC

    Java Data Base Connectivity:Java数据库连接

    JDBC 作用

    通过JDBC可以让Java程序操作数据库

    JDBC 本质

    官方(Sun公司)定义的一套操作所有关系型数据库的规则,即接口(API)
    各个数据库厂商去实现这套接口,提供数据库驱动jar包
    我们可以使用这套接口(JDBC)编程,真正执行的代码是驱动jar包中的实现类

    JDBC的好处

    我们只需要会调用JDBC接口中的方法即可,使用简单
    使用同一套Java代码,进行少量的修改就可以访问其他JDBC支持的数据库

    JDBC的使用步骤

    JDBC的使用步骤

    1.注册驱动
    2.获取数据库连接
    3.获取执SQL语句对象
    4.执行SQL语句并返回结果
    5.处理结果
    6.释放资源

    1.static void registerDriver(Driver driver) 向 DriverManager 注册给定驱动程序。

    MySQL 5之后的驱动包,可以省略注册驱动的步骤

    自动加载jar包中META-INF/services/java.sql.Driver文件中的驱动类

    2.DriverManager.getConnection(url,账户,密码)

    url:连接数据库的URL,用于说明连接数据库的位置

    连接数据库的URL地址格式:协议名:子协议://服务器名或IP地址:端口号/数据库名

    如果是本地服务器,端口号是默认的3306,则可以简写

    3.Statement createStatement()
    创建一个 Statement 对象来将 SQL 语句发送到数据库

    4.Statement中执行SQL语句的方法

    int executeUpdate(String sql) 用于执行除查询外的SQL语句

    ResultSet executeQuery(String sql) 用于执行查询语句, 返回查询到的结果集

    5.用ResultSet来接收返回值

    //代码使用MySQL8
    public static void main(String[] args) throws SQLException {
    		// 1.注册驱动(自动注册)
    		// 2.获取连接
    		Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/db1?useSSL=false&useUnicode=true&characterEncoding=UTF8&serverTimezone=GMT", "root", "1234");
    		// 3.获取Statement
    		Statement statement = connection.createStatement();
    		// 4.执行SQL语句
    		String sql = "select * from account";
    		// 5.处理结果
    		ArrayList<User> list = new ArrayList<>();
    		ResultSet resultSet = statement.executeQuery(sql);
    		//直接打印是一个地址值,要循环打印
    		//resultSet.next()是否有下一行,有返回true,无则返回false
    		while (resultSet.next()){
    			int id = resultSet.getInt("id");
    			String name = resultSet.getString("NAME");
    			String balance = resultSet.getString("balance");
    			//System.out.println("id:"+id+",name:"+name+",balance:"+balance);
    			User user = new User(id, name, balance);
    			list.add(user);
    		}
    
    		// 6.关闭资源
    		statement.close();
    		connection.close();
    		for (User user : list) {
    			System.out.println(user);
    		}
    	}
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30

    常见错误

    No suitable driver found for jdbc:mysql://Localhost:3306/db 没有导入驱动
    
    Unknown database 'database1' 找不到数据库
    
    Access denied for user'root'@'localhost' (using password: YES) 密码输入错误
    
    如果url有问题会报The driver has not received any packets from the server.
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7

    JDBC事务

    方法名说明
    setAutoCommit()默认true:关闭事务,false:开启事务
    commit()提交事务
    rollback()回滚事务

    使用步骤

    1.注册驱动
    2.获取连接
    3.开启事务
    4.获取到Statement
    5.Statement执行SQL
    6.提交或回滚事务
    7.关闭资源

    可以将事务用动态代理来帮助我们完成。

    public static void main(String[] args) {
            Connection connection = null;
            Statement statement =null;
            try {
                // 1.注册驱动(自动注册)
                // 2.获取连接
                connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/db1?useSSL=false&useUnicode=true&characterEncoding=UTF8&serverTimezone=GMT", "root", "1234");
                // 3.开启事务 将自动提交关闭 setAutoCommit false 表示开启手动提交事务,如果设置为true表示自动提交事务,默认是true
                connection.setAutoCommit(false);
                // 4.获取到Statement
                statement = connection.createStatement();
                // 5.Statement执行SQL
    
                // 张三-500
                String sql = "update account set balance = balance - 500 where id = 1";
                //int i = 10/0;
                // 李四+500
                String sql2 = "update account set balance = balance +500 where id = 2";
    
                statement.executeUpdate(sql);
                statement.executeUpdate(sql2);
    
                // 6.成功提交事务
                connection.commit();
                System.out.println("成功提交事务");
            } catch (SQLException e) {
                try {
                    if(connection!=null){
                        // 6.失败回滚事务
                        connection.rollback();
                    }
                    e.printStackTrace();
                } catch (SQLException ex) {
                    ex.printStackTrace();
                }
            }finally {
                try {
                    if(statement!=null){
                        statement.close();
                    }
                    if(connection!=null){
                        connection.close();
                    }
    
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49

    最后

    如果你对本文有疑问,你可以在文章下方对我留言,敬请指正,对于每个留言我都会认真查看。

  • 相关阅读:
    vue中父组件给子组件传递了参数后,什么时候确保子组件中收到的参数更新了
    服务类报错记录
    【FLASH存储器系列八】ONFI数据接口详述之一
    从0开始学c语言-32-自定义类型:结构体,枚举,联合
    宇宙采集器 淘宝商家电话采集爬虫分享
    boost::asio::ip::tcp::acceptor::async_accept 一直被死循环调用(无错误)问题的处理。
    C++I/O流
    6---Linux下版本控制器Git的知识点
    双胶合透镜初始设计
    原生 canvas 如何实现大屏?
  • 原文地址:https://blog.csdn.net/weixin_47543906/article/details/128000238