第七章：JDBC
7.1:jDBC简介
7.1.1:为什么要使用JDBC
Java是通过JDBC技术实现对数据的访问的，JDBC是java数据库(Java database connectivity)技术的简称，它充当java应用程序与各种不同的数据库之间的媒介，吧数据持久化，这就是一种持久化机制
7.1.2：JDBC工作原理
JDBC API
由Sun公司提供的，包括java应用程序的各种不同数据库交互的接口，如connection（连接） Statement(执行sql命令) ResultSet（返回结果集） PreparedStatement接口。
JDBC Driver Manager
JDBC驱动管理程序，负责各种不同的jDBC驱动，把Java应用程序连接到jDBC驱动程序上，位于jdk的java.sql包下面
JDBC驱动
由各厂家提供的，负责连接不同的数据库，mysql和oracle需要不同的数据库。
7.1.3：JDBC Api介绍
DriverManager:装载驱动程序，并且为创建数据库连接提供支持
Connection：负责连接数据量并且传输数据任务
Statement：由connection产生，负责执行sql语句
resultSet:负责保存Statement执行返回的结果集
preparedStatement:是statement的子接口，由connection产生，也是负责执行sql语句。他的安全性更高，高可读性
7.1.4：jDBC访问数据库的步骤
l 加载JDBC驱动(可能会引发异常，所以用ClassNotFoundExeception来声明try——catch)
Class.forName(“JDBc驱动类名称”);
l 与数据库建立连接
Connection conn=DriverManager.getConnection(“数据库连接字符串“,”数据库用户名”,”密码”);
l 发生sql语句，并且返回结果
Statement st=conn.createStatement(); //创建执行sql语句的对象
ResultSet rs=statement.executeQuery(“sql语句”); //返回结果集
l 处理返回的结果
While(rs.next()){ //判断是否有下一行的数据
//读取
Int id=rs.getInt(“id”); 或者 int id=rs.getInt(0);
};
7.2:连接数据库
7.2.3:使用纯java方式连接数据库
需要引入jar包，mysql-connector-java-5.1.0-bin.jar
package cn.jbit.example02;
import java.sql.Connection;
import java.sql.DriverManager;
import org.apache.log4j.Logger;
public class example02 {
private static Logger logger=Logger.getLogger(example02.class.getName());
public static void main(String[] args) {
Connection conn=null;
//加载驱动
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
// TODO: handle exception
logger.error(e);
}
try {
conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/myschool","root","root");
logger.warn("建立连接成功啦");
System.out.println("建立连接成功啦");
} catch (Exception e) {
// TODO: handle exception
logger.error(e);
}finally {
try {
if(null!=conn) {
conn.close();
System.out.println("关闭连接成功！！");
}
} catch (Exception e) {
// TODO: handle exception
logger.error(e);
}
}
}
}
以上是连接数据库的步骤
7.3：Statement接口和ResultSet接口
l Connection接口的方法
|
方法名称 |
作用 |
|
Void close() |
立即释放 连接资源 |
|
Statement crementstatement() |
创建一个Statement的对象，来讲sql语句发送到数据库 |
|
PreparedStatement preparedStatement(String sql) |
创建一个preparedStatement对象将参赛化的sql语句发送到数据库 |
|
Boolean isCloseed() |
查询connection是否关闭 |
l Statement接口的常用方法
|
方法名称 |
作用 |
|
Result ExecuteQuery(String sql) |
执行sql查询并且返回ResultSet的对象 |
|
Int executeUpdate(String sql) |
可以执行 insert,update,delete的操作，返回受影响行数 |
|
Boolean execute(String sql) |
可以执行任意的sql语句，若执行Result对象，则返回true，若执行更新计数或者不存在的结果，返回false |
以下是添加一个记录到数据库
package cn.jbit.example03;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import org.apache.log4j.Logger;
public class example03 {
private static Logger logger=Logger.getLogger(example03.class.getName());
public static void main(String[] args) {
//申明连接对象
Connection conn=null;
//处理执行sql语句的对象
Statement statement=null;
String name="欧欧";
int health=100;
int love=70;
String starin="酷酷的雪拉瑞";
//加载驱动
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (Exception e) {
logger.error(e);
}
try {
//建立连接
conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/epet","wangchao","root");
System.out.println("建立连接成功啦！！");
//创建执行sql语句的对象
statement=conn.createStatement();
//创建一个连接的对象
StringBuffer sb=new StringBuffer();
sb.append(" insert into dog(id,name,health,love,starin) values(");
sb.append(5+",'");
sb.append(name+"',");
sb.append(health+",");
sb.append(love+",'");
sb.append(starin+"')");
//执行sql语句的命令
statement.execute(sb.toString());
System.out.println("插入狗狗成功啦！！");
} catch (SQLException e) {
logger.error(e);
}finally {
try {
if(null!=statement) {
statement.close();
}
if(null!=conn) {
conn.close();
}
} catch (SQLException e) {
logger.error(e);
}
}
}
}
l ResultSet接口常用的方法
|
方法名称 |
作用 |
|
Boolean next() |
判断，将光标移到当前位置的下一行 |
|
Boolean previous() |
将光标移到上一行 |
|
Void close（） |
关闭ResultSet对象 |
|
Int getInt(int CloumnIndex) |
以int 下标的形式获取该列的值 |
|
Int getInt(int CloumnName) |
以int列名的形式获取该列的值 |
|
float getFloate(int CloumnIndex) |
以float 下标的形式获取该列的值 |
|
Float getfloat(int CloumnName) |
以float列名的形式获取该列的值 |
|
String getString(int CloumnIndex) |
以String下标的形式获取该列的值 |
|
String getString(int CloumnName) |
以String列名的形式获取该列的值 |
|
Int getRow() |
得到光标当前所指行的行号 |
|
Boolean absolute(int row) |
将光标移动到指定的行 |
7.4:PreparedStatement接口
7.4.1:为什么要使用:PreparedStatement接口
为了防止sql注入攻击，原因是statement接口方法是要进行sql语句的拼接.不仅麻烦而且存在安全隐患，PreparedStatement解决了这个问题
7.4.2: 使用:PreparedStatement接口
|
方法名称 |
作用 |
|
Boolean execute() |
`可以执行任意的sql语句，若执行Result对象，则返回true，若执行更新计数或者不存在的结果，返回false |
|
ResultSet executeQuery() |
执行sql查询，返回ResultSet的对象 |
|
Int executeUpdate() |
可以执行 insert,update,delete的操作，返回受影响行数 |
|
Void setInt(int index,int x) |
将指定的参数设置给java int值，也就是给上面的sql语句的格式（？）设置值，前：下标1开始，后：值 |
|
Void setobject(int index,int x) |
给定对象设置指定参数 |
步骤：
l 创建PreparedStatement对象
通过connection的preparedStatement（String sql） 方法创建PreparedStatement对象，sql语句可以一个或者多个参数，值用一个？占位符表示。
String sql=Update dog set name=?,health=? Where id=?
PreparedStatement ps=conn.preparedStatement(String sql);
l 给每个占位符的参数设置值
Ps.setInt(int index,int values); //第一个：是下标从1开始，第二个：是值
Ps.setString(int index,Stringvalues); //第一个：是下标从1开始，第二个：是值
l 执行sql语句
在设置各个参数值后，就可以调用preparedStatement的方法了（resultSet executeQuery）, int execute() , boolean execute()
示例代码如下
package cn.jbit.example07;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Scanner;
import org.apache.log4j.Logger;
public class example07 {
private static Logger logger=Logger.getLogger(example07.class.getName());
public static void main(String[] args) {
Connection conn=null;
PreparedStatement pstatement=null;
ResultSet rs=null;
Scanner input=new Scanner(System.in);
System.out.println("请输入用户名：");
String name=input.next();
System.out.println("输入密码：");
String pass=input.next();
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
logger.error(e.getMessage());
}
try {
conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/epet","wangchao","root");
String str=" select * from master where name=? and password=? ";
pstatement=conn.prepareStatement(str);
pstatement.setString(1, name);
pstatement.setString(2, pass);
rs = pstatement.executeQuery();
if(rs.next()) {
System.out.println("成功！");
}else {
System.out.println("失败！！");
}
} catch (SQLException e) {
logger.error(e.getMessage());
}finally {
try {
rs.close();
pstatement.close();
conn.close();
} catch (SQLException e) {
logger.error(e.getMessage());
}
}
}
}