JDBC操作数据库实现增、删、查、改

玩技站长
科技百科评论111字数 2102阅读7分0秒阅读模式
摘要这表明JDBC规范了所有数据库的编程操作：以DriverManager(驱动管理类)的静态方式获取：通过DataSource(数据源)对象获取。在实际开发中使用DataSource...
0.JDBC概念

实际开发中,手动的输入SQL语句是少之又少,大多数情况下是通过编译代码进行来控制自动执行.文章源自玩技e族-https://www.playezu.com/746030.html

具体操作如下:文章源自玩技e族-https://www.playezu.com/746030.html

JDBC操作数据库实现增、删、查、改插图文章源自玩技e族-https://www.playezu.com/746030.html

上述展示有一个【自己写的Mysql客户端】，这种操作是非常容易的，因为各种数据库本身就提供一系列的API，可以让用户很方便的实现这个客户端。**显然MySQl提供的有API（Application Programming Interface ）Java也提供了一些API 这些API 提供了一些类和方法，通过这些类和方法可以进行一系列操作，比如操作硬盘的文件，进行增删查改，操作数据库等 **。不同的数据库提供的API是不相同的，于是由于不同的数据库有不同的API，一旦使用不同的数据库就需要重新学习API。这时候就有Java大佬出了一个JDBC这一套API来适配不同的数据库，不同数据库就需要提供能适应JDBC相关的“驱动包”。这也就表示JDBC规范了所有数据库的编程操作。文章源自玩技e族-https://www.playezu.com/746030.html

JDBC: 约定了有哪些API，具体怎么用。文章源自玩技e族-https://www.playezu.com/746030.html

驱动包： API的具体实现。文章源自玩技e族-https://www.playezu.com/746030.html

1. 数据库连接 Connection文章源自玩技e族-https://www.playezu.com/746030.html

  • 通过DriverManager(驱动管理类)的静态方式获取
//加载jdbc驱动程序
Class.forName("com.mysql.jdbc.Driver");
//创建数据库连接
Connection connection1 = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/Class?characterEncoding=utf8&useSSL=false")
  • 通过DataSource(数据源)对象获取.实际开发中会使用DataSource对象
 DataSource dataSource = new MysqlDataSource();
((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/Class?characterEncoding=utf8&useSSL=false");
((MysqlDataSource)dataSource).setUser("root");
((MysqlDataSource)dataSource).setPassword("123456");
  • 以上两种方式的区别是:
    1. DriverManager类来获取的Connection连接，是无法重复利用的，每次使用完以后释放资源时，通过connection.close()都是关闭物理连接。
    2. DataSource提供连接池的支持。连接池在初始化时将创建一定数量的数据库连接，这些连接是可以复用的，每次使用完数据库连接，释放资源调用connection.close()都是将Conncetion连接对象回收。

2.Statement 对象文章源自玩技e族-https://www.playezu.com/746030.html

statement对象主要将SQL语句发送到数据库中,JDBC API中主要提供了三种Statement对象.文章源自玩技e族-https://www.playezu.com/746030.html

  1. statement : 用于执行不带参数的简单sql语句文章源自玩技e族-https://www.playezu.com/746030.html

  2. PrepareStatement:

    a)用于执行带参或者不带参数的sql语句.

    b)SQL语句会预编译在数据库系统.

    c)执行速度快于Statement对象.

  3. CallableStatement:用于执行数据库存储过程的调用.

强调PrepareStatement:

1.可以参数化SQL查询.

2.性能比Statement高.

3.预编译SQL.

4.阻止常见的SQL注入攻击.(黑客…)

5.占位符:?(下标从1开始)

6.占位符不能使用多值.

7.主要掌握两种执行SQL方法:

a).executeQuery()方法执行后返回单个结果集,通常用于select语句.

b).executeUpdate()方法返回值是一个整数,表示受影响的行数,通常用于update,insert,delete,语句.

3.ResultSet对象

ResultSet对象它被称为结果集,它代表符合SQL语句条件的所有行,并且它通过一套getXXX()方法提供了对这些行中数据的访问.

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

4.使用JDBC操作MySQL

【idea导入MySQL驱动包教程】

咱先来看看JDBC是如何操作的：（抽象画家）

通过JDBC使用不同的数据库，JDBC会调用相对应的数据库的“驱动包”，来和数据库的服务器进行交互。

JDBC操作数据库实现增、删、查、改插图1

4.1 插入-删除-修改

  1. 创建数据库源

在使用之前，需要提前准备好数据库和数据表

打开Mysql客户端，创建一个Class数据库，创建一个student表，字段：id，姓名.


import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
import javax.sql.DataSource;
//1.创建数据源..javax.sql底下的DataSource
DataSource dataSource = new MysqlDataSource();//向上转型，这样避免后期换服务器需要到处修改代码
//2.说明数据库服务器在哪里，向下转型
((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/Class?characterEncoding=utf8&useSSL=false");
//3.设置用户名和密码 我默认的是“root” 密码是“123456”
((MysqlDataSource)dataSource).setUser("root");
((MysqlDataSource)dataSource).setPassword("123456");
  • DataSource内置了数据量连接池,可以重复利用.
  • MysqlDataSource()；这是驱动包，里面提供了具体的类。
  • setUrl（）里写的内容，直接复制粘贴就行，除了class要换成你自己需要连接的数据库名。url是给JDBC中的mysql使用的。
  • 你的数据库用户名是什么就写什么，自己设置的密码是什么就写什么。

JDBC操作数据库实现增、删、查、改插图2

  1. 建立数据库连接
//建立连接
import java.sql.Connection;
Connection connection = dataSource.getConnection();

  • Connection :选择java.sql.Connection包。

  • getConnection():需要处理受查异常。

    a）受查异常：必须要显示处理；

    b）非受查异常：可以忽略

  1. 构造SQL语句-插入数据
//1.构造语句
//写法1
String sql = "insert into student values(1,‘张三’)";
//2.在JDBC中需要搭配一个特定的对象，来描述sql的情况
PreparedStatement preparedStatement = connection.prepareStatement(sql);
  • 使用占位符替换:实现动态sql语句构造

//写法2:
Scanner scanner = new Scanner(System.in);
int id = scanner.nextInt();//输入学号 -> 1
String name = scanner.nextLine();//输入姓名 ->"李四"
String sql = "insert into student values(?,?)";//注释1
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setInt(1,id);//注释2
preparedStatement.setString(2,name);//注释3
  • 注意:name输入"李四",如果报错,大概率是字符集不是utf8
  • 注释1处:(?,?),问号表示通配符(占位符),可以自己输入[输入的字段,类型要配对]
  • 注释2处:设置从左开始数,第一个问号,下标为1,使用setInt()把id设置为1.
  • 注释2处:设置第二个问号,下标为2,使用setString()把名字设置为"李四";
  • sql语句是先构造,再执行的,不管是否使用了通配符(占位符).
  1. 执行SQL语句
 int ret = preparedStatement.executeUpdate();
  • executeUpdate();返回结果是:操作在数据库表里影响了几行.
  • 针对增,删,改,使用executeUpdate();针对查使用executeQuery().这些操作跟插入操作的代码几乎相同，修改sql语句，再修改preparedStatement调用的方法就可以了
  • executeQuery()返回的是一个查询的结果集,用ResultSet
  1. 断开连接,释放资源
preparedStatement.close();
connection.close();

  • 注意: 释放资源是从后往前释放.

  • 最后创建的preparedStatement,就最先释放.

  • 最先创建的connection,最后释放.

  • 完整版insert代码

 public static void main(String[] args) throws SQLException {
//1.创建数据源
DataSource dataSource = new MysqlDataSource();
((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/Class?characterEncoding=utf8&useSSL=false");
((MysqlDataSource)dataSource).setUser("root");
((MysqlDataSource)dataSource).setPassword("123456");
//2.手动输入id name
Scanner scanner = new Scanner(System.in);
int id = scanner.nextInt();
String name = scanner.nextLine();
//3.连接
Connection connection = dataSource.getConnection();
//4.构造
String sql = " insert into student values (?,?)";
//5.执行
PreparedStatement preparedStatement = connection.prepareStatement(sql);
preparedStatement.setInt(1,id);//id
preparedStatement.setString(2,name);//name
System.out.println("sql:"+preparedStatement);//返回一个修改执行后的sql语句
//执行
int ret = preparedStatement.executeUpdate();
//关闭资源
preparedStatement.close();
connection.close();;
}

4.2 查找

public class Demo1 {
public static void main(String[] args) throws SQLException {
//1.先创建数据源
DataSource dataSource = new MysqlDataSource();
((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/Class?characterEncoding=utf8&useSSL=false");
((MysqlDataSource)dataSource).setUser("root");
((MysqlDataSource)dataSource).setPassword("123456");
//2.连接数据库
Connection connection = dataSource.getConnection();
//3.构造sql
String sql = "select * from student";
//可以其他加入限制条件
//String sql = "select * from student where id = 1";
//4.执行sql
PreparedStatement preparedStatement = connection.prepareStatement(sql);
//5.注意 这里返回的是一个结果结合
//注意这次调用的是executeQuery()
ResultSet resultSet = preparedStatement.executeQuery();
//6.循环遍历每一行记录
//next(): 只要存在下一行就取出当前一行
while(resultSet.next()){
int id = resultSet.getInt("id");
String name = resultSet.getString("name");
System.out.println("id = "+ " name");
}
resultSet.close();
preparedStatement.close();
connection.close();
}
}
  • 查询调用的是executeQuery(),返回的是一个结果集,用 ResultSet对象接收.
  • resultSet.next(): 取出当前一行数据;如果指向了结尾,则返回false;
  • 使用getXX方法获得具体列;
  • 方法里的参数就是数据表里的列名,注意如果你在查询时,取了别名,这里也要用别名
  • 可以写多条sql语句,但是每条语句执行,都要重新创建一个PreparedStatement对象,进行执行.
  • 在这写的sql语句,和数据库里的语句是相同的,比如加入限制条件where order by…
历史上的今天
6 月
22
 
匿名

发表评论

匿名网友
确定

拖动滑块以完成验证