Java基础-面向接口编程-JDBC详解

　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　作者：尹正杰

版权声明：原创作品，谢绝转载！否则将追究法律责任。

 

　　

 

 

 

 

一.JDBC概念和数据库驱动程序

　　JDBC（Java Data Base Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。是Java访问数据库的标准规范。本篇博客使用的介绍的是Java链接MySQL数据库，如果对MySQL数据不是很了解的小伙伴请参考：

　　JDBC提供了一种基准,据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序。JDBC需要连接驱动，驱动是两个设备要进行通信，满足一定通信数据格式，数据格式由设备提供商规定，设备提供商为设备提供驱动软件，通过软件可以与该设备进行通信。

　　本篇博客使用的是mysql的驱动mysql-connector-java-5.1.39-bin.jar，若没有安装包请自行下载，若在网上没有找到相应的解决方案，别担心，我已经帮你把坑踩好了，请参考：h

 

二.JDBC原理

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

三.JDBC的开发步骤

 1>.JDBC操作数据库的步骤

　　a>.注册驱动

　　　　告知JVM使用的是哪一个数据库的驱动。

　　b>.获得链接

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

　　c>.获得语句执行平台

　　　　通过链接对象获取对SQL语句的执行者对象。

　　d>.执行SQL语句

　　　　使用执行者对象，向数据库执行SQL语句，获取到数据库执行后的结果。

　　e>.处理结果

　　　　就是我们当我们拿到数据库执行后的结果想要完成的业务逻辑。

　　f>.释放资源

　　　　关闭网络链接，跟IO流类似，调用其close方法即可。

2>.导入MySQL数据库驱动程序jar包

　　a>.在当前项目下，创建lib目录，在lib目录下创建MySQL目录（用于标识该目录只存放MySQL相关驱动），并将下载的好的按照保导入该文件夹中。

　　b>.将下载后的Java包添加到项目中的环境变量中

　　c>.导入MySQL驱动成功标志

3>.准备数据库数据（我开发环境在虚拟机上安装的，真正的MySQL服务安装在宿主机上，模拟的是生产环境中链接服务器）

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/%E6%95%B0%E6%8D%AE%E5%BA%93%E4%BB%8E%E5%85%A5%E9%97%A8%E5%88%B0%E7%B2%BE%E9%80%9A/ 4 EMAIL:y1053419035@qq.com 5 */ 6  7  8 #创建表结构 9 create table Classmate(10     ID int(11) NOT NULL primary key AUTO_INCREMENT,11     Name varchar(30) COLLATE gbk_bin DEFAULT NULL,12     Age int DEFAULT NULL,13     Job varchar(50),14     Chinese int,15     English int,16     Math int,17     Physics int,18     Chemistry int,19     Biology int20 );21 22 #往表里添加数据23 insert into Classmate values(null,'王建军',30,'Java讲师',100,98,99,96,97,100);24 insert into Classmate values(null,'常庆林',28,'Linux讲师',100,100,98,93,99,96);25 insert into Classmate values(null,'徐培成',35,'BigData讲师',100,100,100,98,96,100);26 insert into Classmate values(null,'李永强',30,'javaEE开发工程师',100,93,91,74,89,100);27 insert into Classmate values(null,'赵子昂',24,'python开发工程师',98,93,91,74,89,100);28 insert into Classmate values(null,'桂阳',25,'C++开发工程师',100,98,93,91,99,82);29 insert into Classmate values(null,'肖云龙',24,'Golang开发工程师',93,97,85,100,93,69);30 insert into Classmate values(null,'李洋',23,'C#开发工程师',100,98,99,96,97,100);31 insert into Classmate values(null,'卜孟龙',30,'BigData开发',98,93,100,100,73,92);32 insert into Classmate values(null,'罗大鹏',22,'Java开发工程师',100,84,91,87,100,93);33 insert into Classmate values(null,'尹正杰',26,'高级运维工程师',100,100,100,100,100,100);

 

四.JDBC执行insert语句( Statement接口的实现类对象)

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/ 4 EMAIL:y1053419035@qq.com 5 */ 6 package cn.org.yinzhengjie.note; 7  8 import java.sql.Connection; 9 import java.sql.DriverManager;10 import java.sql.ResultSet;11 import java.sql.Statement;12 13 public class JDBCDemo {14 15     public static void main(String[] args) throws Exception {16         17         //1.注册驱动,利用java反射技术,将驱动类加入到内容18         /*使用java.sql.DriverManager类静态方法 registerDriver(Driver driver)19           Diver是一个接口,参数传递,MySQL驱动程序中的实现类20           DriverManager.registerDriver(new Driver());21            驱动类源代码,注册2次驱动程序 */22         Class.forName("com.mysql.jdbc.Driver");23         //2.获得数据库连接  DriverManager类中静态方法24         /*static Connection getConnection(String url, String user, String password)  25             返回值是Connection接口的实现类,在mysql驱动程序26             url: 数据库地址  jdbc:mysql://连接主机IP:端口号//数据库名字  */27         String url = "jdbc:mysql://192.168.0.254:5200/yinzhengjie";28         String username="root";29         String password="yinzhengjie";30         Connection conn = DriverManager.getConnection(url, username, password);31         //3.获得语句执行平台, 通过数据库连接对象,获取到SQL语句的执行者对象32         /* conn对象调用方法   Statement createStatement() 获取Statement对象,将SQL语句发送到数据库返回值是 Statement接口的实现类对象.*/33         Statement stat = conn.createStatement();34         //    4.执行sql语句35         /* 通过执行者对象调用方法执行SQL语句,获取结果 int executeUpdate(String sql)  执行数据库中的SQL语句, insert,delete,update操作，返回值int,操作成功数据表多少行 */36         String sql = "insert into Classmate values(null,'邓西',27,'DBA开发工程师',98,100,81,70,100,90);";37         int row = stat.executeUpdate(sql);38         System.out.printf("表中有【%d】行发生了改变！",row);39         //6.释放资源  一堆close()40         stat.close();41         conn.close();42     }43 }44 45 46 /*47 以上代码执行结果如下：48 表中有【1】行发生了改变！49 */

 

五.JDBC执行select语句(ResultSet接口的实现类)

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/ 4 EMAIL:y1053419035@qq.com 5 */ 6 package cn.org.yinzhengjie.note; 7  8 import java.sql.Connection; 9 import java.sql.DriverManager;10 import java.sql.ResultSet;11 import java.sql.Statement;12 /*13  *  JDBC技术,查询数据表,获取结果集14  */15 public class JDBCDemo1 {16     public static void main(String[] args) throws Exception{17         //1. 注册驱动18         Class.forName("com.mysql.jdbc.Driver");19         //2. 获取连接对象20         String url = "jdbc:mysql://192.168.0.254:5200/yinzhengjie";21         String username="root";22         String password="yinzhengjie";23         Connection conn = DriverManager.getConnection(url, username, password);24         //3 .获取执行SQL 语句对象25         Statement stat = conn.createStatement();26         // 拼写查询的SQL27         String sql = "select * from classmate";28         //4. 调用执行者对象方法,执行SQL语句获取结果集29         /* ResultSet executeQuery(String sql)  执行SQL语句中的select查询,返回值ResultSet接口的实现类对象,实现类在mysql驱动中*/30         ResultSet rs = stat.executeQuery(sql);31         //5 .处理结果集32         // ResultSet接口方法 boolean next() 返回true,有结果集,返回false没有结果集33         //获取结果集中的数据，一种是逐行获取每列的内容，如果知道是字符串就用getString方法接住，类型为String，如果知道是数字则用getInt方式接着，类型为int，如果你不知道此列的类型可以用getObject接住，类型为Object。34         /*根据每列的长度进行取值，不推荐使用35         while(rs.next()){36             int id = rs.getInt(1);37             String name = rs.getString(2);38             int age = rs.getInt(3);39             String job = rs.getString(4);40             int Chinese = rs.getInt(5);41             int English = rs.getInt(6);42             int Math = rs.getInt(7);43             int Physics = rs.getInt(8);44             int Chemistry = rs.getInt(9);45             int Biology = rs.getInt(10);46             System.out.println(id +","+ name +","+ age +","+ job +","+ Chinese+","+ English+","+ Math+","+ Physics+","+ Chemistry+","+ Biology);47         }*/48         //除了上面的取值方式，当然还可以用列明的方式取值啦。这样你可以清楚的知道自己取出来的是什么数据，推荐使用该方法。49         while(rs.next()){50             int id = rs.getInt("id");51             String name = rs.getString("name");52             int age = rs.getInt("age");53             String job = rs.getString("job");54             int Chinese = rs.getInt("Chinese");55             int English = rs.getInt("English");56             int Math = rs.getInt("Math");57             int Physics = rs.getInt("Physics");58             int Chemistry = rs.getInt("Chemistry");59             int Biology = rs.getInt("Biology");60             System.out.println(id +","+ name +","+ age +","+ job +","+ Chinese+","+ English+","+ Math+","+ Physics+","+ Chemistry+","+ Biology);61         }62         //6.释放资源  一堆close()63         rs.close();64         stat.close();65         conn.close();66     }67 }68 69 70 71 /*72 以上代码执行结果如下：73 1,王建军,30,Java讲师,100,98,99,96,97,10074 2,常庆林,28,Linux讲师,100,100,98,93,99,9675 3,徐培成,35,BigData讲师,100,100,100,98,96,10076 4,李永强,30,javaEE开发工程师,100,93,91,74,89,10077 5,赵子昂,24,python开发工程师,98,93,91,74,89,10078 6,桂阳,25,C++开发工程师,100,98,93,91,99,8279 7,肖云龙,24,Golang开发工程师,93,97,85,100,93,6980 8,李洋,23,C#开发工程师,100,98,99,96,97,10081 9,卜孟龙,30,BigData开发,98,93,100,100,73,9282 10,罗大鹏,22,Java开发工程师,100,84,91,87,100,9383 11,尹正杰,26,高级运维工程师,100,100,100,100,100,10084 12,邓西,27,DBA开发工程师,98,100,81,70,100,9085 */

 

六.Java防SQL注入的解决方案

1 /*  2 @author :yinzhengjie  3 Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/  4 EMAIL:y1053419035@qq.com  5 */  6 package cn.org.yinzhengjie.note;  7   8 import java.sql.Connection;  9 import java.sql.DriverManager; 10 import java.sql.PreparedStatement; 11 import java.sql.Statement; 12  13 /* 14  *  15  * 1.statement使用的不方便 16  * 2.sql注入的问题 17  *     在SQL语句中使用了系统自带的关键字 or and ,让where条件判断失效 18  *  19  * prepareStatement: 20  *     1.sql语句不用在拼字符串 21  *     2.防止sql注入问题 22  *  23  */ 24 public class CURDDemo { 25  26     public static void main(String[] args) throws Exception { 27 //        insertTest(); 28         insertTest2();        //优化后的代码 29 //         deleteTest(); 30 //         deleteTest2();        //优化后的代码 31     } 32  33     // 删除方法，存在SQL注入风险！ 34     private static void deleteTest() throws Exception { 35         Class.forName("com.mysql.jdbc.Driver"); 36  37         Connection conn = DriverManager.getConnection("jdbc:mysql://192.168.0.254:5200/yinzhengjie", "root", "yinzhengjie"); 38  39         Statement st = conn.createStatement(); 40  41         int id = 4; 42         //定义我们想要执行的语句 43 //        String sql = "delete from emp where eid = " + id "; 44         //一些对SQL语句小朋友喜欢搞点事情，把上面的代码添头加醋,就生成了以下代码(" or 1 = 1"),最终会导致where匹配条件失效，导致清空掉了整个数据库内容！是不是有点小惊讶呢？ 45         String sql = "delete from classmate where id = " + id + " or 1 = 1"; 46         //除了上面说的SQL注入情况外，按照上面的拼接字符串真的让人欲哭无泪啊，庆幸的是我上面测试环境参数相对较少，要是在实际生产环境中就有50个参数要传递那只要你的小手一哆嗦就很容易出错呢！ 47         int i = st.executeUpdate(sql); 48  49         if (i != 0) { 50             System.out.println("删除成功"); 51         } 52  53         st.close(); 54         conn.close(); 55     } 56  57     // 删除优化，解决掉SQL注入风险以及拼接字符串的烦恼！ 58     private static void deleteTest2() throws Exception { 59         Class.forName("com.mysql.jdbc.Driver"); 60         Connection conn = DriverManager.getConnection("jdbc:mysql://192.168.0.254:5200/yinzhengjie", "root", "yinzhengjie"); 61         /*调用Connection接口的方法prepareStatement,获取PrepareStatement接口的实现类,方法中参数,SQL语句中的参数全部采用问号占位符*/ 62         String sql = "delete from classmate where id = ?"; 63         PreparedStatement pst = conn.prepareStatement(sql); 64         //我们在传参数的时候 65 //        pst.setInt(1, 12); 66         //这个时候我们再去模仿SQL注入，发现数据库真实删除的只有第二条。关于后面的“or 1 = 1”压根就没有执行！！，是不是很高大上？ 67         pst.setString(1," 2 or 1 = 1" ); 68         int i = pst.executeUpdate(); 69  70         if (i != 0) { 71             System.out.println("删除成功"); 72         } 73  74         pst.close(); 75         conn.close(); 76     } 77  78     // 增,也能存在SQL注入的风险，不推荐使用！ 79     private static void insertTest() throws Exception { 80         // 注册驱动 81         Class.forName("com.mysql.jdbc.Driver"); 82         // 获取连接 83         Connection conn = DriverManager.getConnection("jdbc:mysql://192.168.0.254:5200/yinzhengjie", "root", "yinzhengjie"); 84         // 创建statement对象 85         Statement st = conn.createStatement(); 86         // 执行sql语句 87         // 真实场景中,sql中的数据都是从外界获取的. 88          89         String name = "方合意"; 90         int age = 21; 91         String job = "Python开发工程师"; 92         int chinese = 100; 93         int english = 89; 94         int math = 98; 95         int physics = 91; 96         int chemistry = 73; 97         int biology = 89; 98          99         String sql = "insert into classmate values(null,'" + name + "', " + age + ", '" + job+ "', " + chinese+ ", " + english+ ", " + math + ", " + physics + ", " + chemistry +", " + biology+ ")";100 101         int i = st.executeUpdate(sql);102         // 判断插入语句是否执行成功103         if (i != 0) {104             System.out.println("插入数据成功");105         }106         st.close();107         conn.close();108     }109 110     //增,防止SQL注入版本！111     private static void insertTest2() throws Exception {112         // 注册驱动113         Class.forName("com.mysql.jdbc.Driver");114 115         // 获取连接116         Connection conn = DriverManager.getConnection("jdbc:mysql://192.168.0.254:5200/yinzhengjie", "root", "yinzhengjie");117         /*调用Connection接口的方法prepareStatement,获取PrepareStatement接口的实现类,方法中参数,SQL语句中的参数全部采用问号占位符*/118         String sql = "insert into classmate values (null,?,?,?,?,?,?,?,?,?)";119 120         PreparedStatement pst = conn.prepareStatement(sql);121         //调用pst对象set方法,设置问号占位符上的参数122         pst.setString(1, "邓聪");123         pst.setInt(2, 28);124         pst.setString(3, "网络工程师");125         pst.setInt(4, 100);126         pst.setInt(5, 98);127         pst.setInt(6, 89);128         pst.setInt(7, 86);129         pst.setInt(8, 97);130         pst.setInt(9, 94);131 132         int i = pst.executeUpdate();133         // 判断插入语句是否执行成功134         if (i != 0) {135             System.out.println("插入数据成功");136         }137 138         pst.close();139         conn.close();140 141     }142 }143 144 145 /*146 以上代码执行结果如下：147 插入数据成功148 */

 

八.JDBC的工具类和测试

1 DriverName=com.mysql.jdbc.Driver2 #zai "url" lu jing hou jia "?useServerPrepStmts=true&cachePrepStmts=true&rewriteBatchedStatements=true" ke yi kai qi pi chu li mo shi !3 url=jdbc:mysql://192.168.0.254:5200/yinzhengjie?useServerPrepStmts=true&cachePrepStmts=true&rewriteBatchedStatements=true4 user=root5 password=yinzhengjie

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/ 4 EMAIL:y1053419035@qq.com 5 */ 6 package cn.org.yinzhengjie.note1; 7  8 import java.io.FileInputStream; 9 import java.io.IOException;10 import java.sql.Connection;11 import java.sql.DriverManager;12 import java.util.Properties;13 14 /*15  * 获取数据库连接的工具类16  * 在获取连接对象的方法中,首先是注册驱动,实际上没有必要17  * 注册驱动只需要执行一次就OK18  * 19  */20 public class Utils {21     22     private Utils(){}23     24     private static Properties p = new Properties();25     private static String driver;26     private static String url;27     private static String user;28     private static String password;29     30     //加载配置文件31     static{32         try {33 //            p.load(Utils.class.getClassLoader().getResourceAsStream("config.properties"));34             p.load(new FileInputStream("config.properties"));35             driver = p.getProperty("DriverName");36             url = p.getProperty("url");37             user = p.getProperty("user");38             password = p.getProperty("password");39         } catch (IOException e) {40             e.printStackTrace();41         }42     }43     44     //注册驱动45     static{46         //注册驱动47         try {48             Class.forName(driver);49         } catch (ClassNotFoundException e) {50             e.printStackTrace();51         }52     }53     54     public static Connection getConnect() throws Exception{55         //获取连接56         Connection conn = DriverManager.getConnection(url, user, password);57         return conn;58     }59 60 }

1 /*  2 @author :yinzhengjie  3 Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/  4 EMAIL:y1053419035@qq.com  5 */  6 package cn.org.yinzhengjie.note1;  7   8 import java.sql.Connection;  9 import java.sql.ResultSet; 10 import java.sql.Statement; 11 import org.junit.Test; 12  13  14 public class Demo { 15     @Test        //注意，这个Test是单元测试，程序员不需要写main方法就可以测试！选中方法名运行即可。 16     public void insertTest() throws Exception{ 17         //使用工具类获取连接 18         Connection conn = Utils.getConnect(); 19          20         // 创建statement对象 21         Statement st = conn.createStatement(); 22  23         // 执行sql语句 24         String sql = "insert into Classmate values(null,'陶涛',22,'网络工程师',100,100,72,93,79,81)"; 25         int i = st.executeUpdate(sql); 26         // 判断插入语句是否执行成功 27         if (i != 0) { 28             System.out.println("插入数据成功"); 29         } 30  31         st.close(); 32         conn.close(); 33     } 34      35     @Test        //注意，这个Test是单元测试，程序员不需要写main方法就可以测试！选中方法名运行即可。 36     public void deleteTest() throws Exception{ 37         Connection conn = Utils.getConnect(); 38          39         Statement st = conn.createStatement(); 40         String name = "陶涛"; 41         //注意，字段需要用单引号引起来，这是数据库的语法规则！因此我们需要在字符串两侧加上相应的单引号！ 42         String sql = "delete from classmate where name = '" + name + "'";     43  44         int i = st.executeUpdate(sql); 45  46         if (i != 0) { 47             System.out.println("删除成功"); 48         } 49  50         st.close(); 51         conn.close(); 52     } 53      54     @Test        //注意，这个Test是单元测试，程序员不需要写main方法就可以测试！选中方法名运行即可。 55     public void updateTest() throws Exception{ 56          57         Connection conn = Utils.getConnect(); 58          59         Statement st = conn.createStatement(); 60          61         String sql = "update classmate set English = English + 120"; 62         int i = st.executeUpdate(sql); 63          64         if (i != 0) { 65             System.out.println("修改成功"); 66         } 67  68         st.close(); 69         conn.close(); 70     } 71      72     @Test        //注意，这个Test是单元测试，程序员不需要写main方法就可以测试！选中方法名运行即可。 73     public void selectTest() throws Exception{ 74         Connection conn = Utils.getConnect(); 75         Statement st = conn.createStatement(); 76          77     String sql = "select * from classmate where id = 11"; 78          79         //执行查询语句！ 80         ResultSet rs = st.executeQuery(sql); 81          82         while(rs.next()){ 83             //如果你不知道返回值是什么类型的话，可以用getObject来接住哟！！！ 84             Object id = rs.getObject("id"); 85             Object name = rs.getObject("name"); 86             Object age = rs.getObject("age"); 87             Object job = rs.getObject("job"); 88             Object chinese = rs.getObject("chinese"); 89             Object english = rs.getObject("english"); 90             Object math = rs.getObject("math"); 91             Object physics = rs.getObject("physics"); 92             Object chemistry = rs.getObject("chemistry"); 93             Object biology = rs.getObject("biology"); 94             System.out.println(id +","+ name +","+ age +","+ job+","+ chinese +","+ english +","+ math +","+ physics +","+ chemistry +","+biology); 95         } 96          97         rs.close(); 98         st.close(); 99         conn.close();100     }101 102 }

 

九.JDBC的异常处理

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/ 4 EMAIL:y1053419035@qq.com 5 */ 6  7 package cn.org.yinzhengjie.note; 8  9 import java.sql.Connection;10 import java.sql.DriverManager;11 import java.sql.PreparedStatement;12 import java.sql.SQLException;13 import java.sql.Statement;14 15 public class ExceptionDemo {16 17     public static void main(String[] args) {18         //提升作用域19         Connection conn = null;20         Statement st = null;21 22         try {23             Class.forName("com.mysql.jdbc.Driver");24 25             conn = DriverManager.getConnection("jdbc:mysql://192.168.0.254:5200/yinzhengjie", "root", "yinzhengjie");26 27             String sql = "insert into classmate values (null,?,?,?,?,?,?,?,?,?)";28 29             PreparedStatement pst = conn.prepareStatement(sql);30 31             pst.setString(1, "杨明明");32             pst.setInt(2, 32);33             pst.setString(3, "网络工程师");34             pst.setInt(4, 100);35             pst.setInt(5, 98);36             pst.setInt(6, 89);37             pst.setInt(7, 86);38             pst.setInt(8, 97);39             pst.setInt(9, 94);40 41             int i = pst.executeUpdate();42             // 判断插入语句是否执行成功43             if (i != 0) {44                 System.out.println("插入数据成功");45             }46 47         } catch (ClassNotFoundException e) {48             e.printStackTrace();49         } catch (SQLException e) {50             e.printStackTrace();51         } finally {52             //对被关闭的对象进行非空判断53             try {54                 if (st != null) {55                     st.close();56                 }57             } catch (SQLException e) {58                 e.printStackTrace();59             }60             try {61                 if (conn != null) {62                     conn.close();63                 }64             } catch (SQLException e) {65                 e.printStackTrace();66             }67         }68 69     }70 }71 72 /*73 以上代码执行结果如下：74 插入数据成功75 */

 

十. JDBC操作较大数据对象

　　如果存储的对象较大，我们可以采用以二进流的方式存储，即BLOB，如果你较大的文本文件的话也可以采用TEXT进行存储。值得一说的是，在测试建表的时候要注意字段的数据类型， 如果类型指定的过小的话可能导致数据存储会失败哟！

1>.准备实验环境

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/%E6%95%B0%E6%8D%AE%E5%BA%93%E4%BB%8E%E5%85%A5%E9%97%A8%E5%88%B0%E7%B2%BE%E9%80%9A/ 4 EMAIL:y1053419035@qq.com 5 */ 6  7 CREATE TABLE myblob( 8     id INT PRIMARY KEY AUTO_INCREMENT, 9     img LONGBLOB10 );11 12 CREATE TABLE mytext(13     id INT PRIMARY KEY AUTO_INCREMENT,14     txt LONGBLOB15 );

2>.JDBC操作BLOB对象

1 DriverName=com.mysql.jdbc.Driver2 #zai "url" lu jing hou jia "?useServerPrepStmts=true&cachePrepStmts=true&rewriteBatchedStatements=true" ke yi kai qi pi chu li mo shi !3 url=jdbc:mysql://192.168.0.254:5200/yinzhengjie?useServerPrepStmts=true&cachePrepStmts=true&rewriteBatchedStatements=true4 user=root5 password=yinzhengjie

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/ 4 EMAIL:y1053419035@qq.com 5 */ 6  7 package cn.org.yinzhengjie.note; 8  9 import java.sql.Connection;10 import java.sql.DriverManager;11 import java.util.ResourceBundle;12 13 /*14  * 获取数据库连接的工具类15  * 在获取连接对象的方法中,首先是注册驱动,实际上没有必要16  * 注册驱动只需要执行一次就OK17  * 18  */19 public class Utils {20     21     private Utils(){}22     23     private static final String DRIVERCLASS;24     private static final String URL;25     private static final String USERNAME;26     private static final String PASSWORD;27     //使用配置文件28     static {29         //注意，这里写文件名的时候不要写全称，我们此处这需要写前缀就好，在Windows操作系统中如果你画蛇添足写上了文件名后缀可能会报错哟！30         DRIVERCLASS = ResourceBundle.getBundle("config").getString("DriverName");31         URL = ResourceBundle.getBundle("config").getString("url");32         USERNAME = ResourceBundle.getBundle("config").getString("user");33         PASSWORD = ResourceBundle.getBundle("config").getString("password");34     }35     36     //注册驱动37     static{38         //注册驱动39         try {40             Class.forName(DRIVERCLASS);41         } catch (ClassNotFoundException e) {42             e.printStackTrace();43         }44     }45     46     public static Connection getConnect() throws Exception{47         48         //获取连接49         Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);50         return conn;51     }52 53 }

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/ 4 EMAIL:y1053419035@qq.com 5 */ 6  7 package cn.org.yinzhengjie.note; 8  9 import java.io.File;10 import java.io.FileInputStream;11 import java.io.FileNotFoundException;12 import java.io.FileOutputStream;13 import java.io.InputStream;14 import java.sql.Connection;15 import java.sql.PreparedStatement;16 import java.sql.ResultSet;17 import java.sql.SQLException;18 19 public class BlobDemo {20 21     public static void main(String[] args) throws Exception {22 //        sava();23         get();24     }25 26     //获取二进制大对象27     private static void get() throws Exception {28         Connection conn = Utils.getConnect();29         String sql = "select img from myblob where id = 1";30         PreparedStatement ps = conn.prepareStatement(sql);31         ResultSet rs = ps.executeQuery();32         if(rs.next()){33             InputStream in = rs.getBinaryStream(1);34             FileOutputStream fos = new FileOutputStream("1.jpg");35             byte[] buf = new byte[4096];36             int len;37             while((len = in.read(buf))!=-1){38                 fos.write(buf,0,len);39             }40             fos.close();41             in.close();42         }43         rs.close();44         ps.close();45         conn.close();46     }47 48     49     50     //保存二进制流文件到数据库51     private static void sava() throws Exception, SQLException, FileNotFoundException {52         Connection conn = Utils.getConnect();53         String sql = "insert into myblob values(null,?)";54         55         PreparedStatement ps = conn.prepareStatement(sql);56 //        ps.setBinaryStream(1, new FileInputStream("c:/dog.jpg"));    //MySQL对这种方式传参不感冒！但是提供了其他方法进行传值！57         File file = new File("C:/Users/yinzhengjie/Desktop/电子相册/1.jpg");58         FileInputStream fis = new FileInputStream(file);59         //将图片保存到数据库服务器中！60         ps.setBinaryStream(1, fis, (int)file.length());        61         62         int i = ps.executeUpdate();63         System.out.println(i);64 65         ps.close();66         conn.close();67     }68 }69 70 71 72 /*73 注意，如果出现以下报错的话，说明你上传的数据大于数据库定义的数据类型了哟！解决方法要么就是上传数据库规定的大小范围，要么修改数据库字段类型的限制范围。74 com.mysql.jdbc.MysqlDataTruncation: Data truncation: Data too long for column 'img' at row 175     at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:2983)*/

3>.JDBC操作TEXT对象

1 DriverName=com.mysql.jdbc.Driver2 #zai "url" lu jing hou jia "?useServerPrepStmts=true&cachePrepStmts=true&rewriteBatchedStatements=true" ke yi kai qi pi chu li mo shi !3 url=jdbc:mysql://192.168.0.254:5200/yinzhengjie?useServerPrepStmts=true&cachePrepStmts=true&rewriteBatchedStatements=true4 user=root5 password=yinzhengjie

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/ 4 EMAIL:y1053419035@qq.com 5 */ 6  7 package cn.org.yinzhengjie.note; 8  9 import java.sql.Connection;10 import java.sql.DriverManager;11 import java.util.ResourceBundle;12 13 /*14  * 获取数据库连接的工具类15  * 在获取连接对象的方法中,首先是注册驱动,实际上没有必要16  * 注册驱动只需要执行一次就OK17  * 18  */19 public class Utils {20     21     private Utils(){}22     23     private static final String DRIVERCLASS;24     private static final String URL;25     private static final String USERNAME;26     private static final String PASSWORD;27     //使用配置文件28     static {29         //注意，这里写文件名的时候不要写全称，我们此处这需要写前缀就好，在Windows操作系统中如果你画蛇添足写上了文件名后缀可能会报错哟！30         DRIVERCLASS = ResourceBundle.getBundle("config").getString("DriverName");31         URL = ResourceBundle.getBundle("config").getString("url");32         USERNAME = ResourceBundle.getBundle("config").getString("user");33         PASSWORD = ResourceBundle.getBundle("config").getString("password");34     }35     36     //注册驱动37     static{38         //注册驱动39         try {40             Class.forName(DRIVERCLASS);41         } catch (ClassNotFoundException e) {42             e.printStackTrace();43         }44     }45     46     public static Connection getConnect() throws Exception{47         48         //获取连接49         Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);50         return conn;51     }52 53 }

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/ 4 EMAIL:y1053419035@qq.com 5 */ 6 package cn.org.yinzhengjie.note; 7  8 import java.io.File; 9 import java.io.FileInputStream;10 import java.io.FileOutputStream;11 import java.io.InputStream;12 import java.sql.Connection;13 import java.sql.PreparedStatement;14 import java.sql.ResultSet;15 16 public class TextDemo {17 18     public static void main(String[] args) throws Exception {19 //        textSava();20         textGet();21     }22 23     private static void textGet() throws Exception {24         Connection conn = Utils.getConnect();25         String sql = "select txt from mytext where id = 1";26         PreparedStatement ps = conn.prepareStatement(sql);27         ResultSet rs = ps.executeQuery();28         if(rs.next()){29             InputStream in = rs.getBinaryStream(1);30             FileOutputStream fos = new FileOutputStream("1.txt");31             byte[] buf = new byte[4096];32             int len;33             while((len = in.read(buf))!=-1){34                 fos.write(buf,0,len);35             }36             fos.close();37             in.close();38         }39         rs.close();40         ps.close();41         conn.close();42     }43 44     private static void textSava() throws Exception {45         Connection conn = Utils.getConnect();46         String sql = "insert into mytext values(null,?)";47         48         PreparedStatement ps = conn.prepareStatement(sql);49         File file = new File("C:/Users/yinzhengjie/Desktop/Java常见的关键字.txt");50         FileInputStream fis = new FileInputStream(file);51         //将图片保存到数据库服务器中！52         ps.setBinaryStream(1, fis, (int)file.length());        53         54         int i = ps.executeUpdate();55         System.out.println(i);56 57         ps.close();58         conn.close();59         60         61     }62     63 }64

 

十一.JDBC批处理案例

1>.准备实验环境

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/%E6%95%B0%E6%8D%AE%E5%BA%93%E4%BB%8E%E5%85%A5%E9%97%A8%E5%88%B0%E7%B2%BE%E9%80%9A/ 4 EMAIL:y1053419035@qq.com 5 */ 6  7 CREATE TABLE test1( 8     id INT PRIMARY KEY AUTO_INCREMENT, 9     num int10 );

2>.批处理操作

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/%E6%95%B0%E6%8D%AE%E5%BA%93%E4%BB%8E%E5%85%A5%E9%97%A8%E5%88%B0%E7%B2%BE%E9%80%9A/ 4 EMAIL:y1053419035@qq.com 5 */ 6  7 CREATE TABLE test1( 8     id INT PRIMARY KEY AUTO_INCREMENT, 9     num int10 );

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/ 4 EMAIL:y1053419035@qq.com 5 */ 6  7 package cn.org.yinzhengjie.note; 8  9 import java.sql.Connection;10 import java.sql.DriverManager;11 import java.util.ResourceBundle;12 13 /*14  * 获取数据库连接的工具类15  * 在获取连接对象的方法中,首先是注册驱动,实际上没有必要16  * 注册驱动只需要执行一次就OK17  * 18  */19 public class Utils {20     21     private Utils(){}22     23     private static final String DRIVERCLASS;24     private static final String URL;25     private static final String USERNAME;26     private static final String PASSWORD;27     //使用配置文件28     static {29         //注意，这里写文件名的时候不要写全称，我们此处这需要写前缀就好，在Windows操作系统中如果你画蛇添足写上了文件名后缀可能会报错哟！30         DRIVERCLASS = ResourceBundle.getBundle("config").getString("DriverName");31         URL = ResourceBundle.getBundle("config").getString("url");32         USERNAME = ResourceBundle.getBundle("config").getString("user");33         PASSWORD = ResourceBundle.getBundle("config").getString("password");34     }35     36     //注册驱动37     static{38         //注册驱动39         try {40             Class.forName(DRIVERCLASS);41         } catch (ClassNotFoundException e) {42             e.printStackTrace();43         }44     }45     46     public static Connection getConnect() throws Exception{47         48         //获取连接49         Connection conn = DriverManager.getConnection(URL, USERNAME, PASSWORD);50         return conn;51     }52 53 }

1 /* 2 @author :yinzhengjie 3 Blog:http://www.cnblogs.com/yinzhengjie/tag/Java%E5%9F%BA%E7%A1%80/ 4 EMAIL:y1053419035@qq.com 5 */ 6 package cn.org.yinzhengjie.note; 7  8 import java.sql.Connection; 9 import java.sql.PreparedStatement;10 import java.sql.SQLException;11 import java.sql.Statement;12 13 /*14  * 1.驱动版本5.1.13以上15  * 2.在url中开启批处理功能16  */17 public class BatchTest {18 19     public static void main(String[] args) throws Exception {20         test1();        //3526毫秒21 //        test2();        //用时1523毫秒22     }23     24 25     //5.1.13之后批处理功能，SQL语句的整体框架变动起来很方便！26     private static void test1() throws Exception, SQLException {27         Connection conn = Utils.getConnect();28         Statement st = conn.createStatement();29         long start = System.currentTimeMillis();30         for(int i = 0;i<100000;i++){31             String sql = "insert into test1 values(null," + i + ")";32             st.addBatch(sql);33         }34         35         st.executeBatch();36         st.clearBatch();37         st.close();38         conn.close();39         System.out.println(System.currentTimeMillis() - start);40     }41     42     //SQL语句的整体框架变动起来麻烦，需要逐个进行预编译43     private static void test2() throws Exception, SQLException {44         Connection conn = Utils.getConnect();45         String sql = "insert into test1 values(null,?)";46         PreparedStatement ps = conn.prepareStatement(sql);47         long start = System.currentTimeMillis();48         49         for(int i = 1;i<=100000;i++){50             ps.setInt(1, i);51             if(i % 1000 == 0){52                 ps.executeBatch();53                 ps.clearBatch();54             }55             ps.addBatch();56         }57         58         ps.executeBatch();59         ps.clearBatch();60         ps.close();61         conn.close();62         System.out.println(System.currentTimeMillis() - start);63     }64 65 }