Java |
您所在的位置：网站首页 › jdbc驱动包应该放在哪里 › Java |
Java
|
目录 第一章 JDBC 1.1 JDBC概述 1.2 JDBC原理 1.3 案例分析 1.4 JDBC开发步骤 1.4.1 导入驱动jar包 1.4.2 API详解：注册驱动 1.4.3 API详解：获得链接 1.4.4 API详解：获得语句执行平台 1.4.5 API详解：处理结果集（执行insert、update、delete无需处理） 1.4.6 API详解：释放资源 1.5 SQL注入问题 1.6 API详解：预处理对象 1.7 预处理对象executeUpdate方法 1.7.1 增删改 1.8 预处理对象executeQuery方法 1.8.1 查询 1.9 JDBC工具类 第二章 properties配置文件 2.1 使用properties配置文件 2.2 创建配置文件 2.3 加载配置文件：Properties对象 2.4 使用JDBCUtils工具类 第一章 JDBC 1.1 JDBC概述JDBC（Java Data Base Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。是Java访问数据库的标准规范。 通俗来讲，JDBC屏蔽了各种数据库之间的差异,是Sun公司定义的类或者接口。 JDBC提供了一种基准,据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序。 JDBC需要连接驱动，驱动是两个设备要进行通信，满足一定通信数据格式，数据格式由设备提供商规定，设备提供商为设备提供驱动软件，通过软件可以与该设备进行通信。 今天我们使用的是mysql的驱动mysql-connector-java-5.1.39-bin.jar 1.2 JDBC原理 Java提供访问数据库规范称为JDBC，而生产厂商提供规范的实现类称为驱动。
JDBC是接口，驱动是接口的实现，没有驱动将无法完成数据库连接，从而不能操作数据库！每个数据库厂商都需要提供自己的驱动，用来连接自己公司的数据库，也就是说驱动一般都由数据库生成厂商提供。
1.3 案例分析 昨天我们学习了sql语句的使用，并创建的分类表sort，今天我们将使用JDBC对分类表进行增删改查操作。 CREATE TABLE sort( sid INT PRIMARY KEY AUTO_INCREMENT, sname VARCHAR(100), sprice DOUBLE, sdesc VARCHAR(5000) ); #初始化数据 INSERT INTO sort(sname,sprice,sdesc) VALUES('家电',2000,'优惠的促销'), ('家具',8900,'家具价格上调,原材料涨价'), ('儿童玩具',300,'赚家长钱'), ('生鲜',500.99,'生鲜商品'), ('服装',24000,'换季销售'), ('洗涤',50,'洗发水促销') SELECT * FROM sort1.4 JDBC开发步骤 注册驱动.获得连接.获得语句执行平台执行sql语句处理结果释放资源. 1.4.1 导入驱动jar包 创建lib目录，用于存放当前项目需要的所有jar包 选择jar包，右键执行build path / Add to Build Path
1.4.2 API详解：注册驱动 Class.forName("com.mysql.jdbc.Driver"); JDBC规范定义驱动接口：java.sql.Driver，MySql驱动包提供了实现类：com.mysql.jdbc.Driver DriverManager工具类，提供注册驱动的方法 registerDriver()，方法的参数是java.sql.Driver，所以我们可以通过如下语句进行注册: DriverManager.registerDriver(new com.mysql.jdbc.Driver()); 以上代码不推荐使用，存在两方面不足 硬编码，后期不易于程序扩展和维护驱动被注册两次。通过查询com.mysql.jdbc.Driver源码，我们发现Driver类“主动”将自己进行注册 DriverManager.registerDriver(new com.mysql.jdbc.Driver());//若这样写则Driver()注册了两次com.mysql.jdbc.Driver源码: //com.mysql.jdbc.Driver源码 public class Driver extends NonRegisteringDriver implements java.sql.Driver { // // Register ourselves with the DriverManager // static { try { java.sql.DriverManager.registerDriver(new Driver()); } catch (SQLException E) { throw new RuntimeException("Can't register driver!"); } }因此我们使用反射机制，来注册驱动，即使用Class.forName() 加载一个使用字符串描述的驱动类,这避免了我们两次注册。 如果使用Class.forName()将类加载到内存，该类的静态代码将自动执行。 注意：Class.forName(“ ”)//括号中给出类的全名 Class.forName("com.mysql.jdbc.Driver");//括号中给出类的全名
1.4.3 API详解：获得链接 代码： Connection con = DriverManager.getConnection(“jdbc:mysql://localhost:3306/mydb”,”root”,”root”);获取连接需要方法 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)组成。 1.4.4 API详解：获得语句执行平台 String sql = "某SQL语句"; 获取Statement语句执行平台：Statement stmt = con.createStatement(); 常用方法： int executeUpdate(String sql); --执行insert update delete语句. ResultSet executeQuery(String sql); --执行select语句. boolean execute(String sql); --执行select返回true 执行其他的语句返回false. 1.4.5 API详解：处理结果集（执行insert、update、delete无需处理） ResultSet实际上就是一张二维的表格，我们可以调用其boolean next()方法指向某行记录，当第一次调用next()方法时，便指向第一行记录的位置，这时就可以使用ResultSet提供的getXXX(int col)方法(与索引从0开始不同个，列从1开始)来获取指定列的数据： rs.next();//指向第一行 rs.getInt(1);//获取第一行第一列的数据 常用方法： Object getObject(int index) / Object getObject(String name) 获得任意对象 String getString(int index) / Object getObject(String name) 获得字符串 int getInt(int index) / Object getObject(String name) 获得整形 double getDouble(int index) / Object getObject(String name) 获得双精度浮点型 1.4.6 API详解：释放资源 与IO流一样，使用后的东西都需要关闭！关闭的顺序是先得到的后关闭，后得到的先关闭。 rs.close(); stmt.close(); con.close(); package day29.demo1; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; /* JDBC操作数据库的步骤 1.注册驱动 告知JVM使用的是哪一个数据库的驱动 2.获得连接 使用JDBC中的类,完成对MySQL数据库的连接 3.获得语句执行平台 通过连接对象获取对SQL语句的执行者对象 4.执行sql语句 使用执行者对象,向数据库执行SQL语句 获取到数据库的执行后的结果 5.处理结果 6.释放资源 一堆close() */ public class JDBCDemo { public static void main(String[] args)throws ClassNotFoundException,SQLException{ //1.注册驱动 反射技术,将驱动类加入到内容 // 使用java.sql.DriverManager类静态方法 registerDriver(Driver driver) // Diver是一个接口,参数传递,MySQL驱动程序中的实现类 //DriverManager.registerDriver(new Driver()); //驱动类源代码,注册2次驱动程序 Class.forName("com.mysql.jdbc.Driver"); //2.获得数据库连接 DriverManager类中静态方法 //static Connection getConnection(String url, String user, String password) //返回值是Connection接口的实现类,在mysql驱动程序 //url: 数据库地址 jdbc:mysql://连接主机IP:端口号//数据库名字 String url = "jdbc:mysql://localhost:3306/pra? characterEncoding=utf-8 "; String username="root"; String password=""; Connection con = DriverManager.getConnection(url, username, password); System.out.println(con); //3.获得语句执行平台, 通过数据库连接对象,获取到SQL语句的执行者对象 // con对象调用方法 Statement createStatement() 获取Statement对象,将SQL语句发送到数据库 // 返回值是 Statement接口的实现类对象,,在mysql驱动程序 Statement stat = con.createStatement(); // 4.执行sql语句 // 通过执行者对象调用方法执行SQL语句,获取结果 // int executeUpdate(String sql) 执行数据库中的SQL语句, insert delete update // 返回值int,操作成功数据表多少行 int row = stat.executeUpdate ("INSERT INTO sort(sname,sprice,sdesc) VALUES('汽车用品',50000,'疯狂涨价')"); System.out.println(row); //6.释放资源 一堆close() stat.close(); con.close(); } }运行结果：
运行结果：
1.5 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注入问题。 为此，我们使用Statement的子类PreparedStatement来解决对应的问题，并且为每个占位符指定参数。 注入攻击： --注入攻击 CREATE TABLE users( id INT PRIMARY KEY AUTO_INCREMENT, username VARCHAR(100), PASSWORD VARCHAR(100) ); INSERT INTO users (username,PASSWORD) VALUES ('a','1'),('b','2'); SELECT * FROM users; -- 登录查询 SELECT * FROM users WHERE username='dsfsdfd' AND PASSWORD='wrethiyu'1 OR 1=1 SELECT * FROM users WHERE username='a' AND PASSWORD='1'OR'1=1'users表
注入攻击可以理解为：我在执行的sql语句后面加上 or ‘1= 1’类似的语句，不管怎样返回值结果都为true，因此登录成功。 1.6 API详解：预处理对象 使用PreparedStatement预处理对象时，建议每条sql语句所有的实际参数，都使用逗号分隔。 String sql = "insert into sort(sid,sname) values(?,?)";; PreparedStatement预处理对象代码： PreparedStatement psmt = conn.prepareStatement(sql) 常用方法： 执行SQL语句: int executeUpdate(); --执行insert update delete语句. ResultSet executeQuery(); --执行select语句. boolean execute(); --执行select返回true 执行其他的语句返回false. 设置实际参数 void setXxx(int index, Xxx xx) 将指定参数设置为给定Java的xx值。在将此值发送到数据库时，驱动程序将它转换成一个 SQL Xxx类型值。 例如： setString(2, "家用电器") 把SQL语句中第2个位置的占位符？ 替换成实际参数 "家用电器" package cn.itcast.demo; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; import java.util.Scanner; /* * Java程序实现用户登录,用户名和密码,数据库检查 * 演示被别人注入攻击 */ public class JDBCDemo2 { public static void main(String[] args)throws Exception { Class.forName("com.mysql.jdbc.Driver"); String url = "jdbc:mysql://localhost:3306/mybase"; String username = "root"; String password = "123"; Connection con = DriverManager.getConnection(url, username, password); Statement stat = con.createStatement(); Scanner sc = new Scanner(System.in); String user = sc.nextLine(); String pass = sc.nextLine(); //执行SQL语句,数据表,查询用户名和密码,如果存在,登录成功,不存在登录失败 String sql = "SELECT * FROM users WHERE username='"+user+"' AND PASSWORD='"+pass+"'"; System.out.println(sql); ResultSet rs = stat.executeQuery(sql); while(rs.next()){ System.out.println(rs.getString("username")+" "+rs.getString("password")); } rs.close(); stat.close(); con.close(); } }运行结果：
1.7 预处理对象executeUpdate方法 通过预处理对象的executeUpdate方法，完成记录的insert\update\delete语句的执行。操作格式统一如下： 1. 注册驱动 2. 获取连接 3. 获取预处理对象 4. SQL语句占位符设置实际参数 5. 执行SQL语句 6. 释放资源 1.7.1 增删改增删改都用 pst.executeUpdate(); package day29.demo1; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; /* * 使用PrepareStatement接口,实现数据表的更新操作 */ public class JDBCDemo4 { public static void main(String[] args) throws Exception{ Class.forName("com.mysql.jdbc.Driver"); String url = "jdbc:mysql://localhost:3306/pra? characterEncoding=utf-8 "; String username="root"; String password=""; Connection con = DriverManager.getConnection(url, username, password); //拼写修改的SQL语句,参数采用?占位 String sql = "UPDATE sort SET sname=?,sprice=? WHERE sid=?"; //调用数据库连接对象con的方法prepareStatement获取SQL语句的预编译对象 PreparedStatement pst = con.prepareStatement(sql); //调用pst的方法setXXX设置?占位 pst.setObject(1, "汽车美容"); pst.setObject(2, 49988); pst.setObject(3, 7); //调用pst方法执行SQL语句 pst.executeUpdate(); pst.close(); con.close(); } }
1.8 预处理对象executeQuery方法 通过预处理对象的executeQuery方法，完成记录的select语句的执行。操作格式统一如下： 1. 注册驱动 2. 获取连接 3. 获取预处理对象 4. SQL语句占位符设置实际参数 5. 执行SQL语句 6. 处理结果集(遍历结果集合) 7. 释放资源 1.8.1 查询查询用： pst.executeQuery(); import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; /* * PrepareStatement接口实现数据表的查询操作 */ public class JDBCDemo1 { public static void main(String[] args) throws Exception{ Class.forName("com.mysql.jdbc.Driver"); String url = "jdbc:mysql://localhost:3306/mybase"; String username="root"; String password="123"; Connection con = DriverManager.getConnection(url, username, password); String sql = "SELECT * FROM sort"; PreparedStatement pst = con.prepareStatement(sql); //调用pst对象的方法,执行查询语句,Select ResultSet rs=pst.executeQuery(); while(rs.next()){ System.out.println(rs.getString("sid")+" "+rs.getString("sname")+" "+rs.getString("sprice")+" "+rs.getString("sdesc")); } rs.close(); pst.close(); con.close(); } }1.9 JDBC工具类 “获得数据库连接”操作，将在以后的增删改查所有功能中都存在，可以封装工具类JDBCUtils。提供获取连接对象的方法，从而达到代码的重复利用。 该工具类提供方法：public static Connection getConn ()。代码如下： 静态代码块异常抛不出去，使用try...catch JDBC工具类： package day29.demo1; /* * 实现JDBC的工具类 * 定义方法,直接返回数据库的连接对象 * * 写关闭方法 */ import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class JDBCUtils { private JDBCUtils(){} private static Connection con ; static{ try{ Class.forName("com.mysql.jdbc.Driver"); String url = "jdbc:mysql://localhost:3306/pra? characterEncoding=utf-8 "; String username="root"; String password=""; con = DriverManager.getConnection(url, username, password); }catch(Exception ex){ throw new RuntimeException(ex+"数据库连接失败"); } } /* * 定义静态方法,返回数据库的连接对象 */ public static Connection getConnection(){ return con; } public static void close(Connection con,Statement stat){ if(stat!=null){ try{ stat.close(); }catch(SQLException ex){} } if(con!=null){ try{ con.close(); }catch(SQLException ex){} } } public static void close(Connection con,Statement stat , ResultSet rs){ if(rs!=null){ try{ rs.close(); }catch(SQLException ex){} } if(stat!=null){ try{ stat.close(); }catch(SQLException ex){} } if(con!=null){ try{ con.close(); }catch(SQLException ex){} } } }测试类： package day29.demo2; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import day29.demo1.JDBCUtils; public class TestJDBCUtils { public static void main(String[] args)throws Exception { Connection con = JDBCUtils.getConnection(); PreparedStatement pst = con.prepareStatement("SELECT sname FROM sort"); ResultSet rs = pst.executeQuery(); while(rs.next()){ System.out.println(rs.getString("sname")); } JDBCUtils.close(con, pst, rs); /*List list = new XXXX() * while(rs.next()){ Sort s = new Sort(rs.getInt("")......); list.add(s); } * */ } }运行结果：
Sort类：（与数据库定义相同） package day29.demo2; public class Sort { private int sid; private String sname; private double sprice; private String sdesc; public Sort(int sid, String sname, double sprice, String sdesc) { super(); this.sid = sid; this.sname = sname; this.sprice = sprice; this.sdesc = sdesc; } public Sort() { super(); } public int getSid() { return sid; } public void setSid(int sid) { this.sid = sid; } public String getSname() { return sname; } public void setSname(String sname) { this.sname = sname; } public double getSprice() { return sprice; } public void setSprice(double sprice) { this.sprice = sprice; } public String getSdesc() { return sdesc; } public void setSdesc(String sdesc) { this.sdesc = sdesc; } @Override public String toString() { return "Sort [sid=" + sid + ", sname=" + sname + ", sprice=" + sprice + ", sdesc=" + sdesc + "]"; } }JDBC工具类： package day29.demo2; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.util.ArrayList; import java.util.List; import day29.demo1.JDBCUtils; /* * JDBC读取数据表sort,每行数据封装到Sort类的对象中 * 很多个Sort类对象,存储到List集合中 */ public class JDBCDemo { public static void main(String[] args) throws Exception{ //使用JDBC工具类,直接获取数据库连接对象 Connection con = day29.demo1.JDBCUtils.getConnection(); //连接获取数据库SQL语句执行者对象 PreparedStatement pst = con.prepareStatement("SELECT * FROM sort"); //调用查询方法,获取结果集 ResultSet rs = pst.executeQuery(); //创建集合对象 List list = new ArrayList(); while(rs.next()){ //获取到每个列数据,封装到Sort对象中 Sort s = new Sort(rs.getInt("sid"),rs.getString("sname"),rs.getDouble("sprice"),rs.getString("sdesc")); //封装的Sort对象,存储到集合中 list.add(s); } JDBCUtils.close(con, pst, rs); //遍历List集合 for(Sort s : list){ System.out.println(s); } } }运行结果：
第二章 properties配置文件 2.1 使用properties配置文件 开发中获得连接的4个参数（驱动、URL、用户名、密码）通常都存在配置文件中，方便后期维护，程序如果需要更换数据库，只需要修改配置文件即可。 通常情况下，我们习惯使用properties文件，此文件我们将做如下要求： 文件位置：任意，建议src下 文件名称：任意，扩展名为properties 文件内容：一行一组数据，格式是“key=value”. —key命名自定义，如果是多个单词，习惯使用点分隔。例如：jdbc.driver —value值不支持中文，如果需要使用非英文字符，将进行unicode转换。
2.2 创建配置文件 在项目跟目录下，创建文件，输入“db.properties”文件名。 文件中的内容: driver=com.mysql.jdbc.Driver url=jdbc:mysql://localhost:3306/pra user=root password= 2.3 加载配置文件：Properties对象 对应properties文件处理，开发中也使用Properties对象进行。我们将采用加载properties文件获得流，然后使用Properties对象进行处理。 连接数据库的操作只执行一次，因此不能写在main中（调用一次，执行一次main，不合适），因此写在static中。 JDBCUtilsConfig.java中编写代码: import java.io.InputStream; import java.sql.Connection; import java.sql.DriverManager; import java.util.Properties; /* * 编写数据库连接的工具类,JDBC工具类 * 获取连接对象采用读取配置文件方式 * 读取文件获取连接,执行一次,static{} */ public class JDBCUtilsConfig { private static Connection con ; private static String driverClass; private static String url; private static String username; private static String password; static{ try{ readConfig(); Class.forName(driverClass); con = DriverManager.getConnection(url, username, password); }catch(Exception ex){ throw new RuntimeException("数据库连接失败"); } } private static void readConfig()throws Exception{ InputStream in = JDBCUtilsConfig.class.getClassLoader().getResourceAsStream("database.properties"); Properties pro = new Properties(); pro.load(in); System.out.println(in); driverClass=pro.getProperty("driverClass"); url = pro.getProperty("url"); username = pro.getProperty("username"); password = pro.getProperty("password"); } public static Connection getConnection(){ return con; } }System.out.println(in)输出为null：
System.out.println(in)输出为null的原因： 1.bin目录下没有database.properties文件（在scr在重新建立一个，bin目录下回自动复制一份database.properties文件） 2.database.properties文件位置应该和该类的包在同一级。举例：
以后连接数据库，只需要修改database.properties配置文件即可。 2.4 使用JDBCUtils工具类测试类文件 TestJDBCUtils1.java文件： package day29.demo2; import java.sql.Connection; public class TestJDBCUtils1 { public static void main(String[] args) { Connection con = JDBCUtilsConfig.getConnection(); System.out.println(con); } }运行结果：
|
【本文地址】
今日新闻 |
推荐新闻 |