大数据之路week05--day01（JDBC 初识）

一、概述

JDBC（Java Data Base Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。是Java访问数据库的标准规范

JDBC提供了一种基准,据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序。

JDBC需要连接驱动，驱动是两个设备要进行通信，满足一定通信数据格式，数据格式由设备提供商规定，设备提供商为设备提供驱动软件，通过软件可以与该设备进行通信。

今天我们使用的是mysql的驱动mysql-connector-java-5.1.39-bin.jar

提供我的百度云链接，有需要的自行下载：

　　链接：https://pan.baidu.com/s/1ZiJMW1brgjWFvXH1dueeLg
　　提取码：ram7

二、JDBC原理

Java提供访问数据库规范称为JDBC，而生产厂商提供规范的实现类称为驱动。

JDBC是接口，驱动是接口的实现，没有驱动将无法完成数据库连接，从而不能操作数据库！每个数据库厂商都需要提供自己的驱动，用来连接自己公司的数据库，也就是说驱动一般都由数据库生成厂商提供。

 三、JDBC开发步骤   重点，必须记住

1.注册驱动

　　用来告诉JVM使用的是哪个生产厂商的驱动

2.获得链接，链接数据库

　　使用JDBC中的类，完成对MySQL数据库的链接　

3.获得语句执行平台

　　通过连接对象获取对SQL语句的执行对象

4.执行SQL语句

　　使用执行对象对数据库执行SQL语句

　　获取执行结果

5.处理结果

　　处理结果集，（insert、update、delete无需处理）

6.释放资源

　　调用一堆 close()方法，将调用的对象弹栈

 　　　详细步骤：

　　1.导入驱动jar包

　　创建lib文件夹，存放所需要的所有jar包。

　　选择jar包，右键选择 bulid path 再选择 Add to bulid path 

　　如图：

　　

这样就加载好了。

　　2.注册驱动

　　代码：class.forName("com.mysql.jdbc.Dirver");　

　　  JDBC规范定义驱动接口：java.sql.Driver，MySql驱动包提供了实现类：com.mysql.jdbc.Driver

　　 3.获得链接

　　   代码：Connection conn=DiverManager.getConnection("jdbc:Mysql://localhost:3306/goods,'root','123456'");

　　     获取连接需要方法 DriverManager.getConnection(url,username,password)，三个参数分别表示，url 需要连接数据库的位置（网址） user用户名  password 密　　

             url比较复杂，下面是mysql的url：　

　　　　    jdbc:mysql://localhost:3306/mydb

　　　　　JDBC规定url的格式由三部分组成，每个部分中间使用冒号分隔。

　　　　   第一部分是jdbc，这是固定的；

　　　　   第二部分是数据库名称，那么连接mysql数据库，第二部分当然是mysql了；

                 第三部分是由数据库厂商规定的，我们需要了解每个数据库厂商的要求，mysql的第三部分分别由数据库服务器的IP地址（localhost）、端口号（3306），以及DATABASE名称(mydb)组成。

 

（后面的操作，朋友们完全可以自己新建一个数据库，建几张表和数据进行学习，这里数据库的sql文件就不在这给出了。）

 

代码实现：

package MySQL测试连接;

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

/**

 * 创建时间：2019年11月30日 下午9:06:12

 * 项目名称：MySQL_Test

 * @author WYH

 * @version 1.0

 * @since JDK 1.8.0

 * 文件名称：Test.java

 * 类说明：

 */

public class Test {
    public static void main(String[] args) {
        try {
            //加载驱动
            Class.forName("com.mysql.jdbc.Driver");
            
            //连接数据库
            String url = "jdbc:mysql://127.0.0.1:3306/school";
            Connection con = DriverManager.getConnection(url, "root", "root");
            System.out.println(con);//com.mysql.jdbc.JDBC4Connection@728938a9   表示连接成功
            con.close();
            
            //
            
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        
    }

}

　　　4.获得SQL语句执政平台

　　　代码：String sql="某sql语句";

　　　获取Statement语句执行平台：Statement stmt=con.createStatement();

　　　常用方法：

　　　(1)int executeUpdate(String sql); ------ 执行intert 、update、delete（增删改操作）语句

　　　   (2)ResultSet executeQuery(String sql);-------执行select（查询操作） 语句

　　    (3) boolean execute(String sql); --执行select返回true 执行其他的语句返回false.

代码测试：

package MySQL测试连接;

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

/**

 * 创建时间：2019年12月1日 下午4:37:34

 * 项目名称：MySQL_Test

 * @author WYH

 * @version 1.0

 * @since JDK 1.8.0

 * 文件名称：Test2.java

 * 类说明：

 */

public class Test2 {
    public static void main(String[] args) {
        Connection conn = null;
        Statement state = null;
        ResultSet rs = null;
        
        
        try {
            //加载驱动
            Class.forName("com.mysql.jdbc.Driver");
            
            //建立连接
            conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/school","root","root");
//            System.out.println(conn);
            
            //创建Statem对象
            state = conn.createStatement();
            
            //传sql语句到数据库，用rs接收查到的数据结果集
            rs = state.executeQuery("SELECT SubjectNo,SubjectName,ClassHour,GradeName FROM `subject` "
                    + "INNER JOIN grade ON(`subject`.GradeID=grade.GradeID) order by SubjectNo");//注意这里可以不用写分号，写了也不算错
            
            //while循环判断及接收
            while(rs.next()){//next指针，如果有值就返回true
                String SubjectNo = rs.getString("SubjectNo");
                String SubjectName = rs.getString("SubjectName");
                String ClassHour = rs.getString(3);//3代表第三列
                String GradeName = rs.getString("GradeName");
                
                System.out.println("课程编号="+SubjectNo+" 课程名称="+SubjectName+" 课程时长="+ClassHour+" 年纪编号="+GradeName);
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            if(rs!=null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(state!=null){
                try {
                    state.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
             
    }

}

　　5.处理结果集（执行insert、update、delete无需处理）

　　　　ResultSet实际上就是一张二维的表格，我们可以调用其boolean next()方法指向某行记录，当第一次调用next()方法时，便指向第一行记录的位置，

　　　这时就可以使用ResultSet提供的getXXX(int col)方法(与索引从0开始不同个，列从1开始)来获取指定列的数据：

　　　代码：rs.next();//指向第一行　　　　

　　　　　　　  rs.getInt(1);//获取第一行第一列的数据

 

  常用方法：

　(1)Object getObject(int index) / Object getObject(String name) 获得任意对象

    (2)  String getString(int index) / Object getObject(String name) 获得字符串

    (3)  int getInt(int index) / Object getObject(String name) 获得整形

    (4)  double getDouble(int index) / Object getObject(String name) 获得双精度浮点型

代码演示（以插入为例，删除和修改和这个类似，基本上就是改改sql语句，而查询不一样，这里给出插入和查询的例子）：

package MySQL测试连接;

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

/**

 * 创建时间：2019年12月2日 上午8:55:15

 * 项目名称：MySQL_Test

 * @author WYH

 * @version 1.0

 * @since JDK 1.8.0

 * 文件名称：Test4.java

 * 类说明：
 *         增删查改

 */

public class Test4 {
    public static void main(String[] args) {
        Connection conn = null;
        Statement state = null;
        ResultSet rs = null;
        
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/school","root","root");
            state = conn.createStatement();
//            System.out.println(conn);
            String InsertSql = "insert into t_student(sid,sname,gender,Classid) values('789','rows','nv',6)";
            int i = state.executeUpdate(InsertSql);
            System.out.println("共有"+i+"条记录被影响");
            rs = state.executeQuery("select * from t_student");    
            while(rs.next()){
                String s1 = rs.getString(1);
                String s2 = rs.getString(2);
                String s3 = rs.getString(3);
                String s4 = rs.getString(4);
                System.out.println(s1+" "+s2+" "+s3+" "+s4);
            }
            
            
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            if(rs!=null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(state!=null){
                try {
                    state.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
        
    }
        

　  　6.释放资源

　　与IO流一样，使用后的东西都需要关闭！关闭的顺序是先得到的后关闭，后得到的先关闭。

　　实例代码：　

 

　　   　　　　　　rs.close();

　　　　　　　   　stmt.close();

　　　　　　　　   con.close();

 

　　　四、SQL注入问题

假设有登录案例SQL语句如下:

　　　　SELECT * FROM 用户表 WHERE NAME = 用户输入的用户名 AND PASSWORD = 用户输的密码;

此时，当用户输入正确的账号与密码后，查询到了信息则让用户登录。但是当用户输入的账号为XXX 密码为：XXX’  OR ‘a’=’a时，则真正执行的代码变为：

　　　　SELECT * FROM 用户表 WHERE NAME = ‘XXX’ AND PASSWORD =’ XXX’  OR ’a’=’a’;

此时，上述查询语句时永远可以查询出结果的。那么用户就直接登录成功了，显然我们不希望看到这样的结果，这便是SQL注入问题。

为此，我们使用PreparedStatement来解决对应的问题。

　　五、预处理对象

使用PreparedStatement预处理对象时，建议每条sql语句所有的实际参数，都使用逗号分隔。

String sql = "insert into sort(sid,sname) values(?,?)";;
PreparedStatement预处理对象代码：
PreparedStatement psmt = conn.prepareStatement(sql);

　　常用方法：　　

　　1.    执行SQL语句:

  int executeUpdate(); --执行insert update delete语句.

  ResultSet executeQuery(); --执行select语句.

  boolean execute(); --执行select返回true 执行其他的语句返回false.

2.设置实际参数

  void setXxx(int index, Xxx xx) 将指定参数设置为给定Java的xx值。在将此值发送到数据库时，驱动程序将它转换成一个 SQL Xxx类型值。

　　 例如：

   setString(2, "家用电器") 把SQL语句中第2个位置的占位符？ 替换成实际参数 "家用电器"

代码举例实现：

package MySQL测试连接;

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

/**

 * 创建时间：2019年12月1日 下午4:37:34

 * 项目名称：MySQL_Test

 * @author WYH

 * @version 1.0

 * @since JDK 1.8.0

 * 文件名称：Test2.java

 * 类说明：
 *         动态Sql查询 防止sql注入
 * 
 * 注意：
 *         1、动态sql查询的创建Statement对象的方式和之前的不一样
 * 
 *         2、conn.prepareStatement(sql); 在创建Statement对象的时候就将sql语句带入了
 *                而之前的conn.createStatement();并没有，而是在获取结果集的时候带入sql语句
 *         
 *         3、动态sql语句通配需要注意的问题，通配符有几个，下面的set复制就要有几个，对应上，不能少些或者多写
 *         

 */

public class Test3 {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        
        String sql = "select * from student where StudentName like ? and Sex=?";
        
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/school","root","root");
            ps = conn.prepareStatement(sql);
            ps.setString(1, "李%");
            ps.setInt(2, 2);
            rs = ps.executeQuery();
//            System.out.println("sid		sname	gender	Classid");
            while(rs.next()){
                System.out.println(rs.getString(1)+"	"+rs.getString(2)+"	"+rs.getString(3)+"	"+rs.getString(4)+"	"
                        +"	"+rs.getString(5)+"	"+rs.getString(6)+"	"+rs.getString(7)+"	"+rs.getString(8)
                        +"	"+rs.getString(9)+"	"+rs.getString(10));
            }
            
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally{
            if(rs!=null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(ps!=null){
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }    
        
    }

}