一、通过Java代码来实现对数据库的操作编程:JDBC
JDBC(Java Datebase Connectivity) 全名Java数据库连接,是一种通过使用Java与数据库约定风格的API来连接代码和数据库的编程方式,即可以用java代码来操作数据库。
二、什么是API ?又为什么会有JDBC这个编程方式呢?它存在的意义是什么呢?
API(Application Programming Interface)全名应用程序编程接口,就是我们了解到的函数 / 类 / 方法,这样”连接“上就可以使用其中的接口,就像是充电线和手机,我们要充电就需要把可以充电的充电线连上手机。那为什么会有JDBC这个词呢?它存在的意义是什么呢?我们了解的数据库有很多,MySql,Oracle,Redis,SQLSever……他们来自于不同的厂商提供的API风格形形色色都不一样,这可就苦了我们程序员了,用不同的数据库时都要去学习他们自己的API,这大大加重了程序员的负担,这时候Java站了出来说“我要统一这样的乱象,减轻我们程序员的负担”,于是Java提出了统一风格的API让程序员们可以用这些API来操作不同的数据库,让各个数据库厂商来适配我们的接口就好。
编辑
这个图很直观,**各个厂商为了去和Java的API适配都需要去准备一个驱动包,也就是中间的小方格,驱动包可以讲各自风格的API去转换成Java的API,我们可以在 **mvnre仓库地址中去下载对应的数据库驱动包
三、如何下载数据库对应的驱包?
我们点进mvnre仓库搜索(这里我们用Mysql举例)Mysql
编辑
我们点进去会看到很多的数据库版本,Mysql中需要大版本对应即可,点击并下载即可。(因为是驱动包所以无需安装)
进入idea创建一个与idea同级的包,然后找到我们下载的驱动包复制粘贴到我们创建的包中,然后再右键选add as library这样就成功的加载了驱动
编辑
四、进行JDBC编程
1.创建DataSource对象(这里是javax.sql的) 对数据库进行预准备工作
编辑
1.1、先要声明我们要操作的数据库协议是什么,在哪里,使用哪一个数据库,编码格式是什么,是否有加密
1.2、说明该数据库的名称和密码
编辑
编辑
这里的setUrl和setUser,setPassword都是Mysql驱动包中的方法所以要强转
1.3、创建连接connection
这里使用getConnection方法使idea和数据库进行连接。
编辑
1.4、进行sql语句的编写与预编译处理。
1.5、对sql语句的执行
插入数据库操作
public class JDBCInsert { public static void main(String[] args) throws SQLException { DataSource dataSource = new MysqlDataSource(); ((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/jdbc?characterEncoding=utf8&useSSL=false"); ((MysqlDataSource)dataSource).setUser("root"); ((MysqlDataSource)dataSource).setPassword("1234"); //创建连接 Connection connection = dataSource.getConnection(); System.out.println(connection); Scanner scanner = new Scanner(System.in); System.out.println("请输入学号"); int id = scanner.nextInt(); System.out.println("请输入姓名"); String name= scanner.next(); String sql = "insert into student values(?,?)"; PreparedStatement preparedStatement = connection.prepareStatement(sql); preparedStatement.setInt(1,id); preparedStatement.setString(2,name); System.out.println("statement" + preparedStatement); int n = preparedStatement.executeUpdate(); System.out.println(n); preparedStatement.close(); connection.close(); } }
删除数据库操作
public class JDBCDelet { public static void main(String[] args) throws SQLException { DataSource dataSource = new MysqlDataSource(); ((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/jdbc?characterEncoding=utf8&useSSL=false"); ((MysqlDataSource)dataSource).setUser("root"); ((MysqlDataSource)dataSource).setPassword("1234"); Connection connection = dataSource.getConnection(); String sql = "delete from student where id = ?"; PreparedStatement statement = connection.prepareStatement(sql); statement.setInt(1,1); System.out.println(statement); int n = statement.executeUpdate(); System.out.println(n); statement.close(); connection.close(); } }
修改数据库操作
public class JDBCUpdata { public static void main(String[] args) throws SQLException { DataSource dataSource = new MysqlDataSource(); ((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/jdbc?characterEncoding=utf8&useSSL=false"); ((MysqlDataSource)dataSource).setUser("root"); ((MysqlDataSource)dataSource).setPassword("1234"); Connection connection = dataSource.getConnection(); String sql ="update student set name = ? where id = ?"; PreparedStatement statement = connection.prepareStatement(sql); statement.setString(1,"张飞"); statement.setInt(2,1); System.out.println("statement" + statement); int n = statement.executeUpdate(); System.out.println(n); statement.close(); connection.close(); } }
查询数据库操作
public class JDBCSelect { public static void main(String[] args) throws SQLException { DataSource dataSource = new MysqlDataSource(); ((MysqlDataSource)dataSource).setUrl("jdbc:mysql://127.0.0.1:3306/jdbc?characterEncoding=utf8&useSSL=false"); ((MysqlDataSource)dataSource).setUser("root"); ((MysqlDataSource)dataSource).setPassword("1234"); //创建连接 Connection connection = dataSource.getConnection(); String sql = "select* from student"; PreparedStatement statement = connection.prepareStatement(sql); // statement.setString(1,"student"); ResultSet resultSet = statement.executeQuery(); while(resultSet.next()){ int id = resultSet.getInt("id"); String name = resultSet.getString("name"); System.out.println(id + name); } resultSet.close(); statement.close(); connection.close(); } }
五、注意事项
5.1、虽然有增删查改四个操作但这里的执行操作只有两个方法:
增删改:executeUpdata
查询:executeQuery
5.2、sql语句中的?是占位符用statemen.setInt(String.....)来设置?中的内容,其中第一个参数是第几个?,第二个参数就是要放入的数据。
5.3、在预编译sql语句的方法一共有两个实现类,PreparedStatement与Statement。
PreparedStatement是将sql语句在idea中进行编译处理,减少数据库的负担。推荐使用这个。
Statement是将sql语句放在数据库进行编译处理,这样会加重数据库的负担。
5.4、ResultSet类是结果集,在获取表的时候将表中每行每列的数据放在这个结果集中
ResultSet resultSet = statement.executeQuery(); while(resultSet.next()){ int id = resultSet.getInt("id"); String name = resultSet.getString("name"); System.out.println(id + name); }
5.5、这里遍历就可以得到表中的数据,这里的getInt(''id')和getString("name"')中的id和name是表列的名称,来分出表中的数据。
5.6、在操作结束的时候要关闭相关的资源。
resultSet.close();//如果使用了resultSet需要关闭这个资源 statement.close(); connection.close();