JDBC—连接数据库

最新推荐文章于 2024-06-05 16:56:59 发布

鱼子酱:P

最新推荐文章于 2024-06-05 16:56:59 发布

阅读量1k

点赞数

分类专栏： mysql 文章标签： java mysql

本文链接：https://blog.csdn.net/weixin_45780538/article/details/122371874

版权

mysql 专栏收录该内容

2 篇文章

订阅专栏

本文详细介绍了JDBC，包括其作用、相关概念和使用步骤。JDBC是Java连接数据库的标准API，通过驱动管理类DriverManager或数据源DataSource进行连接。在使用过程中，涉及注册驱动、建立连接、创建执行SQL的Statement对象、执行SQL、处理结果集ResultSet以及释放资源等步骤。PreparedStatement作为常用执行对象，能预编译SQL提高效率。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

一：初始JDBC

JDBC，即Java Database Connectivity，java数据库连接。是一种用于执行SQL语句的Java API，它是 Java中的数据库连接规范。

JDBC为开发人员提供了一种标准的程序设计接口，使开发人员可以纯java语言编写完整的数据库应用程序。

JDBC用来让我们的程序通过网络来操作数据库，作用很重要；JDBC技术也是java核心技术之一。

二：相关概念

驱动：不同数据库或者同一厂商的不同数据库版本都会提供不同的驱动，任何应用程序都是通过这个驱动来操作数据库的。

数据库驱动包：不同的数据库，对应不同的编程语言提供了不同的数据库驱动包，如：MySQL提供了Java的驱动包mysql-connector-java，需要基于Java操作MySQL即需要该驱动包。同样的，要基于Java操作Oracle数据库则需要Oracle的数据库驱动包ojdbc。

使用JDBC操作数据库步骤：

1）注册驱动（只做一次）

2）建立连接（Connection）

3）创建执行SQL的语句（Statement）

4）使用操作命令来执行SQL

5）处理执行结果

6）释放资源

三：使用步骤-详细介绍

JDBC使用第一步：注册（加载）驱动

a).创建一个普通的java项目

b).准备数据库驱动包，并添加到项目的依赖中：

右键点击项目Open Module Settings，在Modules中，点击项目，配置 Dependencies，点击+，

-->加载JDBC驱动程序：

1.通过DriverManager（驱动管理类）的静态方法获取：

// 加载JDBC驱动程序
Class.forName("com.mysql.jdbc.Driver");
// 创建数据库连接
Connection connection = DriverManager.getConnection(url);

2.通过DataSource（数据源）对象获取。实际应用中会使用DataSource对象。

DataSource ds = new MysqlDataSource();
((MysqlDataSource) ds).setUrl("jdbc:mysql://localhost:3306/test");
((MysqlDataSource) ds).setUser("root");
((MysqlDataSource) ds).setPassword("root");
Connection connection = ds.getConnection();

DriverManager创建连接，无法重复利用，每次释放资源通过coon.close都是物理连接

DataSource提供连接池的支持，连接池初始化时就会创建一定数量的数据库连接，这些连接是可以复用的，每次释放资源后调用coon.close都是把coonection连接对象回收

JDBC使用第二步：建立连接

1.建立Connection接口类对象

// 创建数据库连接
Connection connection =
DriverManager.getConnection("jdbc:mysql://localhost:3306/test?
user=root&password=root&useUnicode=true&characterEncoding=UTF-8");

2. URL格式

//先创建数据库连接池，在通过连接池获取数据库连接对象
DataSource ds = new MysqlDataSource();
//创建数据库连接池：初始化时，就会创建一定数量的数据库连接，这些连接对象是可以重复使用、效率更高
//整个url带参数可以只使用setURl方法，也可以将参数调用方法的方式来设置
   ((MysqlDataSource) ds).setURL("jdbc:mysql://localhost:3306/test04");//设置路径
   ((MysqlDataSource) ds).setUser("root");
   ((MysqlDataSource) ds).setPassword("111111");
   ((MysqlDataSource) ds).setUseUnicode(true);
   ((MysqlDataSource) ds).setCharacterEncoding("UTF-8");
   ((MysqlDataSource) ds).setUseSSL(false);//不会报红色警告
   conn = ds.getConnection();

JDBC使用第三步：创建执行SQL语句的对象

执行对象Statement负责执行SQL语句，由Connection对象产生。语法如下：

Statement statement = connection.createStatement();

Statement对象主要是将SQL语句发送到数据库中。JDBC API中主要提供了三种Statement对象。

1)statement:用于执行不带参数的简单数据库

2)preparedstatement：用于执行带或者不带参数的数据库；执行速度快于statement;SQL语句会预编译在数据库系统

3)callablestatement：用于执行数据库存储过程的调用

实际开发中最常用PreparedStatement

JDBC使用第四步：使用操作命令来执行SQL

执行对象Statement提供两个常用方法来执行SQL语句

1.executeQuery(Stringsql)：该方法执行实现查询功能的sql语句，返回类型为ResultSet(结果集）

ResultSet resultSet= statement.executeQuery(
                "select id, sn, name, qq_mail, classes_id from student");

2.executeUpdate(Stringsql)：该方法用于执行实现增、删、改功能的sql语句，返回类型为int，即受影响的行数有几条

  Statement s = null; 
 int n = s.executeUpdate("update student set sn=200 where id =3");
   System.out.println("修改成功的数据:" + n);

JDBC使用第五步：处理执行结果

ResultSet对象它被称为结果集，负责保存Statement执行后所产生的的查询结果，它代表符合SQL语句条件的所有行，并且它通过一套getXXX方法提供了对这些行中数据的访问。

ResultSet里的数据一行一行排列，每行有多个字段，并且有一个记录指针，指针所指的数据行叫做当前数据行，我们只能来操作当前的数据行。我们如果想要取得某一条记录，就要使用ResultSet的next() 方法 ,如果我们想要得到ResultSet里的所有记录，就应该使用while循环。

while (resultSet.next()) {
      int id = resultSet.getInt("id");
      String sn = resultSet.getString("sn");
      String name = resultSet.getString("name");
      int classesId = resultSet.getInt("classes_id");
      System.out.println(String.format("Student: id=%d, sn=%s, name=%s, 
classesId=%s", id, sn, name, classesId));
       }

JDBC使用第六步：释放资源

  if(r != null)//出现异常的时候，对象可能还没有赋值（初始化），调用close就可能会出现空指针异常
r.close();
  if(s != null)
s.close();
  if(conn != null)
 conn.close();

完整实例：

public class test2 {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        Connection conn = null;//
        Statement s = null;
        ResultSet r = null;
        try {
            //先创建数据库连接池，在通过连接池获取数据库连接对象
            DataSource ds = new MysqlDataSource();
            //创建数据库连接池：初始化时，就会创建一定数量的数据库连接，这些连接对象是可以重复使用、效率更高
            //整个url带参数可以只使用setURl方法，也可以将参数调用方法的方式来设置
            ((MysqlDataSource) ds).setURL("jdbc:mysql://localhost:3306/test04");//设置路径
            ((MysqlDataSource) ds).setUser("root");
            ((MysqlDataSource) ds).setPassword("111111");
            ((MysqlDataSource) ds).setUseUnicode(true);
            ((MysqlDataSource) ds).setCharacterEncoding("UTF-8");
            ((MysqlDataSource) ds).setUseSSL(false);//不会报红色警告
            conn = ds.getConnection();
            System.out.println(conn);

            //（2）创建操作命令
            s = conn.createStatement();

            //（3）执行sql语言
            //查找操作
            r = s.executeQuery("select id,sn,name,qq_mail,classes_id from student");

            //（3）处理执行结果
            while (r.next()) {//类似于List迭代器的迭代遍历
                int id = r.getInt("id");
                String sn = r.getString("sn");
                String name = r.getString("name");
                String qqMail = r.getString("qq_mail");
                int classesId = r.getInt("classes_id");
                System.out.printf("id=%s,sn=%s,name=%s,qqMail=%s,classesId=%s\n",
                        id, sn, name, qqMail, classesId);
            }
            System.out.println();

            //更新操作：调用executeUpdate方法，插入，修改，删除都是
            int n = s.executeUpdate("update student set sn=200 where id =3");
            System.out.println("修改成功的数据:" + n);

        } finally {
            if (r != null)//出现异常的时候，对象可能还没有赋值（初始化），调用close就可能会出现空指针异常
                r.close();
            if (s != null)
                s.close();
            if (conn != null)
                conn.close();
        }
    }
}