码迷，mamicode.com
首页 > 数据库 > 详细

day06_JDBC学习笔记

时间：2018-04-29 23:59:13      阅读：322      评论：0      收藏：0      [点我收藏+]

标签：ica   mirror   spl   释放   nec   规范   扩展包   junit   getx   

============================================================

一、JDBC概述

为什么要使用JDBC？

JDBC：Java DataBase Connectivity，是SUN公司提供的一套操作数据库的标准规范(技术)。

JDBC与数据库驱动的关系：接口与实现的关系。

技术分享图片


JDBC规范（掌握四个核心对象）：

DriverManager类：用于注册驱动(创建连接对象)。 java.sql.DriverManager;

Connection接口：表示与数据库创建的连接 。java.sql.Connection;

Statement接口：操作数据库sql语句的对象，并返回相应结果的对象。 java.sql.Statement;

preparedStatement接口：预编译对象，是Statement对象的子类。用于解决sql的注入问题。实际用的是这个类。java.sql.PreparedStatement;

ResultSet接口：结果集或一张虚拟表(客户端存表数据的对象)。 java.sql.ResultSet;

技术分享图片

开发一个JDBC程序的准备工作：

> JDBC规范在哪里：

  JDK中：

java.sql.*;  // jdk自身带的包

javax.sql.*; // 扩展包(企业级开发)

> 数据库厂商提供的驱动：jar文件 (也即具体的实现)

 *.jar

技术分享图片

============================================================

二、开发一个JDBC程序（重要）

使用JDBC技术，通过java代码实现查询数据库中的数据并显示在java的控制台中。


1、先创建数据库表，并向表中添加测试数据。

create database day06;
use day06;
 
create table users (
    id int primary key auto_increment,
    name varchar(40),
    password varchar(40),
    email varchar(60),
    birthday date
) character set utf8 collate utf8_general_ci;
 
insert into users(name, password, email, birthday) values(‘zs‘, ‘123456‘, ‘zs@sina.com‘, ‘1980-12-04‘);
insert into users(name, password, email, birthday) values(‘lisi‘, ‘123456‘, ‘lisi@sina.com‘, ‘1981-12-04‘);
insert into users(name, password, email, birthday) values(‘wangwu‘, ‘123456‘, ‘wangwu@sina.com‘, ‘1979-12-04‘);
14
14
 
1
create database day06;
2
use day06;
3
4
create table users (
5
    id int primary key auto_increment,
6
    name varchar(40),
7
    password varchar(40),
8
    email varchar(60),
9
    birthday date
10
) character set utf8 collate utf8_general_ci;
11
12
insert into users(name, password, email, birthday) values(‘zs‘, ‘123456‘, ‘zs@sina.com‘, ‘1980-12-04‘);
13
insert into users(name, password, email, birthday) values(‘lisi‘, ‘123456‘, ‘lisi@sina.com‘, ‘1981-12-04‘);
14
insert into users(name, password, email, birthday) values(‘wangwu‘, ‘123456‘, ‘wangwu@sina.com‘, ‘1979-12-04‘);

技术分享图片


2、创建Java Project项目，添加数据库驱动(xxx.jar)。

3、实现JDBC操作。


技术分享图片

============================================================

三、JDBC常用的类和接口详解

1、java.sql.Drivermanager类：注册驱动、建立连接

a、注册驱动

DriverManager.deregisterDriver(new com.mysql.jdbc.Driver()); // 不建议使用

原因有2个：

> 导致驱动被注册2次。

> 强烈依赖数据库的驱动jar包  （若把奶瓶的Build Path给Remove掉，代码就会报错，就能看到效果）

解决办法：

Class.forName("com.mysql.jdbc.Driver");  // 把奶瓶的Build Path给Remove掉，代码也不会报错了

用到反射机制的知识：靠类的全路径来加载，解耦合了，不依赖数据库的驱动jar包了，以后会把上面的字符串放在配置文件里，更灵活了，便于后期维护。


b、与数据库建立连接

DriverManager类的静态方法：

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

DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");

URL:是SUN公司与数据库厂商之间的一种协议。

jdbc:mysql://localhost:3306/day06

协议 子协议     IP     数据库端口号 数据库名称

mysql:jdbc:mysql://localhost:3306/day14 或者 

jdbc:mysql:///day14（默认连接本机的数据库）


oracle:jdbc:oracle:thin:@localhost:1521:sid    瘦客户端，比如：玩页游协议   

子协议 子子协议       IP     数据库端口号 数据库名称

oracle:jdbc:oracle:thick:@localhost:1521:sid    胖客户端，比如：LOL、魔兽世界(需要下载软件)

与数据库建立连接的方式

第一种：

// public static Connection getConnection(String url, String user, String password)

Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");

第二种:

// public static Connection getConnection(String url, Properties info)

Properties info = new Properties(); // 要参考数据库文档

info.setProperty("user", "root");

info.setProperty("password", "root");

Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", info);

第三种：

// public static Connection getConnection(String url)

Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day06?user=root&password=root");

// 模拟表单form提交的两种方式：GET和POST

实际开发常用第一种。


扩展内容：演示3个案例的话需要写3个main方法，所以有了快速测试的方法 ==> junit技术

package com.itheima.junitdemo;
public class Calc {
    public int add(int a, int b) {
        return a + b;
    }
    public double div(double a, int b) {
        return a / b;
    }
}

-------------------------------------------

package com.itheima.junitdemo;
import org.junit.Assert;
import org.junit.Test;
// 注：测试的方法有要求：不能有返回值，不能有参数。
public class TestCalc {
    @Test
    public void test1(){
        Calc c = new Calc();
        Assert.assertEquals(8, c.add(3, 5)); // assert 断言
    }
    @Test
    public void test2(){
        Calc c = new Calc();
        Assert.assertEquals(3, c.div(10, 3),0.4);
    }
}

-----------------------------------------------------------------------------

2、java.sql.Connection接口：一个连接(与数据库连接的一座桥梁)

该接口的实现在数据库驱动jar包中。所有与数据库交互都是基于连接对象的。


// 创建执行sql语句的对象Satement(接口)
// Connection(接口)的方法：Statement createStatement()
Statement stmt = conn.createStatement();

-----------------------------------------------------------------------------

3、java.sql.Statement接口：操作sql语句，并返回相应结果的对象(小货车)

该接口的实现在数据库驱动jar包中。用于执行静态 SQL 语句并返回它所生成结果的对象。


// 执行sql语句,该语句返回单个 ResultSet 结果集对象。 
// Statement(接口)的方法：ResultSet executeQuery(String sql)
// 注意；该方法只能执行select语句。
ResultSet rs = stmt.executeQuery("select * from users");

// 根据执行的 DML(insert update delete)语句，返回受影响的行数。
// 服务器端叫法：insert、delete、update、select （增删改查）
// 客户端的叫法：create、read、update、delete （CRUD）（增删改查）
int i = stmt.executeUpdate("INSERT INTO users VALUES (4, ‘tom‘, ‘123‘,‘tom@163.com‘, ‘2015-09-28‘)");
int i = stmt.executeUpdate("UPDATE users SET NAME = ‘jerry‘, PASSWORD = ‘333‘, email = ‘jerry@163.com‘ WHERE id = 4");
int i = stmt.executeUpdate("DELETE FROM users WHERE id = 4");
         
// Statement(接口)的方法:boolean execute(String sql)
// 这个方法很奇葩！！！
// 此方法可以执行任意sql语句。返回boolean值，表示是否返回ResultSet结果集。
// 仅当执行select语句，且有返回结果时返回true, 其它语句都返回false。

-----------------------------------------------------------------------------

4、java.sql.ResultSet接口：结果集(客户端存表数据的对象)

a、封装结果集

提供一个游标，默认游标指向结果集第一行之前(即表头)。

调用一次boolean next()，游标向下移动一行。

提供一些getXxx()方法。

将结果集中的数据封装到javaBean类中，javaBean就是一普通java类，该类中只有private类型的成员变量、无参构造方法和getter/setter方法。

java的数据类型与数据库中的类型的关系:

    JAVA         DB

    byte         tityint 1字节

    short        smallint 2字节

    int          int 4字节

    long         bigint 8字节


    float        float

    double       double


    String       char 或者 varchar 

    Date         date

-------------------------------------------

ResultSet结果集封装数据的方法：

Object getObject(int columnIndex) 根据序号取值，索引从1开始

Object getObject(String ColomnName) 根据列名取值

boolean next() 将光标从当前位置向下移动一行


int getInt(int colIndex) 以int 形式获取ResultSet结果集当前行指定列号值

int getInt(String colLabel) 以int 形式获取ResultSet结果集当前行指定列名值


float getFloat(int colIndex) 以float 形式获取ResultSet结果集当前行指定列号值

float getFloat(String colLabel) 以float形式获取ResultSet结果集当前行指定列名值


String getString(int colIndex) 以String 形式获取ResultSet结果集当前行指定列号值

String getString(String colLabel) 以String 形式获取ResultSet结果集当前行指定列名值


Date getDate(int columnIndex) 以Date 形式获取ResultSet结果集当前行指定列号值

Date getDate(String columnName) 以Date 形式获取ResultSet结果集当前行指定列名


void close() 关闭ResultSet 对象

package com.itheima.entitydemo;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import org.junit.Test;

/* 
 * 服务器端叫法：insert、delete、update、select （增删改查）
 * 客户端的叫法：create、read、update、delete （CRUD）（增删改查）
 */
public class TestCRUD {

	@Test
	public void testSelect() throws Exception {
		// 加载驱动
		Class.forName("com.mysql.jdbc.Driver");
		
		// 获取连接对象Connection(注意：能用接口的就不用实现类，多态=>对象上传=>向上转型=>里氏替换，利于后期代码扩展)
		Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
		
		// 获取执行sql语句的对象Statement 
		Statement stmt = conn.createStatement();
		
		// 执行sql的查询语句，并返回结果
		ResultSet rs = stmt.executeQuery("select * from users");
		
		// 把取到的数据装到集合中
		List<Users> list = new ArrayList<Users>();
		
		// 处理结果
		Users u = null;
		while (rs.next()) {
			u = new Users();
			u.setId(rs.getInt("id"));
			u.setName(rs.getString("name"));
			u.setPassword(rs.getString("password"));
			u.setEmail(rs.getString("email"));
			u.setBirthday(rs.getDate("birthday"));
			list.add(u); // 把对象添加到集合中去
		}
		
		// 遍历集合(增强for)
		for (Users user : list) {
			System.out.println(user);
		}
		
		// 关闭资源
		rs.close();
		stmt.close();
		conn.close();
	}
	
	@Test
	public void testInsert() throws Exception {
		// 加载驱动
		Class.forName("com.mysql.jdbc.Driver");
		
		// 获取连接对象Connection(注意；能用接口的就不用实现类，多态=>对象上传=>向上转型=>里氏替换，利于后期代码扩展)
		Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
		
		// 获取执行sql语句的对象Statement 
		Statement stmt = conn.createStatement();
		
		// 执行sql的插入语句，并返回结果
		int i = stmt.executeUpdate("INSERT INTO users VALUES (4, ‘tom‘, ‘123‘,‘tom@163.com‘, ‘2015-09-28‘)");
		
		// 处理返回的结果
		if (i > 0) {
			System.out.println("success");
		}
		
		// 关闭资源
		stmt.close();
		conn.close();
	}
	
	@Test
	public void testUpdate() throws Exception {
		// 加载驱动
		Class.forName("com.mysql.jdbc.Driver");
		
		// 获取连接对象Connection(注意；能用接口的就不用实现类，多态=>对象上传=>向上转型=>里氏替换，利于后期代码扩展)
		Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
		
		// 获取执行sql语句的对象Statement 
		Statement stmt = conn.createStatement();
		
		// 执行sql的更新语句，并返回结果
		int i = stmt.executeUpdate("UPDATE users SET NAME = ‘jerry‘, PASSWORD = ‘333‘, email = ‘jerry@163.com‘ WHERE id = 4");
		
		// 处理返回的结果
		if (i > 0) {
			System.out.println("success");
		}
		
		// 关闭资源
		stmt.close();
		conn.close();
	}
	
	@Test
	public void testDelete() throws Exception {
		// 加载驱动
		Class.forName("com.mysql.jdbc.Driver");
		
		// 获取连接对象Connection(注意；能用接口的就不用实现类，多态=>对象上传=>向上转型=>里氏替换，利于后期代码扩展)
		Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
		
		// 获取执行sql语句的对象Statement 
		Statement stmt = conn.createStatement();
		
		// 执行sql的删除语句，并返回结果
		int i = stmt.executeUpdate("DELETE FROM users WHERE id = 4");
		
		// 处理返回的结果
		if (i > 0) {
			System.out.println("success");
		}
		
		// 关闭资源
		stmt.close();
		conn.close();
	}
	
}
 
1
package com.itheima.entitydemo;
2
3
import java.sql.Connection;
4
import java.sql.DriverManager;
5
import java.sql.ResultSet;
6
import java.sql.Statement;
7
import java.util.ArrayList;
8
import java.util.List;
9
10
import org.junit.Test;
11
12
/*
13
 * 服务器端叫法：insert、delete、update、select （增删改查）
14
 * 客户端的叫法：create、read、update、delete （CRUD）（增删改查）
15
 */
16
public class TestCRUD {
17
18
    @Test
19
    public void testSelect() throws Exception {
20
        // 加载驱动
21
        Class.forName("com.mysql.jdbc.Driver");
22
23
        // 获取连接对象Connection(注意：能用接口的就不用实现类，多态=>对象上传=>向上转型=>里氏替换，利于后期代码扩展)
24
        Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
25
26
        // 获取执行sql语句的对象Statement
27
        Statement stmt = conn.createStatement();
28
29
        // 执行sql的查询语句，并返回结果
30
        ResultSet rs = stmt.executeQuery("select * from users");
31
32
        // 把取到的数据装到集合中
33
        List<Users> list = new ArrayList<Users>();
34
35
        // 处理结果
36
        Users u = null;
37
        while (rs.next()) {
38
            u = new Users();
39
            u.setId(rs.getInt("id"));
40
            u.setName(rs.getString("name"));
41
            u.setPassword(rs.getString("password"));
42
            u.setEmail(rs.getString("email"));
43
            u.setBirthday(rs.getDate("birthday"));
44
            list.add(u); // 把对象添加到集合中去
45
        }
46
47
        // 遍历集合(增强for)
48
        for (Users user : list) {
49
            System.out.println(user);
50
        }
51
52
        // 关闭资源
53
        rs.close();
54
        stmt.close();
55
        conn.close();
56
    }
57
58
    @Test
59
    public void testInsert() throws Exception {
60
        // 加载驱动
61
        Class.forName("com.mysql.jdbc.Driver");
62
63
        // 获取连接对象Connection(注意；能用接口的就不用实现类，多态=>对象上传=>向上转型=>里氏替换，利于后期代码扩展)
64
        Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
65
66
        // 获取执行sql语句的对象Statement
67
        Statement stmt = conn.createStatement();
68
69
        // 执行sql的插入语句，并返回结果
70
        int i = stmt.executeUpdate("INSERT INTO users VALUES (4, ‘tom‘, ‘123‘,‘tom@163.com‘, ‘2015-09-28‘)");
71
72
        // 处理返回的结果
73
        if (i > 0) {
74
            System.out.println("success");
75
        }
76
77
        // 关闭资源
78
        stmt.close();
79
        conn.close();
80
    }
81
82
    @Test
83
    public void testUpdate() throws Exception {
84
        // 加载驱动
85
        Class.forName("com.mysql.jdbc.Driver");
86
87
        // 获取连接对象Connection(注意；能用接口的就不用实现类，多态=>对象上传=>向上转型=>里氏替换，利于后期代码扩展)
88
        Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
89
90
        // 获取执行sql语句的对象Statement
91
        Statement stmt = conn.createStatement();
92
93
        // 执行sql的更新语句，并返回结果
94
        int i = stmt.executeUpdate("UPDATE users SET NAME = ‘jerry‘, PASSWORD = ‘333‘, email = ‘jerry@163.com‘ WHERE id = 4");
95
96
        // 处理返回的结果
97
        if (i > 0) {
98
            System.out.println("success");
99
        }
100
101
        // 关闭资源
102
        stmt.close();
103
        conn.close();
104
    }
105
106
    @Test
107
    public void testDelete() throws Exception {
108
        // 加载驱动
109
        Class.forName("com.mysql.jdbc.Driver");
110
111
        // 获取连接对象Connection(注意；能用接口的就不用实现类，多态=>对象上传=>向上转型=>里氏替换，利于后期代码扩展)
112
        Connection conn =  DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
113
114
        // 获取执行sql语句的对象Statement
115
        Statement stmt = conn.createStatement();
116
117
        // 执行sql的删除语句，并返回结果
118
        int i = stmt.executeUpdate("DELETE FROM users WHERE id = 4");
119
120
        // 处理返回的结果
121
        if (i > 0) {
122
            System.out.println("success");
123
        }
124
125
        // 关闭资源
126
        stmt.close();
127
        conn.close();
128
    }
129
130
}
技术分享图片


b、可移动游标的方法(现在很少用了，只有next()还常用)


ResultSet结果集的方法： 
boolean next() 将光标从当前位置向前移一行
boolean previous() 将光标移动到此 ResultSet 对象的上一行
boolean absolute(int row)  参数是当前行的索引，从1开始，根据行的索引定位移动的指定索引行
void afterLast()  将光标移动到末尾，正好位于最后一行之后
void beforeFirst()  将光标移动到开头，正好位于第一行之前（即表头）

-----------------------------------------------------------------------------

5、释放资源 

资源有限，要正确关闭。

原则：在使用对象之前，先判断对象是否为空。

把某一部分代码加上try...catch...的快捷键：Alt + Shift + Z

package com.itheima.jdbcdemo;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/*
 * 使用JDBC技术，通过java代码实现查询数据库中的数据并显示在java的控制台中。
 * 
 * 		演示正确释放资源。
 * 
 * 		把某一部分代码加上try...catch...的快捷键：Alt + Shift + Z
 */
public class Demo4 {
	
	public static void main(String[] args) {
		// 获取连接对象Connection
		Connection conn = null;
		// 获取执行sql语句的对象Statement
		Statement stmt = null;
		// 执行sql查询语句，并返回结果
		ResultSet rs = null;
		try {
			// 加载驱动
			Class.forName("com.mysql.jdbc.Driver");
			conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
			stmt = conn.createStatement();
			rs = stmt.executeQuery("select * from users");
			// 处理返回的结果
			while (rs.next()) {
				// 根据列名取值，顺序自己定，更灵活
				System.out.println(rs.getObject("id"));
				System.out.println(rs.getObject("name"));
				System.out.println(rs.getObject("password"));
				System.out.println(rs.getObject("email"));
				System.out.println(rs.getObject("birthday"));
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			// 关闭资源
			if (rs != null) {
				try {
					rs.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
			if (stmt != null) {
				try {
					stmt.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
			if (conn != null) {
				try {
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}	
		}
	}
}
 
1
package com.itheima.jdbcdemo;
2
3
import java.sql.Connection;
4
import java.sql.DriverManager;
5
import java.sql.ResultSet;
6
import java.sql.SQLException;
7
import java.sql.Statement;
8
9
/*
10
 * 使用JDBC技术，通过java代码实现查询数据库中的数据并显示在java的控制台中。
11
 *
12
 *      演示正确释放资源。
13
 *
14
 *      把某一部分代码加上try...catch...的快捷键：Alt + Shift + Z
15
 */
16
public class Demo4 {
17
18
    public static void main(String[] args) {
19
        // 获取连接对象Connection
20
        Connection conn = null;
21
        // 获取执行sql语句的对象Statement
22
        Statement stmt = null;
23
        // 执行sql查询语句，并返回结果
24
        ResultSet rs = null;
25
        try {
26
            // 加载驱动
27
            Class.forName("com.mysql.jdbc.Driver");
28
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day06", "root", "root");
29
            stmt = conn.createStatement();
30
            rs = stmt.executeQuery("select * from users");
31
            // 处理返回的结果
32
            while (rs.next()) {
33
                // 根据列名取值，顺序自己定，更灵活
34
                System.out.println(rs.getObject("id"));
35
                System.out.println(rs.getObject("name"));
36
                System.out.println(rs.getObject("password"));
37
                System.out.println(rs.getObject("email"));
38
                System.out.println(rs.getObject("birthday"));
39
            }
40
        } catch (Exception e) {
41
            e.printStackTrace();
42
        } finally {
43
            // 关闭资源
44
            if (rs != null) {
45
                try {
46
                    rs.close();
47
                } catch (SQLException e) {
48
                    e.printStackTrace();
49
                }
50
            }
51
            if (stmt != null) {
52
                try {
53
                    stmt.close();
54
                } catch (SQLException e) {
55
                    e.printStackTrace();
56
                }
57
            }
58
            if (conn != null) {
59
                try {
60
                    conn.close();
61
                } catch (SQLException e) {
62
                    e.printStackTrace();
63
                }
64
            }
65
        }
66
    }
67
}

============================================================

四、使用JDBC实现CRUD操作

技术分享图片
 注意：
* 一般实体类的类名和数据库的表名一致。(注意：若数据库的表名单词带s的，则实体类名就去掉s)
* 实体类的成员变量名和数据库表中的列名一致。(这是一个约定，网站开发的时候会提到)
后续演示代码的实体类的类名为User。
其实名字可以随意起的，但是一般要求我们做到见名知意。

============================================================

五、实现一个用户登录的功能 

技术分享图片

============================================================

六、解决SQL注入问题：preparedStatement(预编译语句)

技术分享图片

preparedStatement(接口)：预编译对象，是Statement(接口)对象的子类。

特点：（安全高效，防止恶义SQL语法）

1、性能要高；PreparedStatement 实例包含已编译的 SQL 语句，所以其执行速度要快于 Statement 对象。

2、会把sql语句先编译。

3、sql语句中的参数会发生变化，过滤掉用户输入的关键字。

package com.itheima.service;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import com.itheima.entity.User;
import com.itheima.util.DBUtils;

public class DoLogin {

	/**
	 * 根据姓名和密码查询用户信息
	 * @param name
	 * @param password
	 * @return User
	 */
	public User findUser(String name, String password) {
		Connection conn = null;
		// Statement stmt = null;
		PreparedStatement stmt = null;
		ResultSet rs = null;
		User u = null;

		try {
			conn = DBUtils.getConnection();
			
			// stmt = conn.createStatement();
			// String sql = "select * from users where name = ‘" + name + "‘ and password = ‘" + password + "‘";
			// rs = stmt.executeQuery(sql);
			
			String sql = "select * from users where name = ? and password = ?";
		    stmt = conn.prepareStatement(sql);
		    stmt.setString(1, name); // 给?赋值
		    stmt.setString(2, password); // 给?赋值
		    rs = stmt.executeQuery();
			
		    if (rs.next()) {
				u = new User();
				u.setId(rs.getInt("id"));
				u.setName(rs.getString("name"));
				u.setPassword(rs.getString("password"));
				u.setEmail(rs.getString("email"));
				u.setBirthday(rs.getDate("birthday"));
			}
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			DBUtils.closeAll(rs, stmt, conn);
			
		}

		return u;
	}
}
 
1
package com.itheima.service;
2
3
import java.sql.Connection;
4
import java.sql.PreparedStatement;
5
import java.sql.ResultSet;
6
7
import com.itheima.entity.User;
8
import com.itheima.util.DBUtils;
9
10
public class DoLogin {
11
12
    /**
13
     * 根据姓名和密码查询用户信息
14
     * @param name
15
     * @param password
16
     * @return User
17
     */
18
    public User findUser(String name, String password) {
19
        Connection conn = null;
20
        // Statement stmt = null;
21
        PreparedStatement stmt = null;
22
        ResultSet rs = null;
23
        User u = null;
24
25
        try {
26
            conn = DBUtils.getConnection();
27
28
            // stmt = conn.createStatement();
29
            // String sql = "select * from users where name = ‘" + name + "‘ and password = ‘" + password + "‘";
30
            // rs = stmt.executeQuery(sql);
31
32
            String sql = "select * from users where name = ? and password = ?";
33
            stmt = conn.prepareStatement(sql);
34
            stmt.setString(1, name); // 给?赋值
35
            stmt.setString(2, password); // 给?赋值
36
            rs = stmt.executeQuery();
37
38
            if (rs.next()) {
39
                u = new User();
40
                u.setId(rs.getInt("id"));
41
                u.setName(rs.getString("name"));
42
                u.setPassword(rs.getString("password"));
43
                u.setEmail(rs.getString("email"));
44
                u.setBirthday(rs.getDate("birthday"));
45
            }
46
        } catch (Exception e) {
47
            e.printStackTrace();
48
        } finally {
49
            DBUtils.closeAll(rs, stmt, conn);
50
51
        }
52
53
        return u;
54
    }
55
}

============================================================





day06_JDBC学习笔记

标签：ica   mirror   spl   释放   nec   规范   扩展包   junit   getx   

原文地址：https://www.cnblogs.com/chenmingjun/p/8972350.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！