Connection（数据库连接对象）

GeekLiHua

发布于 2025-01-21 15:04:05

26400

代码可运行

文章被收录于专栏：JavaJava

运行总次数：0

代码可运行

Connection（数据库连接对象）

简介：通过代码来讲解Connection的含义。

推荐学习路线：JDBC数据库的连接->Connection（数据库连接对象）->Driud数据库连接池的使用->ResultSet->通过PreparedStatement预防SQL注入->JDBC增删改查案例讲解大家跟着敲完基本就可以JDBC基础毕业了。

演示代码

/**
 * JDBC API 详解：Connection
 */
public class JDBCDemo_Connection {

    public static void main(String[] args) throws Exception {
       //1. 注册驱动
        Class.forName("com.mysql.cj.jdbc.Driver");
        //2. 获取连接
        // String url = "jdbc:mysql://127.0.0.1:3306/books"; // 如果是mysql5这样写
        String url = "jdbc:mysql://localhost:3306/books?serverTimezone=GMT%2B8&useOldAliasMetadataBehavior=true"; // 如果是mysql8这样写
        String username = "root";
        String password = "1234";

        Connection conn = DriverManager.getConnection(url, username, password);
        //3. 定义sql
        String sql1 = "update book set price = price - 8 where reclD = 1";
        String sql2 = "update book set price = price - 8 where reclD = 2";
        String sql3 = "update book set price = price - 8 where reclD = 3";
        //4. 获取执行sql的对象 Statement
        Statement stmt = conn.createStatement();

        try {
            // ============开启事务==========
            conn.setAutoCommit(false); // 加上这几句之后 如果发生异常就会回滚 然后数据不会发生改变
            							// 如果没有发生异常 但是发现数据库里面的数据没有改变
            							// 可以把这里改成true 不改的话内存里面的数据改了 但是显示的没有改
            //5. 执行sql
            int count1 = stmt.executeUpdate(sql1);//受影响的行数
            //6. 处理结果
            System.out.println(count1);
            //5. 执行sql
            int count2 = stmt.executeUpdate(sql2);//受影响的行数
            //6. 处理结果
            System.out.println(count2);

            // ============提交事务==========
            //程序运行到此处，说明没有出现任何问题，则需求提交事务
            conn.commit();
        } catch (Exception e) {
            // ============回滚事务==========
            //程序在出现异常时会执行到这个地方，此时就需要回滚事务
            conn.rollback();
            e.printStackTrace();
        }

        //7. 释放资源
        stmt.close();
        conn.close();
    }
}

运行结果：

代码分析

使用Connection的步骤

导入自己的各种信息

//1. 注册驱动
        Class.forName("com.mysql.cj.jdbc.Driver");
        //2. 获取连接
        // String url = "jdbc:mysql://127.0.0.1:3306/books"; // 如果是mysql5这样写
        String url = "jdbc:mysql://localhost:3306/books?serverTimezone=GMT%2B8&useOldAliasMetadataBehavior=true"; // 如果是mysql8这样写
        String username = "root";
        String password = "12345";

创建Connection对象

Connection conn = DriverManager.getConnection(url, username, password);

定义sql语句

	//3. 定义sql
       String sql1 = "update book set price = price - 8 where reclD = 1";
       String sql2 = "update book set price = price - 8 where reclD = 2";
       String sql3 = "update book set price = price - 8 where reclD = 3";

调用creatStatement()方法

//4. 获取执行sql的对象 Statement
        Statement stmt = conn.createStatement();

Connection的理解

这就是Connection(数据库连接对象) 的在代码中的涉及部分，那么Connection到底是什么了，就跟它的名字一样，数据库连接对象，从面相对象的角度理解，这个对象就是封装了去连接整个数据库信息的用户的各种信息，比如url,password,username，这些信息，把这些信息封装打包，成为一个Connection（数据库连接对象）,然后就可以通过这个封装好的对象去进行一系列操作了。