40.0/jdbc/Java数据连接/jar包运用增删改

40.1. 回顾

40.2. 正文

40.1 为什么需要jdbc

40.2 如何连接mysql数据库

40 .3 jdbc容易出现的错误

40.4 完成删除

40.5 完成修改

40.1. 回顾

1. 自联查询: 自己连接自己的表。注意:一定要为表起别名。
2. 嵌套查询: 把一个查询的结果作为另一个查询的条件值。
3. 组合查询: union[去除重复的内容只保留一条] union all
4. 把查询的结果当作一张临时表和其他表进行联表查询。

-- 1、检索读者“杨凡”所在单位--系
-- 查询哪些字段从哪些表查询查询时需要的条件
   select dept from readers where name='杨凡'
-- 2、检索所有读者的全部信息
    select * from readers 
-- 3、检索图书馆中所有藏书的书名和出版单位
 select book_name,publisher from books 
-- 4、检索“人民大学出版社”所有的书名和单价，结果按照单价降序排列
 select book_name,price from books order by price desc; 
-- 5、检索价格在10元至15元之间的图书的名称、作者、单价和分类号，结果按分类号和单价升序排列
select book_name,author,price,type_id from books where price BETWEEN 10 and 15 order by type_id, price ; 
-- 6、检索“人民大学出版社”和“清华大学出版社”的所有图书的名称和作者
  select book_name,author from books where publisher in('人民大学出版社','清华大学出版社')
-- 7、检索书名以“数据库”开头的所有图书的书名和作者
select book_name,author from books where book_name like '数据库%'
-- 8、检索同时借了总编号为209116和209124两本图书的借书证号
-- 查询借阅了209116这本书的读者编号
    select reader_id from borrow_info where  book_id=209116 
   -- 查询借阅了209124这本书的读者编号且读者编号要和上面的读者编号一致
   select reader_id from borrow_info where book_id=209124 and reader_id in(select reader_id from borrow_info where  book_id=209116)
     select reader_id from borrow_info where book_id in(209116,209124) group by reader_id having count(distinct book_id)>=2;
-- 9、检索所有借阅了图书的读者姓名和所在单位
-- 在借书表中-查询所有的读者id
   select name,dept from readers where reader_id in(select distinct reader_id from borrow_info)
-- 10、检索“扬凡”所借的所有图书的书名和借阅日期
    select book_name,borrow_time from books b join borrow_info bi on b.book_id=bi.book_id join readers r on r.reader_id=bi.reader_id where r.name='杨凡'    
-- 11、检索价格在20元以上且已经借出的图书，结果按单价降序排列
   select distinct b.* from books b join borrow_info bi on b.book_id=bi.book_id where b.price>20 order by price desc
-- 12、检索借阅了“C语言程序设计”一书的读者姓名和所在单位
   select name,dept from books b join borrow_info bi on b.book_id=bi.book_id join readers r on r.reader_id=bi.reader_id where b.book_name='C语言程序设计'
-- 13、检索与“杨凡”在同一天借阅了图书的读者的姓名和所在单位
-- 求出杨凡借书时间
 select distinct borrow_time from borrow_info bi join readers r on bi.reader_id=r.reader_id where r.name='杨凡'
-- 查询与杨凡在同一天借书的读者编号
  select distinct reader_id from borrow_info where borrow_time in(select distinct borrow_time from borrow_info bi join readers r on bi.reader_id=r.reader_id where r.name='杨凡')select name,dept from readers where reader_id in(select distinct reader_id from borrow_info where borrow_time in(select distinct borrow_time from borrow_info bi     join readers r on bi.reader_id=r.reader_id where r.name='杨凡')) and name!='杨凡'
-- 14、检索藏书中比“高等教育出版社”的所有图书的单价更高的图书
-- 查询高等教育出版社出版社最高的书的价格
select * from books where price>(select max(price) from books where publisher= '高等教育出版社')
-- 15、检索藏书中所有与“数据库导论”或“数据库原理”在同一出版社出版的图书
-- 查询“数据库导论”或“数据库原理”的出版社
     select * from books where publisher in(select publisher from books where book_name in('数据库导论','数据库原理')) and book_name not in('数据库导论','数据库原理')
-- 16、求该图书馆藏书的总册数
   select count(book_id) from books
-- 17、求“高等教育出版社”的图书中最高的价格、最低的价格以及平均价格
select max(price),min(price),avg(price) from books where publisher= '高等教育出版社'
-- 18、求“计算机学院”当前借阅了图书的读者人数
select count(distinct bi.reader_id) from readers r join borrow_info bi on r.reader_id=bi.reader_id where dept='计算机学院'
-- 19、求各个出版社的最高价格、最低价格、平均价格
select publisher, max(price),min(price),avg(price) from books group by publisher
-- 20、分别求出各个单位当前借阅图书的读者人数
select dept, count(distinct bi.reader_id) from readers r left join borrow_info bi on r.reader_id=bi.reader_id
group by dept;
-- 21、求各个出版单位的册书、价格总额，并按总价降序排列，如有总价相同者按出版社名称降序排列
select publisher, count(book_id),sum(price) from books group by publisher order by sum(price) desc,publisher desc;
-- 22、检索当前至少借阅了5本图书的读者姓名和所在单位

-- 查询每个读者借书的个数
   select name,dept from readers where reader_id in(select reader_id from borrow_info group by reader_id having count(distinct book_id)>=5)
-- 23、分别找出借书人数超过10个人的单位和人数
   select dept, count(distinct bi.reader_id) from readers r left join borrow_info bi on r.reader_id=bi.reader_id
group by dept having count(distinct bi.reader_id) >10 ;
-- 24、检索没有借阅任何图书的读者姓名和所在单位
select name,dept from readers where reader_id not in(select reader_id from borrow_info)

40.2. 正文

1. jdbc 【java database connection】java数据连接

40.1 为什么需要jdbc

我们前面讲解的都是在mysql的客户端对msql表中的数据进行相关的操作。真实我们需要通过java程序对mysql表中的数据进行相关的操作。

40.2 如何连接mysql数据库

(面试题)

java→oop 面向对象语言

mysql→结构化语言

思考: java要和mysql进行通信，由于语言不同，无法直接通信。需要翻译。--翻译它也是一个程序，这个程序别人已经写好并且把这个翻译程序打包为一个jar包，以供java连接mysql使用。翻译由不同的数据库厂商提供。jar从网络下载，也可以jar仓库。

(1）创建一个java工程。

(2)在工程中创建一个目录lib【库】并把mysql的驱动jar包放入该目录

(3) 把上面的jar--解压--[加载到该工程]

（4）编写代码

package com.demo01;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;public class Test01 {public static void main(String[] args) throws Exception{//1. 加载驱动==指定驱动名Class.forName("com.mysql.cj.jdbc.Driver");//2. 获取连接数据库的对象 注意:导入java.sql包下Connection/*** String url:连接数据库的路径.*    jdbc:mysql://localhost:3306/mydb?serverTimezone=Asia/Shanghai*    协议:数据库类型://数据库的ip:数据库的端口号/数据库名?时区*    时区:在mysql8.0以后才有的* String user,数据库的名称root* String password 数据库的密码*/String url="jdbc:mysql://localhost:3306/mydb?serverTimezone=Asia/Shanghai";String user="root";String password="root";Connection conn = DriverManager.getConnection(url,user,password);//3. 获取执行sql语句的对象Statement statement = conn.createStatement();//4. 执行sql语句String sql="insert into tbl_emp values(5,'刘德华','男',25,8888)";statement.executeUpdate(sql);//5. 关闭资源--如果没有关闭会操作内存的泄露statement.close();conn.close();}
}

连接数据库的步骤:

//1. 加载驱动 Class.forName("com.mysql.cj.jdbc.Driver");

//2. 获取连接对象.

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

String url="jdbc:mysql://localhost:3306/数据库名?serverTimezone=Asia/Shanghai";

//3. 获取执行sql语句的对象

Statement statement=conn.createStatement();

//4. 执行sql语句--增删改

statement.executeUpdate(sql);

//5. 关闭资源 close()

通过java代码往一张表中添加记录。

40 .3 jdbc容易出现的错误

ClassNotFoundException: com.mysql.cj.jdbc.Driver

原因: 【1】可能类名写错了

【2】没有引入mysql驱动jar包

【3】没有解压mysql的驱动jar包

（2）

数据库名错误。

（3）

服务器地址错误或者服务器没有开。

（4）

密码错误

（5）

sql语句有问题。

40.4 完成删除

public static void delete(int id) throws Exception{Class.forName("com.mysql.cj.jdbc.Driver");String url="jdbc:mysql://192.168.1.70:3306/mydb?serverTimezone=Asia/Shanghai";String user="root";String password="root";Connection conn=DriverManager.getConnection(url,user,password);Statement statement=conn.createStatement();String sql="delete from tbl_emp where id="+id;System.out.println(sql);//JAVA打印statement.executeUpdate(sql);System.out.println("删除成功");//JAVA打印statement.close();conn.close();}

40.5 完成修改

public static void update() throws Exception{Class.forName("com.mysql.cj.jdbc.Driver");String url="jdbc:mysql://192.168.1.70:3306/mydb?serverTimezone=Asia/Shanghai";String user="root";String password="root";Connection conn=DriverManager.getConnection(url,user,password);Statement statement=conn.createStatement();String sql="update tbl_emp set name='闫克起',sex='女',age=19 where id=4";statement.executeUpdate(sql);statement.close();conn.close();}

改为活数据

 public static void main(String[] args) throws Exception{Scanner sc=new Scanner(System.in);System.out.print("请输入姓名:");String name=sc.next();System.out.println("请输入年龄:");int age=sc.nextInt();System.out.println("请输入性别:");String sex=sc.next();System.out.println("请输入编号:");int id=sc.nextInt();update(id,name,sex,age);}public static void update(int id,String name,String sex,int age) throws Exception{Class.forName("com.mysql.cj.jdbc.Driver");String url="jdbc:mysql://127.0.0.1:3306/mydb?serverTimezone=Asia/Shanghai";String user="root";String password="root";Connection conn=DriverManager.getConnection(url,user,password);Statement statement=conn.createStatement();String sql="update tbl_emp set name='"+name+"',sex='"+sex+"',age="+age+" where id="+id;statement.executeUpdate(sql);statement.close();conn.close();}