JDBC基础
1.JDBC介绍
JDBC是java访问[对象型数据库/关系型数据库]数据库的规则,是原SUN公司开发的.
原来我们程序员需要针对具体的数据库操作,费时费力;
自从有了JDBC规则后,程序员只需要针对JDBC规则编程,不用管底层具体数据库的实现,
好处在于:写一份JDBC代码,可以在很多数据库在执行,即可移植性
2.驱动的原理及使用
就是JDBC规则,在具体数据库中的实现类,且用java书写(需要安装JDK)
3.JDBC核心使用
做jdbc代码,需要用到如下几个固定步骤,以查询为例:
- 1_注册mysql数据库服务器的驱动,DriverManager
- 2_获取mysql数据库服务器的连接,Connection
- 3_获取封装sql语句的对象,Statement
- 4_执行sql语句,并返回结果集合,ResultSet
- 5_迭代这个结果集合,while(){}
- 6_按轻到重的原则关闭连接对象,ResultSet-Statement-Connection,在必要情况下,Connection可重用
4.DriverManager(类)、Connection(接口)、Statement(接口)、ResultSet(接口)详细使用
-
DriverManager:
它是一个类，由原SUN公司提供，负责管理一个或一组访问具体数据库的驱动，
即你想访问Oracle数据库服务器的话，就让DriverManager加载Oracle驱动，
只需注册一次就行 -
Connection:
是原SUN公司提供的接口，是属于重量级对象，建议少创建，要重用
只要你想与数据库进行操作，必须获取连接对象jdbc:mysql://127.0.0.1:3306/mydb1","root","123" jdbc：主协议，你只要使用jdbc技术访问数据库，都是jdbc主协议 mysql：子协议 127.0.0.1：MySQL数据库服务器所在PC的IP地址或域名，建议用IP 3306:MySQL数据库服务器所在的PC的端口号 mydb1:访问数据库服务器中哪一个具体的数据库 root：用户名 123：密码，如果没有密码的话，也需要写""空字符串 -
Statement:
负责封装SQL语句并执行的对象，是原SUN公司提供的接口SQL语句在JDBC中分为二大类 1_静态SQL：SQL语句中无?符号，即select id,name from users where name = '张三'（上） 2_动态SQL：SQL语句中有?符号，即select id,name from users where name = ? ?号由程序在运行时动态设置的值
Statement常用的API：
-
查询：executeQuery(参数为静态SQL)，返回值为ResultSet
增删改：executeUpdate(参数为静态SQL)，返回值为Int,表示影响表格行数 -
ResultSet：
负责装查询语句的结果，默认情况下，游标位于第一条记录的前边。
next()方法就能向下移动一行，如果有结果，返回true
5.jdbc的crud
- 增删改:Statment.executeUpdate(),返回值为int,表示这次操作影响了表中的几条记录
- 查询：Statment.executeQuery()，返回值为ResultSet，表示这次查询操作结果记录数形成的集合
6.sql注入
- 客户端利用jdbc-Statement的缺点,传入非法参数,从而让jdbc返回不合法的值,我们利用这种情况,通称为sql注入.
-
现在项目中不直接使用Statement,使用PreparedStatement,PreparedStatement它除了具有Statement是所有功能外,还有动态sql处理能力,包括:程序执行时动态为?符设置值,安全检查,避免sql注入问题,预处理能力
-
?表示占位符,只能出现在字段值的位置,不能替代表名,不能替代列名;
?表示的字段值,不管是什么类型,都不用加”符号 -
Statement和PreparedStatement的区别:
Statement只能处理静态SQL;
PreparedStatement既能处理静态sql也能处理动态sql,它继承了Statement的特点 -
站在预处理角度:
PreparedStatement适合做连续多次结构相同的sql语句,有优势.
Statement适合做连续多次不同结构的sql语句,有优势. -
项目中,我们都用子接口,
1_支持动态sql,也支持静态sql
2_预处理---相同结构的sql select id,name,from users where id=1; select id,name,gender from users where id=2; 是不相同结构 ---不同结构的sql
声明:
-
静态sql也可以用PreparedStatement
适合:
静态sql—优先Statement;
动态sql—优先PreparedStatement
Statement代码实现:
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
* JDBC开发
*/
public class Demo {
static{
//1)注册一个MySQL数据库驱动，因为你现在要访问的是MySQL数据库服务器，用反射
//好处：只向DriverManager注册一次MySQL驱动
//好处：无需导入MySQL具体的类名
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
/**
* 查询所有用户
*/
public void findAllUser() throws Exception{
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try {
//NO2)获取JavaApp与MySQL数据库服务器的连接
conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/mydb1","root","123");
//NO3)创建封装SQL语句的对象
stmt = conn.createStatement();
//NO4)执行SQL语句，返回结果集合，里面存放装SQL语句执行结果，即是四条记录
rs = stmt.executeQuery("select id,username,gender,hiredate from users");
//NO5)迭代结果集合，在默认情况下，游标指向第一条记录之前，通过next方法将游标下移一条，如果有记录存在，返回true;否则false
while(rs.next()){
//获取一条中id列名对应的值
int id = rs.getInt("id");
String username = rs.getString("username");
String gender = rs.getString("gender");
//在与JDBC访问时，MySQL中的date，对应java中的java.sql.Date
java.sql.Date hiredate = rs.getDate("hiredate");
System.out.println(id+"#"+username+"#"+gender+"#"+hiredate);
}
} catch (SQLException e) {
e.printStackTrace();
//通知调用者，给前台用户提示，html/jsp
throw e;
} finally{
//NO6)关闭上述用过的连接对象
if(rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}finally{
//GC回收
rs = null;
}
}
if(stmt!=null){
try {
stmt.close();
} catch (SQLException e) {
e.printStackTrace();
}finally{
//GC回收
stmt = null;
}
}
//后期重用Connection
if(conn!=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}finally{
//GC回收
conn = null;
}
}
}
}
/**
* 主方法
*/
public static void main(String[] args) throws Exception{
Demo dao = new Demo();
dao.findAllUser();
}
}
PreparedStatement完成对users表的CURD操作,代码实现:
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import cn.itheima.entity.User;
import cn.itheima.utils.JdbcUtils;
/**
* 演示PreparedStatement完成对users表的CURD操作
*/
public class Demo01 {
/**
* 增加用户
*/
public void add(User user){
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String sql = "insert into users(username,gender,hiredate) values(?,?,?)";
try{
conn = JdbcUtils.getConnection();
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,user.getUsername());
pstmt.setString(2,user.getGender());
pstmt.setDate(3,new java.sql.Date(user.getHiredate().getTime()));
int i = pstmt.executeUpdate();
System.out.println(i>0?"成功":"失败");
}catch(Exception e){
e.printStackTrace();
throw new RuntimeException("增加用户失败");
}finally{
JdbcUtils.close(rs);
JdbcUtils.close(pstmt);
JdbcUtils.close(conn);
}
}
/**
* 修改用户
*/
public void update(String oldUsername,String newUsername){
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String sql = "update users set username = ? where username = ?";
try{
conn = JdbcUtils.getConnection();
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,newUsername);
pstmt.setString(2,oldUsername);
int i = pstmt.executeUpdate();
System.out.println(i>0?"成功":"失败");
}catch(Exception e){
e.printStackTrace();
throw new RuntimeException("增加用户失败");
}finally{
JdbcUtils.close(rs);
JdbcUtils.close(pstmt);
JdbcUtils.close(conn);
}
}
/**
* 查询用户
* @param lastname 在这里表示姓
* @param gender 性别
*/
public void find(String lastname,String gender){
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
//String sql = "select * from users where username like '赵%' and gender = '男'";
String sql = "select id,username,gender,hiredate from users where username like ? and gender = ?";
try{
conn = JdbcUtils.getConnection();
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,lastname+"%");
pstmt.setString(2,gender);
rs = pstmt.executeQuery();
while(rs.next()){
int id = rs.getInt("id");
String username = rs.getString("username");
gender = rs.getString("gender");
java.sql.Date hiredate = rs.getDate("hiredate");
System.out.println(id+"#"+username+"#"+gender+"#"+hiredate);
}
}catch(Exception e){
e.printStackTrace();
throw new RuntimeException("查询用户 失败");
}finally{
JdbcUtils.close(rs);
JdbcUtils.close(pstmt);
JdbcUtils.close(conn);
}
}
/**
* 批量删除用户
*/
public void delete(int... ids){
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
StringBuffer sb = new StringBuffer("delete from users where id in (");
for(int id : ids){
sb.append(id+",");
}
//删除最后一个逗号
sb.deleteCharAt(sb.length()-1);
//在最后拼接)
sb.append(")");
String sql = sb.toString();
try{
conn = JdbcUtils.getConnection();
pstmt = conn.prepareStatement(sql);
int i = pstmt.executeUpdate();
System.out.println(i>0?"成功":"失败");
}catch(Exception e){
e.printStackTrace();
throw new RuntimeException("批量删除用户失败");
}finally{
JdbcUtils.close(rs);
JdbcUtils.close(pstmt);
JdbcUtils.close(conn);
}
}
public static void main(String[] args) {
Demo01 test = new Demo01();
User user = new User();
user.setUsername("张三");
user.setGender("男");
user.setHiredate(new java.util.Date());
//test.add(user);
//test.update("张三","李四");
//test.find("赵","男");
test.delete(1,6,7);
}
}
摘自：https://blog.csdn.net/shuaicihai/article/details/53416045?ops_request_misc=%25257B%252522request%25255Fid%252522%25253A%252522160965081316780263098257%252522%25252C%252522scm%252522%25253A%25252220140713.130102334.pc%25255Fall.%252522%25257D&request_id=160965081316780263098257&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~all~first_rank_v2~rank_v29-2-53416045.pc_search_result_cache&utm_term=JDBC%E6%8A%80%E6%9C%AF