JavaWeb07-JDBC（Java真正的全栈开发）

Java帮帮

发布于 2018-03-16 18:06:32

1K0

发布于 2018-03-16 18:06:32

文章被收录于专栏：Java帮帮-微信公众号-技术文章全总结

jdbc

一、JDBC介绍

1. JDBC定义

JDBC（Java Data Base Connectivity,java数据库连接）,说白了就是用Java语言来操作数据库.它是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。JDBC提供了一种基准,据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序.

JDBC是接口，而JDBC驱动才是接口的实现，没有驱动无法完成数据库连接！每个数据库厂商都有自己的驱动，用来连接自己公司的数据库。

2. JDBC的优点

有了JDBC，向各种关系数据发送SQL语句就是一件很容易的事。换言之，有了JDBC API，就不必为访问MySql数据库专门写一个程序，为访问Oracle数据库又专门写一个程序，或为访问DB2数据库又编写另一个程序等等，程序员只需用JDBC API写一个程序就够了，它可向相应数据库发送SQL调用。

3. JDBC作用

通过上面介绍，我们知道了，如果要java语言来操作数据库，就需要使用JDBC,那么我们使用JDBC到底可以做些什么操作哪?

简单的说，通过JDBC我们可以做三件事：

与数据库建立连接

发送sql语句给数据库

处理返回数据集

二、JDBC入门案例

1.新建java项目

2.导入mysql数据库驱动:mysql-connector-java-5.1.22-bin.jar

3.新建数据库

CREATE DATABASE day06;

USE day06
CREATE TABLE USER(
id INT PRIMARY KEY AUTO_INCREMENT,
username VARCHAR(20) ,
PASSWORD VARCHAR(20) ,
email VARCHAR(40)
);
INSERT INTO USER VALUES(NULL,'tom','123','tom@163.com');
INSERT INTO USER VALUES(NULL,'fox','456','fox@163.com');
INSERT INTO USER VALUES(NULL,'james','789','james@163.com');

4.常用的类与接口

在java体系结构中,有这样两个包是与jdbc有关的

java.sql.* javax.sql.*

在java.sql.*包下有以下类与接口，是我们在使用jdbc时需要用到的。

DriverManager类:它主要用于管理驱动

Connection接口:它用于与数据库建立连接

Statement接口:它用于向数据库发送sql语句

PreparedStatement接口:它是Statement的子接口，它提供了预编译功能

CallableStatement接口:它是PreparedStatement的子接口，它用于处理存储过程

ResultSet接口:它用封装查询操作返回的结果信息。

5.编写java代码连接mysql数据库，并获取user表中数据步骤

a)通过DriverManger注册驱动

b)通过DriverManager获取连接对象Connection

c)通过Connection获取一个可以向数据库发送sql语句的对象Statement d)通过Statement对象执行sql语句(select) 得到一个结果集ResultSet e)遍历结果集ResultSet，得到数据表中的数据

f)释放资源

编写java代码

// 1.通过DriverManger注册驱动
DriverManager.registerDriver(new Driver());
// 2.通过DriverManager获取连接对象
Connection con = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/day06", "root", "1234");
// 3.通过Connection获取一个操作sql语句的对象Statement
Statement st = con.createStatement();
// 4.执行sql语句(select) 得到一个ResultSet
String sql = "select * from user";
ResultSet rs = st.executeQuery(sql);
// 5.操作结果集，得到数据
while (rs.next()) {
System.out.println("ID:" + rs.getInt("id") + "\tUSERNAME:"
+ rs.getString("username") + "\tPASSWORD:"
+ rs.getString("password") + "\tEMAIL:"
+ rs.getString("email"));
}
// 6.释放资源
rs.close();
st.close();
con.close();

运行结果:

三、JDBC api详情

1. DriverManager

Drivermanager是java.sql包下的一个类，它的作用是用于管理一组JDBC驱动程序的基本服务。

常用方法:

static void registerDriver(Driver driver) :向 DriverManager 注册给定驱动程序。

registDriver方法分析:

我们可以查看mysql驱动中Driver类的加载，会发现在其内部有一个静态代码块

static {
try {
java.sql.DriverManager.registerDriver(new Driver());
} catch (SQLException E) {
throw new RuntimeException("Can't register driver!");
}
}

在其中它也完成了一个注册操作，那么很明显在我们的程序中会将驱动注册两次。并且我们在使用registDriver方法是，还需要在程序中显示的导入mysql驱动中的driver类import com.mysql.jdbc.Driver;

通过以上分析，我们通过registDriver方法完成驱动的注册存在两个问题:

1.驱动对象在内存中存在两个

2.我们的程序依赖于数据库驱动

为了解决上述问题，我们在实际开发中，一般会通过反射的方式来加载我们的驱动程序

Class.forName("com.mysql.jdbc.Driver");

static Connection getConnection(String url,String user,String password):试图建立到给定数据库 URL 的连接。

getConnection方法分析:

通过这个方法，我们可以获取一个java.sql.Connection对象

getConnection方法有三个参数：

url: URL用于标识数据库的位置，程序员通过URL地址告诉JDBC程序连接哪个数据库

user:这个是数据库的用户名，对于我们来说，就是root用户

password:这个是root用户的密码

关于URL

对于url，它的基本格式如下:

协议 : 子协议 : 子名称

例如: jdbc:mysql://localhost:3306/day06

如果我们连接的是本机并且端口号是3306，以上代码也可以简写成

Jdbc:mysql:///day06

我们在jdbc中使用url很重要的一个目的是为了让DriverManager知道我们要通过哪一个数据库驱动来完成与数据库的连接。

扩展:常用的数据库连接URL

Oracle写法：jdbc:oracle:thin:@localhost:1521:sid

对于url来说，我们有时也会在其后面携带参数例如:

jdbc:mysql://localhost:3306/day06?useUnicode=true&characterEncoding=UTF-8

2. Connection

Connection是java.sql包下的一个接口

Connection代表的是一个与数据库连接的对象，当我们获取了一个Connection对象时，我们就可以说，已经与数据库连接成功.

Connection对象的获取是通过DriverManager的getConnection方法的返回值获取到的。

常用方法:

Statement createStatement():创建一个 Statement 对象来将 SQL 语句发送到数据库

PreparedStatement prepareStatement(String sql):创建一个PreparedStatement 对象来将参数化的 SQL 语句发送到数据库

CallableStatement prepareCall(String sql):创建一个 CallableStatement 对象来调用数据库存储过程

3. Statement

Statement是java.sql包下的一个接口

Statement对象用于执行静态 SQL 语句并返回它所生成结果的对象。

常用方法:

ResultSet executeQuery(String sql) :执行给定的sql语句，该语句通常是select，返回单个的ResultSet对象

int executeUpdate(String sql):执行给定的sql语句,该语句可能为update,delete,insert,返回的是行计数

boolean execute(String sql) :执行给定的sql语句，该语句返回多个结果，如果第一个结果为ResultSet对象，则返回true,其它则返回false,

4. ResultSet

ResultSet是java.sql包下的一个接口

ResultSet对象表示数据库结果集的数据表，通常通过执行查询数据库的语句生成。

Resultset封装执行结果时，采用的类似于表格的方式。ResultSet 对象维护了一个指向表格数据行的游标cursor，初始的时候，游标在第一行之前，调用ResultSet.next() 方法，可以使游标指向具体的数据行，进而调用方法获取该行的数据。

常用方法

boolean next():将光标从当前位置向前移一行。ResultSet 光标最初位于第一行之前；第一次调用 next 方法使第一行成为当前行；第二次调用使第二行成为当前行，依此类推。如果存在下一行，则返回true,不存在则返回false.

获取数据

获取任意类型数据

Object getObject(String columnLabel):参数 columnLabel代表的是列的名称

Object getObject(int columnIndex) :参数columnIndex代表的是列的序号，第一列序号为1，第二列是2，以此类推

获取指定类型数据

int getInt(int columnIndex)
int getInt(String columnLabel)
Date getDate(int columnIndex)
Date getDate(String columnLabel)
String getString(int columnIndex)
String getString(String columnLabel)

以上只是列举出一部分获取指定类型数据的方法，其它的可以查看API

四、JDBC CRUD操作

1. 添加

@Test
public void insertTest() throws ClassNotFoundException, SQLException {
// 1加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 2.获取Connection对象取
Connection con = DriverManager.getConnection("jdbc:mysql:///day06",
"root", "1234");
// 3.获取Statement对象
Statement st = con.createStatement();
// 4.添加操作
String sql = "insert into user values(null,'张三','123','zs@itcast.cn')";
int row = st.executeUpdate(sql);
if (row != 0) {
System.out.println("添加成功");
}
// 5.关闭资源
st.close();
con.close();
}

2. 修改

@Test
public void updateTest() throws ClassNotFoundException, SQLException {
// 1加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 2.获取Connection对象取
Connection con = DriverManager.getConnection("jdbc:mysql:///day06",
"root", "1234");
// 3.获取Statement对象
Statement st = con.createStatement();
// 4.添加操作
String sql = "update user set username='李四' where id=4";
int row = st.executeUpdate(sql);
if (row != 0) {
System.out.println("修改成功");
}
// 5.关闭资源
st.close();
con.close();
}

3. 删除

@Test
public void deleteTest() throws ClassNotFoundException, SQLException {
// 1加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 2.获取Connection对象取
Connection con = DriverManager.getConnection("jdbc:mysql:///day06",
"root", "1234");
// 3.获取Statement对象
Statement st = con.createStatement();
// 4.添加操作
String sql = "delete from user where id=4";
int row = st.executeUpdate(sql);
if (row != 0) {
System.out.println("删除成功");
}
// 5.关闭资源
st.close();
con.close();
}

4. 查询

@Test
public void findById() throws ClassNotFoundException, SQLException {
// 1加载驱动
Class.forName("com.mysql.jdbc.Driver");
// 2.获取Connection对象取
Connection con = DriverManager.getConnection("jdbc:mysql:///day06",
"root", "1234");
// 3.获取Statement对象
Statement st = con.createStatement();
// 4.添加操作
String sql = "select * from user where id=1";
ResultSet rs = st.executeQuery(sql);
if (rs.next()) {
System.out.println("ID:" + rs.getInt("id") + "\tUSERNAME:"
+ rs.getString("username") + "\tPASSWORD:"
+ rs.getString("password") + "\tEMAIL:"
+ rs.getString("email"));
}
// 5.关闭资源
st.close();
con.close();
}

五、JDBC工具类抽取

经过上面的CRUD操作之后,发现有重复的步骤:

l 加载驱动

l 获取连接对象

l 释放资源

那么我们是否可以将这部分内容抽取出来，当使用时，调用一下就可以了呢?

1. 工具类抽取1:

public class JdbcUtils {
public static Connection getConnection() throws ClassNotFoundException,
SQLException {
//加载驱动
Class.forName("com.mysql.jdbc.Driver");
//获取连接对象
return DriverManager.getConnection("jdbc:mysql:///day06","root", "1234");
}
public static void closeResource(Connection conn,Statement st,ResultSet rs){
if(rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (st!=null) {
try {
st.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn!=null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}

上述代码，我们只是简单的抽取加载驱动与获取连接对象，那么这种方式存在一些问题，例如，当每一次调用JdbcUtils.getConnection()方法时，都会重新加载驱动，并且我们连接的数据库也已经固定了，可扩展性太差，为了解决这些问题，我们使用下面的方式会更加合适。

2. 工具类抽取2:

在src下新建一个properties文件,

DRIVERCLASSNAME=com.mysql.jdbc.Driver
URL=jdbc:mysql:///day06
USER=root
PASSWORD=1234
public class JdbcUtils {
private static final String DRIVERCLASSNAME;
private static final String URL;
private static final String USER;
private static final String PASSWORD;
static {
// 通过读取配置文件给常量赋值
ResourceBundle bundle = ResourceBundle.getBundle("jdbc");
DRIVERCLASSNAME = bundle.getString("DRIVERCLASSNAME");
URL = bundle.getString("URL");
USER = bundle.getString("USER");
PASSWORD = bundle.getString("PASSWORD");
}
static {
// 加载驱动
try {
Class.forName(DRIVERCLASSNAME);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static Connection getConnection() throws ClassNotFoundException,
SQLException {
// 获取连接对象
return DriverManager.getConnection(URL,USER,PASSWORD);
}
public static void closeResource(Connection conn,Statement st,ResultSet rs){
if(rs!=null){
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (st!=null) {
try {
st.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn!=null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}

六、JDBC案例-登录

功能描述

要求在控制台上输入用户名与密码，如果信息正确，会显示出用户的详细信息

功能分析

1.要从键盘录入用户名与密码我们需要使用Scanner类完成操作

2.接收到用户名与密码后，我们需要调用jdbc程序根据用户名与密码查询数据库

select * from user where username=xxx and password=xxx;

3.若有该用户,则把用户的所有信息都打印出来;若无,则打印登录失败

代码实现:

sql用户表创建

CREATE DATABASE day06;
USE day06
CREATE TABLE USER(
id INT PRIMARY KEY AUTO_INCREMENT,
username VARCHAR(20) ,
PASSWORD VARCHAR(20) ,
email VARCHAR(40)
);
INSERT INTO USER VALUES(NULL,'tom','123','tom@163.com');
INSERT INTO USER VALUES(NULL,'fox','456','fox@163.com');
INSERT INTO USER VALUES(NULL,'james','789','james@163.com');

user类

public class User {
private int id;
private String username;
private String password;
private String email;
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public String getEmail() {
return email;
}
public void setEmail(String email) {
this.email = email;
}
@Override
public String toString() {
return "User [id=" + id + ", username=" + username + ", password="
+ password + ", email=" + email + "]";
}
}

Jdbc工具类 mysql驱动包

html表单

<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>Insert title here</title>
</head>
<body>
<form method="post" action="/day1001/login">
<table>
<tr>
<td>用户名:</td>
<td><input type="text" name="username">
</td>
</tr>
<tr>
<td>密码:</td>
<td><input type="password" name="password">
</td>
</tr>
<tr>
<td colspan='2'><input type="submit">
</td>
</tr>
</table>
</form>
</body>
</html>

userOperation操作类

public class UserOperation {
public User login(String username, String password) {
User user = null;
Connection conn = null;
Statement st = null;
ResultSet rs = null;
try {
con = JdbcUtils.getConnection();
st = con.createStatement();
String sql = "select * from user where username='" + username
+ "' and password='" + password + "'";
rs = st.executeQuery(sql);
if (rs.next()) {
user = new User();
user.setId(rs.getInt("id"));
user.setUsername(rs.getString("username"));
user.setPassword(rs.getString("password"));
user.setEmail(rs.getString("email"));
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
JdbcUtils.closeResource(conn,st,rs);
}
return user;
}
}

程序入口

public class LoginDemo {
public static void main(String[] args) {
Scanner sc =new Scanner(System.in);
System.out.println("请输入用户名");
String username = sc.nextLine();
System.out.println("请输入密码");//1' or 1=1 or '1
String password = sc.nextLine();
UserOperation uo = new UserOperation();
User user=uo.login(password, username);
if (user != null) {
System.out.println("用户登陆成功");
System.out.println(user);
} else {
System.out.println("登陆失败");
}
}
}

七、sql注入

对于上面的程序，如果我们在输入用户名与密码时，输入的信息如下：

用户名:tom' or 1=1 or 1='

密码:任意输入

这时会发现，我们的程序正确运行了，并显示用户登陆成功及用户的详细信息。这就产生了SQL注入问题.所谓SQL 注入是用户利用某些系统没有对输入数据进行充分的检查，从而进行恶意破坏的行为。对于SQL注入问题，我们可以使用PreparedStatement来替换Statement来解决这类问题。

八、PreparedStatement(解决sql注入)

PreparedStatement是java.sql包下的一个接口。它是Statement的一个子接口,表示预编译的 SQL 语句的对象。

SQL 语句被预编译并存储在 PreparedStatement 对象中。然后可以使用此对象多次高效地执行该语句。

通过 Connection的preparedStatement(sql)获取该对象

注意:

参数sql,代表的是要预编译的sql语句，在语句中可以使用 “?”占位符来占位

常用方法:

ResultSet executeQuery() :用于执行select操作，注意无参数

int executeUpdate():用于执行update delete insert操作，注意无参数

对预编译的sql语句中?占位符赋值操作

void setInt(int parameterIndex,int x)
void setString(int parameterIndex,String x)
void setObject(int parameterIndex,Object x)

参数parameterIndex代表的是第几个?号，也就是参数的序号，从1开始计数,后一个参数，是要赋的值

更多方法大家可以查询帮助文档。

本文参与腾讯云自媒体同步曝光计划，分享自微信公众号。

原始发表：2017-01-24，如有侵权请联系 cloudcommunity@tencent.com 删除

java

jdbc

本文分享自 Java帮帮微信公众号，前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

java

jdbc

登录后参与评论

0 条评论

热度