JDBC技术

怼烎@ 2022-06-05 00:47 106阅读 0赞

> JDBC：Java DataBase Connection，是一种Java连接访问数据库的技术（接口）

为什么会出现该技术呢？  
因为Java操作数据库的时候，所使用的数据库是不尽相同的，可能是MySQL，或是Oracle，也可能是SQLServer，那么总不可能每调用一种类型的数据库，就要重新写一种去访问数据库的方法，为了保证通用性，实现了如下架构去访问数据库中的数据：  
![SouthEast][]  
每种类型的数据库都有其相应的驱动类，该驱动类实现了操作数据库的具体方法，而JDBC就是一套操作数据库的标准规范，是接口！  
下面我们就利用JDBC技术实现对数据库数据的操作：  
步骤：  
1.加载驱动  
2.与数据库建立连接：java.sql.Connection接口  
接口的实现在数据库驱动中。所有与数据库交互都是基于连接对象的。  
Statement createStatement(); //创建操作sql语句的对象  
3.获得执行sql的Statement对象：java.sql.Statement接口，操作sql语句，并返回相应结果的对象

*  ResultSet executeQuery(String sql) 根据查询语句返回结果集。只能执行select语句。
 *  int executeUpdate(String sql) 根据执行的DML（insert update delete）语句，返回受影响的行数。
 *  boolean execute(String sql) 此方法可以执行任意sql语句。返回boolean值，表示是否返回ResultSet结果集。仅当执行select语句，且有返回结果时返回true, 其它语句都返回false;

4.执行SQL语句，返回结果：java.sql.ResultSet接口: 结果集（客户端存表数据的对象）  
提供一个游标，默认游标指向结果集第一行之前。  
调用一次next()，游标向下移动一行。  
提供一些get方法。

//创建驱动
            //DriverManager.registerDriver(new com.mysql.jdbc.Driver());
            //加载驱动
            Class.forName("com.mysql.jdbc.Driver");
            //建立连接
            Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/daily_dream?useSSL=false","root","root");
            //获得执行SQL语句的对象
            Statement sta = con.createStatement();
            //执行SQL语句，返回结果
            ResultSet set = sta.executeQuery("select * from dept");
            //处理结果
            List<Dept> list = new ArrayList<>();
            while(set.next()){
                Dept dept = new Dept();
                dept.setDeptno(set.getInt("deptno"));
                dept.setDname(set.getString("dname"));
                dept.setLoc(set.getString("loc"));
                list.add(dept);
            }
            //关闭资源
            set.close();
            sta.close();
            con.close();
            for(Dept d:list){
                System.out.println(d);
            }

其中加载驱动有两种方式：  
1.创建驱动  
DriverManager.registerDriver(new com.mysql.jdbc.Driver());不建议使用  
原因有2个：  
导致驱动被注册2次。  
强烈依赖数据库的驱动jar  
查看Driver类的源码我们可知  
![这里写图片描述][SouthEast 1]  
该类中的static语句块就可以注册驱动。  
解决办法：  
Class.forName(“com.mysql.jdbc.Driver”);  
如果每写一个操作数据库的方法就要将上述的全部代码写一遍，其中有大量重复的冗余代码，所以接下来我们写一个DBUtil类，代码封装成方法，后续如果想造作数据库，可直接调用。  
对于获得连接时的url,username,password，我们直接写在配置文件中，如果后续发生变化，我们只需要修改配置文件即可！  
配置文件dbinfo.properties：

driverClass=com.mysql.jdbc.Driver
    url=jdbc:mysql://localhost:3306/daily_dream?useSSL=false
    username=root
    password=root

DBUtil类：

package com.jdbc;
    
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.InputStream;
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.Statement;
    import java.util.Map;
    import java.util.Properties;
    import java.util.ResourceBundle;
    import java.util.Set;
    
    /** * Created by Dream on 2017/11/10. */
    public class DBUtils { 
        private static String driverClass;
        private static String username;
        private static String password;
        private static String url;
        static {
            //利用ResourceBundle对象，加载配置文件Properties内的数据
            ResourceBundle re = ResourceBundle.getBundle("dbinfo");
            driverClass = re.getString("driverClass");
            url = re.getString("url");
            username = re.getString("username");
            password = re.getString("password");
            //利用Properties 对象加载配置文件，前面博文提到过该类的使用，不再赘述
            /*Properties prop = new Properties(); try { prop.load(new FileInputStream("E:\\ForUs\\jdbc\\src\\dbinfo.properties")); Set<Map.Entry<Object,Object>> set = prop.entrySet(); for(Map.Entry<Object,Object> entry:set){ if(entry.getKey().equals("driverClass")){ driverClass =(String) entry.getValue(); } if(entry.getKey().equals("url")){ url =(String) entry.getValue(); } if(entry.getKey().equals("username")){ username =(String) entry.getValue(); } if(entry.getKey().equals("password")){ password =(String) entry.getValue(); } } }catch (Exception e){ e.printStackTrace(); }*/
            try{
                Class.forName(driverClass);
            }catch (Exception e){
                e.printStackTrace();
            }
        }
        //获得连接
        public static Connection getConnection()throws Exception{
            return DriverManager.getConnection(url,username,password);
        }
        //关闭所有资源
        public static void close(ResultSet re, Statement sta,Connection con){
            if(re != null){
                try{
                    re.close();
                }catch (Exception e){
                //设为空对象，尽快让JVM垃圾处理器回收
                    re = null;
                }
            }
            if(sta != null) {
                try{
                    sta.close();
                }catch (Exception e){
                    sta = null;
                }
            }
            if(con != null){
                try{
                    con.close();
                }catch (Exception e){
                    con = null;
                }
            }
        }
    }
    //上述DBUtils的使用
        public void testInsert(){
            Connection con = null;
            Statement sta = null;
            try{
                con = DBUtils.getConnection();
                sta = con.createStatement();
                int result = sta.executeUpdate("INSERT INTO dept values (55555,'耿耿','BeiJing')");
                if(result>0)
                    System.out.println("Success");
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                DBUtils.close(null,sta,con);
            }
        }

下面我们利用JDBC技术实现一个简单地用户登录功能：输入用户名和密码，则判断是否存在于数据库中，否则登录失败！  
![这里写图片描述][SouthEast 2]  
User.java

package com.jdbc.login.entity;
    
    import java.util.Date;
    
    /** * Created by Dream on 2017/11/12. */
    public class User { 
        private int id;
        private String name;
        private String password;
        private String email;
        private Date birthday;
    
        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 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;
        }
    
        public Date getBirthday() {
            return birthday;
        }
    
        public void setBirthday(Date birthday) {
            this.birthday = birthday;
        }
    
        @Override
        public String toString() {
            return "User{" +
                    "id=" + id +
                    ", name='" + name + '\'' +
                    ", password='" + password + '\'' +
                    ", email='" + email + '\'' +
                    ", birthday=" + birthday +
                    '}';
        }
    }

DoLogin.java

package com.jdbc.login.service;
    
    import com.jdbc.login.entity.User;
    import com.jdbc.login.utils.DBUtils;
    
    import java.sql.Connection;
    import java.sql.ResultSet;
    import java.sql.Statement;
    
    /** * Created by Dream on 2017/11/12. * 根据用户输入的用户名和密码查找数据库，返回User对象 */
    public class DoLogin {
        public User findUser(String name,String pwd){
            Connection con = null;
            Statement sta = null;
            ResultSet rs = null;
            User user = null;
            try{
                con = DBUtils.getConnection();
                sta = con.createStatement();
                rs = sta.executeQuery("SELECT * from users WHERE name ='"+name+"'AND password = '"+pwd+"'");
                if(rs.next()){
                    user = new User();
                    user.setId(rs.getInt(1));
                    user.setName(rs.getString(2));
                    user.setPassword(rs.getString(3));
                    user.setEmail(rs.getString(4));
                    user.setBirthday(rs.getDate(5));
                }
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                DBUtils.closeAll(rs,sta,con);
            }
            return user;
        }
    }

package com.jdbc.login.client;
    
    import com.jdbc.login.entity.User;
    import com.jdbc.login.service.DoLogin;
    
    import java.util.Scanner;
    
    /** * Created by Dream on 2017/11/12. */
    public class Login {
        public static void main(String[] args){
            Scanner scanner = new Scanner(System.in);
            System.out.println("请输入用户名：");
            String name = scanner.nextLine();
            System.out.println("请输入密码：");
            String pwd = scanner.nextLine();
            DoLogin dl = new DoLogin();
            User user = dl.findUser(name,pwd);
            if(user != null){
                System.out.println("恭喜您登录成功!欢迎您，"+name);
            }else{
                System.out.println("用户名或者密码错误！");
            }
        }
    }

对于上述的登录，当我们输入下列数据：  
请输入用户名：  
Dream  
请输入密码：  
dsjfls’ or ‘1’=’1  
恭喜您登录成功!欢迎您，Dream  
其实，数据库中并没有如下用户，那么这又是什么问题？  
SQL注入问题：因为我们执行的SQL语句是拼接的，当我们输入如下数据时，SQL语句变为：  
select \* from users where name = ‘Dream’ and password = ‘dsjfls’ or ‘1’ =’1’  
那么这条SQL语句对所有的数据库数据都成立，因为’1’=’1’永真  
如何解决上述SQL注入问题呢？利用预编译对象PreparedStatement，是Statement对象的子类。  
特点：  
1.性能要高  
2.会把sql语句先编译  
3.sql语句中的参数会发生变化，过滤掉用户输入的关键字。  
代码修改为如下：

public User findUser(String name,String pwd){
            Connection con = null;
            PreparedStatement sta = null;
            ResultSet rs = null;
            User user = null;
            try{
                con = DBUtils.getConnection();
                //需要注入的参数用问号代替
                String sql = "SELECT * from users WHERE name =? AND password = ?";
                //预编译SQL语句
                sta = con.prepareStatement(sql);
                //参数设置
                sta.setString(1,name);
                sta.setString(2,name);
                rs = sta.executeQuery();
                if(rs.next()){
                    user = new User();
                    user.setId(rs.getInt(1));
                    user.setName(rs.getString(2));
                    user.setPassword(rs.getString(3));
                    user.setEmail(rs.getString(4));
                    user.setBirthday(rs.getDate(5));
                }
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                DBUtils.closeAll(rs,sta,con);
            }
            return user;
        }

这样即使用户输入是上述情况，也不能登录成功了。

[SouthEast]: /images/20220605/98e941c9162949b28bfb3419d9b0bc09.png
[SouthEast 1]: /images/20220605/a4fa43fb5083440aa1638fd73985a76f.png
[SouthEast 2]: /images/20220605/23dd259d3f084312b3ce869b100395e3.png