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里面,依然是在数据Curry,ResultSet中的next()方法类似于3个指南针,指向查询的结果,然后不断遍历。所以那就供给连接无法断开。

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接口完结查询操作:

手续如下:(和上一篇博文中的增删改的步骤类似哦)

  • ① 、加载数据库驱动程序:Class.forName(驱动程序类)
  • ② 、通过用户名密码和接二连三地址获取数据库连接对象:DriverManager.getConnection(连接地址,用户名,密码)
  • 叁 、构造查询SQL语句
  • 4、创建Statement实例:Statement stmt = conn.createStatement()
  • 伍 、执行查询SQL语句,并重回结果:ResultSet rs =
    stmt.executeQuery(sql)
  • ⑥ 、处理结果
  • ⑦ 、关闭连接: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,指针会活动指向下一条记下。

3⑧ 、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     }

此处的办法中,传入的参数是是2个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,则会促成3个安全性难点: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     }

下面代码中的第9行正是选用字符串拼接的措施,就会促成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 }

 

相关文章