一、JDBC

1.1JDBC的概述

JDBD： Java Database Connectivity

使用java代码去连接数据库

JDK:

  1. java.sql.*
  3. javax.sql.*

JDK提供了很多类库让咱们去操作数据库

需要第三方的jar包，jdk只负责增删改查的操作，不负责连上数据库

第三方jar包：mysql-connector-java.jar

如何下载第三方jar包：

  1. 1.百度：[http://mvnrepository.com](http://mvnrepository.com)
  3. 2.搜索mysql
  5. 3.选择MySQL Connector/J
  7. 4.选择一个版本，点击Files下载

1.2连接数据库需要那些参数

mysql -hlocalhost -uroot -p123456

1.需要知道连接哪一款数据库 mysql

2.数据库的服务器的地址 localhost 本机地址

3.数据库的用户名 root

4.数据库的密码 123456

1.3借助JDBC连接数据库

1.在当前工程中导入第三方jar包

  1. 1.1在src下新建一个lib的文件夹
  3. 1.2将jar包粘贴到lib文件夹下
  5. 1.3点击jar包，右键 add
  1. package com.qfedu.test1;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.SQLException;
  7. /**
  8.  * @author shkstart
  9.  * @create 2022-04-26-10:29
  10.  */
  11. public class Demo1 {
  12.     public static void main(String[] args) throws ClassNotFoundException, SQLException {
  13.         //1.加载驱动
  14.         //forName 方法的参数 包名+类名 编译期间会将整个类加载
  15.         //Driver 这个类会被加载 就是驱动
  16.         //Driver 这个类部在jdk里面 需要导包jar
  17.         Class.forName("com.mysql.jdbc.Driver");
  19.         //2.准备一个url url是连接数据库的
  20.         String url = "jdbc:mysql://localhost:3306/java2204?useSSL=false";
  22.         //3.准备用户名和密码
  23.         String user = "root";
  24.         String password = "123456";
  26.         //4.使用驱动管理器类去获取连接数据库对象
  27.         /**
  28.          * getConnection(String url,String user,String password)
  29.          * 尝试建立与给定数据库url的连接，连上一个数据库的一个方法
  30.          * 返回值 Connection 是个接口  是一个连接对象
  31.          *
  32.          */
  33.         Connection connection = DriverManager.getConnection(url, user, password);
  34.         //打印以下connection
  35.         System.out.println(connection);
  37.         connection.close();
  39.     }
  40. }

1.4JDBC的增删改查

数据库已经连接上了，接下来开始对数据库下面的表进行增删改查

1.4.1增 executeUpdate

  1. package com.qfedu.test2mysql;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.SQLException;
  6. import java.sql.Statement;
  8. /**
  9.  * @author shkstart
  10.  * @create 2022-04-26-11:17
  11.  */
  12. public class Demo1 {
  13.     public static void main(String[] args) throws ClassNotFoundException, SQLException {
  14.         Class.forName("com.mysql.jdbc.Driver");
  15.         String url = "jdbc:mysql://localhost:3306/java2204?useSSL=false";
  16.         String user = "root";
  17.         String password = "123456";
  19.         Connection connection = DriverManager.getConnection(url, user, password);
  21.         //Statement对象 可以将sql语句发送到数据库进行执行
  22.         Statement statement = connection.createStatement();
  24.         //再写sql语句是一定要有这个表
  25.         int i = statement.executeUpdate("insert into work(id,name,age) value(1,'博儿',18);");
  26.         System.out.println(i);
  27.         //需要手动关闭一些资源
  28.         statement.close();
  29.         connection.close();
  30.     }
  31. }

1.4.2删 executeUpdate

  1. package com.qfedu.test2mysql;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.Statement;
  7. /**
  8.  * @author shkstart
  9.  * @create 2022-04-26-11:37
  10.  */
  11. public class Demo2 {
  12.     public static void main(String[] args) throws Exception {
  13.         Class.forName("com.mysql.jdbc.Driver");
  14.         String url = "jdbc:mysql://localhost:3306/java2204?useSSL=false";
  15.         Connection connection = DriverManager.getConnection(url, "root", "123456");
  17.         Statement statement = connection.createStatement();
  19.         int i = statement.executeUpdate("delete from work where id = 1");
  20.         System.out.println(i);
  22.         statement.close();
  23.         connection.close();
  26.     }
  27. }

注：防警告，加时区

  1. String url = "jdbc:mysql://localhost:3306/java2204?useSSL=false&serverTimezone=Asia/Shanghai";

1.4.3改 executeUpdate

  1. package com.qfedu.test2mysql;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.Statement;
  7. /**
  8.  * @author shkstart
  9.  * @create 2022-04-26-14:22
  10.  */
  11. public class Demo3update {
  12.     public static void main(String[] args) throws Exception {
  13.         Class.forName("com.mysql.jdbc.Driver");
  14.         String url = "jdbc:mysql://localhost:3306/java2204?useSSL=false";
  15.         String user = "root";
  16.         String paw = "123456";
  18.         Connection connection = DriverManager.getConnection(url, user, paw);
  19.         Statement statement = connection.createStatement();
  20.         int i = statement.executeUpdate("update work set id = 1 where id = 4");
  21.         System.out.println(i);
  22.         int i1 = statement.executeUpdate("update work set id = 2,name = '杨博是条狗'where id = 5");
  23.         System.out.println(i1);
  24.         statement.close();
  25.         connection.close();
  27.     }
  28. }

1.4.4查 executeQuery

光标从上往下移动

  1. package com.qfedu.test2mysql;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.ResultSet;
  6. import java.sql.Statement;
  8. /**
  9.  * @author shkstart
  10.  * @create 2022-04-26-14:35
  11.  */
  12. public class Demo4 {
  13.     public static void main(String[] args) throws Exception {
  14.         Class.forName("com.mysql.jdbc.Driver");
  15.         String url = "jdbc:mysql://localhost:3306/java2204?useSSL=false";
  16.         String user = "root";
  17.         String paw = "123456";
  18.         Connection connection = DriverManager.getConnection(url,user,paw);
  19.         Statement statement = connection.createStatement();
  20.         ResultSet resultSet = statement.executeQuery("select * from work");
  21. //        System.out.println(resultSet);
  22.         while(resultSet.next()){
  23.             //获取数据
  24.             //getInt(String columnLable) 传字段名字
  25.             //getInt(int columnIndex)   传字段所在第几列
  26.             int id = resultSet.getInt(1);
  27.             System.out.print(id + "\t");
  28.             String name = resultSet.getString("name");
  29.             System.out.print(name + "\t");
  30.             int age = resultSet.getInt("age");
  31.             System.out.print(age + "\t");
  32.             String info = resultSet.getString("info");
  33.             System.out.println(info);
  34.             System.out.println();
  35.         }
  37.         resultSet.close();
  38.         statement.close();
  39.         connection.close();
  42.     }
  43. }

改进

要把数据赋值给对象，然后把对象存到list集合中，供别人使用

1.新建一个实体类，一张表对应着一个实体类，属性名字对应这成员属性

2.将其放在list集合里

  1. package com.qfedu.test2mysql;
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.ResultSet;
  6. import java.sql.Statement;
  7. import java.util.ArrayList;
  8. import java.util.List;
  10. /**
  11.  * @author wodexinhuai
  12.  * @create 2022-04-26-15:26
  13.  */
  14. public class Demo5anli {
  15.     public static void main(String[] args) throws Exception {
  16.         Class.forName("com.mysql.jdbc.Driver");
  17.         String url = "jdbc:mysql://localhost:3306/java2204?useSSL=false";
  18.         String user = "root";
  19.         String paw = "123456";
  20.         //获取连接对象
  21.         Connection connection = DriverManager.getConnection(url,user,paw);
  22.         //获取搬运工
  23.         Statement statement = connection.createStatement();
  25.         List<Work> list = new ArrayList<Work>();//空的集合 把数据库中的内容放到集合中
  27.         ResultSet resultSet = statement.executeQuery("select * from work");
  28.         while (resultSet.next()){
  29.             int id = resultSet.getInt("id");
  30.             String name = resultSet.getString("name");
  31.             int age = resultSet.getInt("age");
  32.             String info = resultSet.getString("info");
  33.             Work work = new Work(id, name, age, info);
  34. //            System.out.println(work);
  35.             list.add(work);
  37.         }
  38.         for (Work w1: list
  39.              ) {
  40.             System.out.println(w1);
  41.         }
  43.     }
  44. }

1.5扩展

没有main函数可以执行java程序吗

@Test

但后导入 add’jUnit5.8.1’ to classpath

只能用无参无返回值的方法

  1. @Test
  2. public void test(){
  3.     System.out.println("卧槽？");
  4. }