赞
踩
1.JDBC定义
Java数据库连接技术(Java DataBase Connectivity),
能实现Java程序对各种数据库的访问
2.为什么使用JDBC
不必为不同的数据库专门编写不同的程序,
而只需要加载不同的数据库驱动即可
3.JDBC编程步骤(详细)
4.JDBC (API)连接数据库(企业面试题)
JDBC访问数据库常用类和接口:
DriverManager :管理JDBC驱动
Connection :连接数据库并传送数据
PreparedStatement :负责执行SQL语句
ResultSet:负责保存PreparedStatement执行后所产生的查询结果
JDBC访问数据库的步骤:
注册JDBC驱动
管理连接
创建PreparedStatement对象
发送SQL语句,并得到返回结果
处理返回结果
释放资源
(1)纯Java连接数据库
步骤1:导入mysql驱动包(物料)
mysql-connector-java-5.1.0-bin.jar包导入
在web里的WEB-INF》创建Directory名字为lib,然后拖进去。
然后右击该jar包,Add as Library 然后确定就好了。
步骤2:test包/Demo01.java
cn.kgc.test 包创建一般是倒序。
import java.sql.Connection; import java.sql.DriverManager; public class Demo01 { public static void main(String[] args) throws Exception { //1.注册JDBC驱动 Class.forName("com.mysql.jdbc.Driver"); //2. 管理连接(配置三个参数,jdbc连接url,数据库的用户名,密码) //test数据库名称数据库要有test root超级用户 connection conn = DriverManager.getConnection ("jdbc:mysql://localhost:3306/test","root","ok"); //3.测试用:输出连接对象(java是否能连接数据库) System.out.println(conn); //4.关闭连接 con.close(); } }
如果上面不管用在test后面加
?useUnicode=true&characterEncoding=utf8
如果版本数据库是8版本的话 :
插入mysql-connector-java-8.0.16包
Class.forName("com.mysql.cj.jdbc.Driver");
test后面加
?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true
结果: com.mysql.cj.jdbc.ConnectionImpl@668bc3d5
(2)使用JDBC实现添加功能
import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.SQLException; public class Demo02 { public static void main(String[] args) throws ClassNotFoundException, SQLException { Class.forName("com.mysql.cj.jdbc.Driver"); Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true","root","zjj"); //3.调用conn对象的prepareStatement(),发送sql语句 PreparedStatement ps = conn.prepareStatement("insert into t_user(`name`,pwd) values(?,?) "); // id是自动递增主键 不用设置 // values(?,?)占位符 name是可能会识别关键字,所以需要加 撇 //4.传递两个参数值到sql语句中(数据库sql语句中) ps.setObject(1,"马虎");//1是第一个问号 代表名字 ps.setObject(2,"666");//2是第二个问号 代表密码 //5.执行sql语句 ps.executeUpdate(); //6.关闭资源 ps.close(); conn.close(); } }
如果要添加两个,那么values(?,?),(?,?) ?为 1 2 3 4
(3)使用JDBC实现删除功能
import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; public class Demo03 { public static void main(String[] args) throws Exception { Class.forName("com.mysql.cj.jdbc.Driver"); Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true","root","zjj"); PreparedStatement ps = conn.prepareStatement("delete from t_user where id=?"); ps.setObject(1,2);// 1 第一个问号 1 id 为一 ps.executeUpdate(); ps.close(); conn.close(); } }
(4)使用JDBC修改记录数
import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; /** * 案例4:使用JDBC实现修改功能 */ public class Demo04 { public static void main(String[] args) throws Exception { Class.forName("com.mysql.cj.jdbc.Driver"); Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true","root","zjj"); PreparedStatement ps = conn.prepareStatement("update t_user set `name` = ?,pwd = ? where id = ?"); ps.setObject(1,"嘛啊"); ps.setObject(2,123); ps.setObject(3,1); ps.executeUpdate(); ps.close(); conn.close(); } }
(5)使用JDBC查询对象
查询有个返回值,需要返回给用户。
== > 需要创建User类,先创建cn.kgc.entity这个包。
User类里有
private Integer id;
private String name;
private String pwd;
get和set方法。
import cn.kgc.entity.User; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; /** * 案例5:使用JDBC查询对象 */ public class Demo05 { public static void main(String[] args) throws Exception { Class.forName("com.mysql.cj.jdbc.Driver"); Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true", "root","zjj"); PreparedStatement ps = conn.prepareStatement("select * from t_user where id = ?"); ps.setObject(1,4); //执行查询,返回结果集 ResultSet rs = ps.executeQuery(); User user = null;//全局变量 //使用next方法,迭代结果集,判断是否有下一个数据---获取下一个元素 while (rs.next()){ //把字段封装成对象 //创建对象 user = new User(); //循环塞进去 user.setId(rs.getInt("id")); user.setName(rs.getString("name")); user.setPwd(rs.getString("pwd")); } rs.close(); ps.close(); conn.close(); System.out.println("用户id:" +user.getId() +" 用户名:"+user.getName() + " 用户密码:"+user.getPwd()); } }
(6)使用JDBC查询集合
import cn.kgc.entity.User; import java.sql.*; import java.util.ArrayList; /** * 案例6:使用JDBC 查询集合对象 */ public class Demo06 { public static void main(String[] args) { ArrayList<User> users = new ArrayList<>(); Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; try { //1.注册驱动 Class.forName("com.mysql.cj.jdbc.Driver"); //2.管理连接 conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true", "root","zjj"); //3.发送sql语句 ps = conn.prepareStatement("select * from t_user"); //4.执行executeQuery()方法 rs = ps.executeQuery(); User user = null; //5.循环遍历rs结果集对象,将数据库的在每列的值分别塞入user对象的每个属性中 while (rs.next()){ user = new User(); user.setId(rs.getInt("id")); user.setName(rs.getString("name")); user.setPwd(rs.getString("pwd")); users.add(user); } } catch (ClassNotFoundException | SQLException e) { e.printStackTrace(); } finally { try { if(rs!=null)rs.close(); if(ps!=null)ps.close(); if(conn!=null)conn.close(); } catch (SQLException e) { e.printStackTrace(); } } for (User u : users) { System.out.println("用户id:" +u.getId() +" 用户名:"+u.getName() + " 用户密码:"+u.getPwd()); } } }
(7)使用JDBC模糊查询集合
import cn.kgc.entity.User; import java.sql.*; import java.util.ArrayList; /** * 案例7:使用JDBC模糊查询集合对象 */ public class Demo07 { public static void main(String[] args) { ArrayList<User> users = new ArrayList<>(); Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; try { //1.注册驱动 Class.forName("com.mysql.cj.jdbc.Driver"); //2.管理连接 conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true", "root","zjj"); //3.发送sql语句 ps = conn.prepareStatement("select * from t_user where `name` like concat('%',?,'%')"); //不加%就是精准查询 //4.塞值 ps.setObject(1,"快乐"); //5.执行查询executeQuery()方法 rs = ps.executeQuery(); User user = null; //6.循环遍历rs结果集对象,循环将数据库中的数据遍历到对象中,并循环置于list中 while (rs.next()){ user = new User(); user.setId(rs.getInt("id")); user.setName(rs.getString("name")); user.setPwd(rs.getString("pwd")); users.add(user); } } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } finally { try { if(rs!=null)rs.close(); if(ps!=null)ps.close(); if(conn!=null)conn.close(); } catch (SQLException e) { e.printStackTrace(); } } for (User u : users) { System.out.println("用户id:" +u.getId() +" 用户名:"+u.getName() + " 用户密码:"+u.getPwd()); } } }
----2021.10.19&10.20
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。