MySQL数据库学习笔记(九)—-JDBC的ResultSet接口(查询操作)、PreparedStatement接口重构增删改查(含SQL注入的解说)

【声明】 

迎转载,但求保留文章原来出处→_→ 

生壹号:http://www.cnblogs.com/smyhvae/

章来源:http://www.cnblogs.com/smyhvae/p/4050825.html

 

【正文】

首先需回顾一下达标等同篇稿子被的情:MySQL数据库学习笔记(八)—-JDBC入门及简单多删改数据库的操作

一致、ResultSet接口的牵线:

针对数据库的询问操作,一般需要返回查询结果,在先后中,JDBC也咱提供了ResultSet接口来特别处理查询结果集。

Statement通过以下方法执行一个查询操作:

ResultSet executeQuery(String sql) throws SQLException 

单词Query就是询问的意思。函数的归来路是ResultSet,实际上查询的多少并无在ResultSet里面,依然是当数据库里,ResultSet中之next()方法类似于一个指针,指向查询的结果,然后连遍历。所以这虽要求连接不能够断开。

ResultSet接口常用方法:

  • boolean next()     遍历时,判断是否来下一个结果
  • int getInt(String columnLabel)
  • int getInt(int columnIndex)
  • Date getDate(String columnLabel)
  • Date getDate(int columnIndex)
  • String getString(String columnLabel)
  • String getString(int columnIndex)

 

其次、ResultSet接口实现查询操作:

手续如下:(和达到同首博文被之增删改之步调类似哦)

  • 1、加载数据库驱动程序:Class.forName(驱动程序类)
  • 2、通过用户名密码和连续地址获取数据库连接对象:DriverManager.getConnection(连接地址,用户称,密码)
  • 3、构造查询SQL语句
  • 4、创建Statement实例:Statement stmt = conn.createStatement()
  • 5、执行查询SQL语句,并赶回结果:ResultSet rs =
    stmt.executeQuery(sql)
  • 6、处理结果
  • 7、关闭连接:rs.close()、stmt.close()、conn.close()

咱来推举个例子吧,来询问下面的此发明:

图片 1

新建工程JDBC02,依旧先导入jar包。然后新建类,完整版本代码如下:

 1 package com.vae.jdbc;
 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 public class JdbcQuey {
10 
11 
12     //数据库连接地址
13     private final static String URL = "jdbc:mysql://localhost:3306/JDBCdb";
14     //用户名
15     public final static String USERNAME = "root";
16     //密码
17     public final static String PASSWORD = "smyh";
18     //加载的驱动程序类(这个类就在我们导入的jar包中)
19     public final static String DRIVER = "com.mysql.jdbc.Driver";
20     
21     public static void main(String[] args) {
22         // TODO Auto-generated method stub
23         query();
24 
25     }
26     
27     
28     //方法:查询操作
29     public static void query(){
30         try {
31             Class.forName(DRIVER);
32             Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
33             String sql = "select id,name,age,description from person";
34             Statement state = conn.createStatement();
35             //执行查询并返回结果集
36             ResultSet rs = state.executeQuery(sql);
37             while(rs.next()){  //通过next来索引:判断是否有下一个记录
38                 //rs.getInt("id"); //方法:int java.sql.ResultSet.getInt(String columnLabel) throws SQLException
39                 int id = rs.getInt(1);  //方法:int java.sql.ResultSet.getInt(int columnIndex) throws SQLException
40 
41                 String name = rs.getString(2);
42                 int age = rs.getInt(3);
43                 String description = rs.getString(4);
44                 System.out.println("id="+id+",name="+name+",age="+age+",description="+description);
45             }
46             rs.close();
47             state.close();
48             conn.close();            
49             
50         } catch (ClassNotFoundException e) {
51             e.printStackTrace();
52         } catch (SQLException e) {
53             e.printStackTrace();
54         }
55     }
56 }

关于代码的解说,可以倾心一篇博客。上方代码的主导组成部分是37暨45实施。

37履:next()函数:通过next来索引,判断是否发生下一个记录。一开始即对准内存的首地址,即首先长长的记下,如果回去回值为true,指针会自动对下同样长记下。

38、39实施:getInt(String columnLabel)或者getInt(int
columnIndex)代表的是排的目录,参数可以是排的名字,也得据此数码来代表,我们一般下后者。编号的相继是据33行sql语句被列的逐一来定的。

程序运行后,后台输出如下:

图片 2

上亦然首博客+以上部分,实现了对数据库的粗略增删改查的操作。其实这种拼接的章程非常糟糕:既麻烦又无安全。我们对接下去进行改良。

 

其三、使用PreparedStatement重构增删改查(推荐)

概念:表示预编译的SQL语句的目标。SQL语句被预编译并存储在PreparedStatement对象中。然后可以采用是目标往往快捷地执行该语句。PreparedStatement是Statement的一个接口。

意:灵活处理sql语句被的变量。

举例:

因下面的及时张数库表为条例:

图片 3

新建Java工程文件JDBC3。新建一个Person类,方便在主方法里进行操作。Person类的代码如下:

package com.vae.jdbc;

public class Person {

    private int id;
    private String name;
    private int age;
    private String description;

    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public int getAge() {
        return age;
    }
    public void setAge(int age) {
        this.age = age;
    }
    public String getDescription() {
        return description;
    }
    public void setDescription(String description) {
        this.description = description;
    }

    public Person(int id, String name, int age, String description) {
        super();
        this.id = id;
        this.name = name;
        this.age = age;
        this.description = description;
    }    

    public Person(String name, int age, String description) {
        super();
        this.name = name;
        this.age = age;
        this.description = description;
    }
    public Person() {
        super();
    }

    @Override
    public String toString() {
        return "Person [id=" + id + ", name=" + name + ", age=" + age
                + ", description=" + description + "]";
    }


}

上是一个简单的Person类,并上加set和get方法及构造方法,无需多说。

安插操作:

当今在主类JDBCtest中贯彻插入操作,完整代码如下:

 1 package com.vae.jdbc;
 2 
 3 import java.sql.Connection;
 4 import java.sql.DriverManager;
 5 import java.sql.PreparedStatement;
 6 import java.sql.SQLException;
 7 
 8 public class JDBCtest {
 9 
10 
11     //数据库连接地址
12     public final static String URL = "jdbc:mysql://localhost:3306/JDBCdb";
13     //用户名
14     public final static String USERNAME = "root";
15     //密码
16     public final static String PASSWORD = "smyh";
17     //驱动类
18     public final static String DRIVER = "com.mysql.jdbc.Driver";
19     
20     
21     public static void main(String[] args) {
22         // TODO Auto-generated method stub
23         Person p = new Person("smyhvae",22,"我是在Java代码中插入的数据");
24         insert(p);
25     }
26     
27 
28 
29     //方法:使用PreparedStatement插入数据
30     public static void insert(Person p){
31         
32         try {
33             Class.forName(DRIVER);
34             Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
35             String sql = "insert into person(name,age,description)values(?,?,?)";
36             PreparedStatement ps = conn.prepareStatement(sql);
37             //设置占位符对应的值
38             ps.setString(1, p.getName());
39             ps.setInt(2, p.getAge());
40             ps.setString(3, p.getDescription());
41             
42             ps.executeUpdate();
43             
44             ps.close();
45             conn.close();
46             
47             
48         } catch (ClassNotFoundException e) {
49             e.printStackTrace();
50         } catch (SQLException e) {
51             e.printStackTrace();
52         }        
53     }
54 }

我们来拘禁一下地方的代码是怎么落实代码的优化的:

30执行:将所有person对象上,代表的凡数据库被的一律长条记下。

35行:问号可以了解吧占用位符,有几只问号就代表要插入几独列,这样看来sql代码就于短小

38至40行:给35实行的问号设值,参数1表示第一只问号的职,以此类推

然后我们在main主方法被叫Person设具体的价值(23履),通过insert()方法就是栽到数据库中错过矣。数据库中不怕大多了相同修记下:

图片 4

创新操作:

代码和上类似,修改操作的法门如下:

 1     //方法:使用PreparedStatement更新数据
 2     public static void update(Person p){
 3         try {
 4             Class.forName(DRIVER);
 5             Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
 6             String sql = "update person set name=?,age=?,description=? where id=?";
 7             PreparedStatement ps = conn.prepareStatement(sql);
 8             //设置占位符对应的值
 9             ps.setString(1, p.getName());
10             ps.setInt(2, p.getAge());
11             ps.setString(3, p.getDescription());
12             ps.setInt(4, p.getId());
13             
14             ps.executeUpdate();
15             
16             ps.close();
17             conn.close();
18             
19             
20         } catch (ClassNotFoundException e) {
21             e.printStackTrace();
22         } catch (SQLException e) {
23             e.printStackTrace();
24         }
25     }

坐在此处来四只问号的挤占位符,所以稍后再main方法吃记得使用四个参数的Person构造方法,传递四单参数。

去操作:

代码和上面类似,方法如下:

 1     //方法:使用PreparedStatement删除数据
 2     public static void delete(int id){
 3         try {
 4             Class.forName(DRIVER);
 5             Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
 6             String sql = "delete from person where id=?";
 7             PreparedStatement ps = conn.prepareStatement(sql);
 8             //设置占位符对应的值
 9             ps.setInt(1, id);
10             
11             ps.executeUpdate();
12             
13             ps.close();
14             conn.close();
15             
16             
17         } catch (ClassNotFoundException e) {
18             e.printStackTrace();
19         } catch (SQLException e) {
20             e.printStackTrace();
21         }
22     }

此处的方式中,传入的参数是凡一个id。

查询操作:

 1     // 使用PreparedStatement查询数据
 2     public static Person findById(int id){
 3         Person p = null;
 4         try {
 5             Class.forName(DRIVER);
 6             Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
 7             String sql = "select name,age,description from person where id=?";
 8             PreparedStatement ps = conn.prepareStatement(sql);
 9             //设置占位符对应的值
10             ps.setInt(1, id);
11             
12             ResultSet rs = ps.executeQuery();
13             if(rs.next()){
14                 p = new Person();
15                 p.setId(id);
16                 p.setName(rs.getString(1));
17                 p.setAge(rs.getInt(2));
18                 p.setDescription(rs.getString(3));
19                 //把 java.sql.Date 与 java.util.Date之间的转换
20 //                java.util.Date date = rs.getDate(4);
21 //                ps.setDate(4, new java.sql.Date(date.getTime()));
22                 
23             }
24             rs.close();
25             ps.close();
26             conn.close();
27             
28             
29         } catch (ClassNotFoundException e) {
30             e.printStackTrace();
31         } catch (SQLException e) {
32             e.printStackTrace();
33         }
34         return p;
35     }

查询操作稍微麻烦一点,在点子吃传来的参数是id,方法的返回值是查询的结果,即Person类。

 

四、PreparedStatement小结:

于JDBC应用中,如果您已是小有水平开发者,你不怕应该尽以PreparedStatement代替Statement。也就是说,在其它时刻还休想动Statement。

冲以下的案由:

  • 一致、代码的可读性和可维护性
  • 次、PreparedStatement可以老最充分或增长性能
  • 老三、最要之某些凡是极大地提高了安全性

若果用Statement而无动PreparedStatement,则会促成一个安全性问题:SQL注入

来拘禁一下SQL注入是怎么回事。现在发生如下的平等摆设用户名密码表user:

图片 5

咱们当履如下sql语句进行询问:

select id,name,pwd from user where name='xxx' and pwd = 'x' or '1'='1'

 

还是能有奇异地查看及持有的用户称、密码信息:

图片 6

以1=1永久是起之,所以就词话永远都立。所以当Java代码中,可以行使这个漏洞,将上的蓝框部分情节作为pwd的变量的内容。来推举个反例:使用Statement写一个登陆的操作:

 1     //登 录(Statement:会造成SQL注入的安全性问题)
 2     public static void login(String name,String pwd){
 3         Person p = null;
 4         try {
 5             Class.forName(DRIVER);
 6             Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
 7 //            String sql = "select id,name,pwd from user where name='' and pwd=''";
 8             
 9             StringBuffer sql = new StringBuffer("select id,name,pwd from user where name='");
10             sql.append(name).append("' and pwd='").append(pwd).append("'");
11             Statement ps = conn.createStatement();
12             
13             ResultSet rs = ps.executeQuery(sql.toString());
14             if(rs.next()){
15             }
16             rs.close();
17             ps.close();
18             conn.close();
19             
20             
21         } catch (ClassNotFoundException e) {
22             e.printStackTrace();
23         } catch (SQLException e) {
24             e.printStackTrace();
25         }
26     }

头代码中之第10履就是是行使字符串拼接的方,就会见招SQL注入的安全性问题。

使若应用PreparedStatement中包含问号的sql语句,程序就算会先对立即句sql语句进行判断,就未会见起字符串拼接的光景了。

 

五、完整版本代码:

说到底附上本文中,PreparedStatement接口重构增删改查的一体化版本代码:

  1 package com.vae.jdbc;
  2 
  3 import java.sql.Connection;
  4 import java.sql.DriverManager;
  5 import java.sql.PreparedStatement;
  6 import java.sql.ResultSet;
  7 import java.sql.SQLException;
  8 
  9 public class JDBCtest {
 10 
 11 
 12     //数据库连接地址
 13     public final static String URL = "jdbc:mysql://localhost:3306/JDBCdb";
 14     //用户名
 15     public final static String USERNAME = "root";
 16     //密码
 17     public final static String PASSWORD = "smyh";
 18     //驱动类
 19     public final static String DRIVER = "com.mysql.jdbc.Driver";
 20     
 21     
 22     public static void main(String[] args) {
 23         // TODO Auto-generated method stub
 24         Person p = new Person();
 25         //insert(p);
 26         //update(p);
 27         //delete(3);
 28         p = findById(2);
 29         System.out.println(p);
 30     }
 31     
 32     
 33     //方法:使用PreparedStatement插入数据
 34     public static void insert(Person p){
 35         
 36         try {
 37             Class.forName(DRIVER);
 38             Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
 39             String sql = "insert into person(name,age,description)values(?,?,?)";
 40             PreparedStatement ps = conn.prepareStatement(sql);
 41             //设置占位符对应的值
 42             ps.setString(1, p.getName());
 43             ps.setInt(2, p.getAge());
 44             ps.setString(3, p.getDescription());
 45             
 46             ps.executeUpdate();
 47             
 48             ps.close();
 49             conn.close();
 50             
 51             
 52         } catch (ClassNotFoundException e) {
 53             e.printStackTrace();
 54         } catch (SQLException e) {
 55             e.printStackTrace();
 56         }        
 57     }
 58     
 59     
 60     //方法:使用PreparedStatement更新数据
 61     public static void update(Person p){
 62         try {
 63             Class.forName(DRIVER);
 64             Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
 65             String sql = "update person set name=?,age=?,description=? where id=?";
 66             PreparedStatement ps = conn.prepareStatement(sql);
 67             //设置占位符对应的值
 68             ps.setString(1, p.getName());
 69             ps.setInt(2, p.getAge());
 70             ps.setString(3, p.getDescription());
 71             ps.setInt(4, p.getId());
 72             
 73             ps.executeUpdate();
 74             
 75             ps.close();
 76             conn.close();
 77             
 78             
 79         } catch (ClassNotFoundException e) {
 80             e.printStackTrace();
 81         } catch (SQLException e) {
 82             e.printStackTrace();
 83         }
 84     }
 85     
 86     
 87     //方法:使用PreparedStatement删除数据
 88     public static void delete(int id){
 89         try {
 90             Class.forName(DRIVER);
 91             Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
 92             String sql = "delete from person where id=?";
 93             PreparedStatement ps = conn.prepareStatement(sql);
 94             //设置占位符对应的值
 95             ps.setInt(1, id);
 96             
 97             ps.executeUpdate();
 98             
 99             ps.close();
100             conn.close();
101             
102             
103         } catch (ClassNotFoundException e) {
104             e.printStackTrace();
105         } catch (SQLException e) {
106             e.printStackTrace();
107         }
108     }
109     
110     
111     // 使用PreparedStatement查询数据
112     public static Person findById(int id){
113         Person p = null;
114         try {
115             Class.forName(DRIVER);
116             Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);
117             String sql = "select name,age,description from person where id=?";
118             PreparedStatement ps = conn.prepareStatement(sql);
119             //设置占位符对应的值
120             ps.setInt(1, id);
121             
122             ResultSet rs = ps.executeQuery();
123             if(rs.next()){
124                 p = new Person();
125                 p.setId(id);
126                 p.setName(rs.getString(1));
127                 p.setAge(rs.getInt(2));
128                 p.setDescription(rs.getString(3));
129                 //把 java.sql.Date 与 java.util.Date之间的转换
130 //                java.util.Date date = rs.getDate(4);
131 //                ps.setDate(4, new java.sql.Date(date.getTime()));
132                 
133             }
134             rs.close();
135             ps.close();
136             conn.close();
137             
138             
139         } catch (ClassNotFoundException e) {
140             e.printStackTrace();
141         } catch (SQLException e) {
142             e.printStackTrace();
143         }
144         return p;
145     }
146     
147 
148 }

 

相关文章