概念∶Java DataBase Connectivity Java 数据库连接， Java语言操作数据库。
JDBC本质:其实是官方(sun公司)定义的一套操作所有关系型数据库的规则，即接口。各个数据库厂商去实现这套接口，提供数据库驱动jar包。我们可以使用这套接口(DBC）编程，真正执行的代码是驱动jar包中的实现类。
- 步骤∶
- 导入驱动jar包
1,复制mysql-connector-java-5.1.37-bin.jar到项目的libs目录下
2,右键-- >Add As Library(将jar包加载到项目中)
2．注册驱动
Class.forName("com.mysql.jdbc.Driver");
3．获取数据库连接对象connection
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/jdbc", "root", "123456");
4．定义sql
String sql="update account set balance=5000 where id=1";
5．获取执行sql语句的对象statement
Statement statement = conn.createStatement();
6．执行sql，接受返回结果
int count = statement.executeUpdate(sql);
7．处理结果
System.out.println(count);//报错：在libs加入版本低的jar包
8．释放资源
statement.close(); conn.close();
- 详解各个对象∶
- DriverManager：驱动管理对象
1．注册驱动︰告诉程序该使用哪一个数据库驱动jar
DriverManager方法：static void registerDriver(Driver driver) :注册与给定的驱动程序 DriverManager
写代码使用:class.forName( "com.mysql.jdbc.Driver");
注意:mysql5之后的驱动jar包可以省略注册驱动的步骤。
通过查看源码发现∶在com.mysql.jdbc.Driver类中存在静态代码块
static {
try {
java.sql.DriverManager.registerDriver(new Driver());
} catch (SQLException E) {
throw new RuntimeException( "can't register driver!");
}
2．获取数据库连接︰
方法：static Connection getConnection(string url，string user，string password
参数:
url：idbc :mysql:/ /ip地址(域名):端口号/数据库名称（"jdbc:mysql://localhost:3306/db3"）
细节∶如果连接的是本机my sql服务器，并且mysql服务默认端口是3306，则url可以简写为: jdbc:mysql:///
数据库名称user：用户名（“root”）
password：密码("123456")
- connection：数据库链接对象
方法介绍：
获取执行sql 的对象：statement createstatement()Preparedstatement preparestatement(string sql)
开启事务:setAutoCommit(boolean autoCommit):调用该方法设置参数为false，即开后事务
提交事务:commit()
回滚事务:rollback()
- statement：sql执行对象
方法介绍：
boolean execute(string sql);可以执行任意的sql(了解)
int executeupdate(string sql) 执行DML (insert、update、delete)语句、DOL(create,，alter、drop)语句
返回值：影响数据库数据的行数，可以通过这个影响的行数判断DwL语句是否执行成功返回值>0的则执行成功，反之，则失败。
Resultset executeQuery(string sql)︰执行DQL (select)语句
- Resultset :结果集对象,封装查询结果
方法介绍：
next()：游标向下移动一行 类似指针 游标向下移动一行，判断当前行是否是最后一行末尾(是否有数据)，如果是，则返回false，如果不是则返回true
getxxx(参数)：获取数据
xxx:代表数据类型如: int getInt() , string getstring()
参数∶int :代表列的编号,从1开始如: getstring(1) string :代表列名称。如: getDouble( "balance" )
注意:
使用步骤:
1，游标向下移动一行 2，判断是否有数据 3，获取数据
//循环判断游标是否是最后一行末尾。
while(rs.next()){
int id = rs.getInt(1);
string name = rs.getstring( "name" );double balance = rs.getDouble(3);
system.out.println(id + "---" + name + "---" + balance);
}
- Preparedstatement :sql执行对象
1.SQL注入问题∶在拼接sql时，有一些sql的特殊关键字参与字符串的拼接。会造成安全性问题
输入用户随便，输入密码:a' or 'a' = 'a
sql : select * from user where username = 'fhdsjkf' and password = 'a' or 'a' = 'a'
2，解决sql注入问题:使用Preparedstatement对象来解决
3，预编译的SQL:参数使用?作为占位符
4，步骤∶
1.导人驱动jar包mysql-connector-java-5.1.37-bin.jar
2.注册驱动
3.获取数据库连接对象 connection
4.定义sql：
注意: sql的参数使用?作为占位符。如: select * from user where username = ? and password = ?;
5.获取执行sql语句的对象 PreparedStatement Connection.prepareStatement(string sql)
6．给?赋值:
*方法:setXxx(参数1[?的位置],参数2[?的值])
7.执行sql，接受返回结果，不需要传递sql语句
8.处理结果
9.释放资源
try {
//获取数据库连接
conn = JdbcUtils.getConnection();
//sql语句
String sql="select * from user where username=? and password=?";
//获取sql执行对象
preparedStatement = conn.prepareStatement(sql);
preparedStatement.setString(1,username);
preparedStatement.setString(2,password);
//执行sql
res = preparedStatement.executeQuery();
return res.next();
} catch (SQLException e) {
e.printStackTrace();
}finally {
JdbcUtils.close(res,preparedStatement,conn);
}
- 抽取JDBC工具类
package com.xjbt.Untis;
import java.io.FileReader;
import java.io.IOException;
import java.net.URL;
import java.sql.*;
import java.util.Properties;
public class JdbcUtils {
//设置静态资源，在静态方法和静态代码块上都可以使用可以直接使用
private static String url;
private static String user;
private static String password;
private static String driver;
static{//静态代码块，随着类的加载只加载一次
//读取资源（JDBC.properties）文件获取值
//1创建Properties集合类
Properties pro=new Properties();
try {
//获取src路径下的文件的方式-->ClassLoader类加载器(加载字节码文件进内存，获取src路径下的资源文件)
ClassLoader classLoader = JdbcUtils.class.getClassLoader();//通过字节码文件（JdbcUtils.class）的方法得到ClassLoader类加载器
URL res=classLoader.getResource("JDBC.properties");//获取到资源文件的绝对路径对象（URL统一资源定位符，定位一个文件的绝对地址）
String path=res.getPath();//转化成字符串
//2，load方法可以加载properties文件
pro.load(new FileReader(path));
//3．获取数据，赋值
url = pro.getProperty ("url");
user = pro.getProperty("user");
password=pro.getProperty ("password");
driver=pro.getProperty ("driver");
try {
//4．注册驱动
Class.forName(driver);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
} catch (IOException e) {
e.printStackTrace();
}
}
//获取连接对象
public static Connection getConnection() throws SQLException {
return DriverManager.getConnection(url,user,password);
};
//释放资源方法
public static void close(Statement statement,Connection conn){
if(statement!=null){
try {
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn!=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
//释放资源方法(重载)
public static void close(ResultSet res,Statement statement,Connection conn){
if(res!=null){
try {
res.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(statement!=null){
try {
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if(conn!=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
JDBC控制事务︰
1，事务：一个包含多个步骤的业务操作。如果这个业务操作被事务管理，则这多个步骤要么同时成功，要么同时失败。
2．操作：1．开启事务2．提交事务3.回滚事务
3．使用connection对象来管理事务
开启事务: setAutoCommit(boolean autoCommit) ：调用该方法设置参数为false，即开后事务
提交事务: commit()
回滚事务: rollback()
package com.xjbt.jdbc;
import com.xjbt.Untis.JdbcUtils;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class JdbcAuto {
public static void main(String[] args) {
Connection conn=null;
PreparedStatement preparedStatement1=null;
PreparedStatement preparedStatement2=null;
try {
conn=JdbcUtils.getConnection();
conn.setAutoCommit(false);//开启事务
String sql1="update account set balance=balance-? where id=?";
String sql2="update account set balance=balance+? where id=?";
preparedStatement1= conn.prepareStatement(sql1);
preparedStatement2= conn.prepareStatement(sql2);
preparedStatement1.setDouble(1,500);
preparedStatement1.setInt(2,1);
preparedStatement2.setDouble(1,500);
preparedStatement2.setInt(2,2);
//执行
preparedStatement1.executeUpdate();
//int i=3/0;
preparedStatement2.executeUpdate();
conn.commit();//提交事务
} catch (Exception e) {
try {
if(conn!=null){
conn.rollback();//回滚事务
}
} catch (SQLException ex) {
ex.printStackTrace();
}
e.printStackTrace();
}finally {
JdbcUtils.close(preparedStatement1,conn);
JdbcUtils.close(preparedStatement1,null);
}
}
}
网友评论