最近看老罗的视频，跟着完成了利用java操作mysql数据库的一个框架类jdbcutils.java,完成对数据库的增删改查。其中查询这块，包括普通的查询和利用反射完成的查询，主要包括以下几个函数接口:
1、public connection getconnection() 获得数据库的连接 2、public boolean updatebypreparedstatement(string sql, list 3、public map 4、public list<map
上面四个函数已经包括了mysql的所有操作，完全能够满足使用需要。视频里老罗还扩展了两个反射来查询的函数。
5、public
6、 public
下面附完整代码:
jdbcutils.java
package com.jdbc.dbutils; import java.lang.reflect.field; import java.sql.connection; import java.sql.drivermanager; import java.sql.preparedstatement; import java.sql.resultset; import java.sql.resultsetmetadata;import java.sql.sqlexception; import java.util.arraylist;import java.util.hashmap; import java.util.list;import java.util.map; import domain.userinfo; public class jdbcutils { //数据库用户名 private static final string username = "root"; //数据库密码 private static final string password = "yanzi"; //驱动信息 private static final string driver = "com.mysql.jdbc.driver"; //数据库地址 private static final string url = "jdbc:mysql://localhost:3306/mydb"; private connection connection; private preparedstatement pstmt; private resultset resultset; public jdbcutils() { // todo auto-generated constructor stub try{ class.forname(driver); system.out.println("数据库连接成功！"); }catch(exception e){ } } /** * 获得数据库的连接 * @return */ public connection getconnection(){ try { connection = drivermanager.getconnection(url, username, password); } catch (sqlexception e) { // todo auto-generated catch block e.printstacktrace(); } return connection; } /** * 增加、删除、改 * @param sql * @param params * @return * @throws sqlexception */ public boolean updatebypreparedstatement(string sql, listparams)throws sqlexception{ boolean flag = false; int result = -1; pstmt = connection.preparestatement(sql); int index = 1; if(params != null && !params.isempty()){ for(int i=0; i0 ? true : false; return flag; } /** * 查询单条记录 * @param sql * @param params * @return * @throws sqlexception */ public mapfindsimpleresult(string sql, listparams) throws sqlexception{ mapmap = new hashmap(); int index = 1; pstmt = connection.preparestatement(sql); if(params != null && !params.isempty()){ for(int i=0; i<params.size(); i++){ pstmt.setobject(index++, params.get(i)); } } resultset = pstmt.executequery();//返回查询结果 resultsetmetadata metadata = resultset.getmetadata(); int col_len = metadata.getcolumncount(); while(resultset.next()){ for(int i=0; i<col_len; i++ ){ string cols_name = metadata.getcolumnname(i+1); object cols_value = resultset.getobject(cols_name); if(cols_value == null){ cols_value = ""; } map.put(cols_name, cols_value); } } return map; } /**查询多条记录 * @param sql * @param params * @return * @throws sqlexception */ public list<map> findmoderesult(string sql, listparams) throws sqlexception{ list<map> list = new arraylist<map>(); int index = 1; pstmt = connection.preparestatement(sql); if(params != null && !params.isempty()){ for(int i = 0; i<params.size(); i++){ pstmt.setobject(index++, params.get(i)); } } resultset = pstmt.executequery(); resultsetmetadata metadata = resultset.getmetadata(); int cols_len = metadata.getcolumncount(); while(resultset.next()){ mapmap = new hashmap(); for(int i=0; i<cols_len; i++){ string cols_name = metadata.getcolumnname(i+1); object cols_value = resultset.getobject(cols_name); if(cols_value == null){ cols_value = ""; } map.put(cols_name, cols_value); } list.add(map); } return list; } /**通过反射机制查询单条记录 * @param sql * @param params * @param cls * @return * @throws exception */ public t findsimplerefresult(string sql, listparams, classcls )throws exception{ t resultobject = null; int index = 1; pstmt = connection.preparestatement(sql); if(params != null && !params.isempty()){ for(int i = 0; i<params.size(); i++){ pstmt.setobject(index++, params.get(i)); } } resultset = pstmt.executequery(); resultsetmetadata metadata = resultset.getmetadata(); int cols_len = metadata.getcolumncount(); while(resultset.next()){ //通过反射机制创建一个实例 resultobject = cls.newinstance(); for(int i = 0; i<cols_len; i++){ string cols_name = metadata.getcolumnname(i+1); object cols_value = resultset.getobject(cols_name); if(cols_value == null){ cols_value = ""; } field field = cls.getdeclaredfield(cols_name); field.setaccessible(true); //打开javabean的访问权限 field.set(resultobject, cols_value); } } return resultobject; } /**通过反射机制查询多条记录 * @param sql * @param params * @param cls * @return * @throws exception */ public listfindmorerefresult(string sql, listparams, classcls )throws exception { listlist = new arraylist(); int index = 1; pstmt = connection.preparestatement(sql); if(params != null && !params.isempty()){ for(int i = 0; i<params.size(); i++){ pstmt.setobject(index++, params.get(i)); } } resultset = pstmt.executequery(); resultsetmetadata metadata = resultset.getmetadata(); int cols_len = metadata.getcolumncount(); while(resultset.next()){ //通过反射机制创建一个实例 t resultobject = cls.newinstance(); for(int i = 0; i<cols_len; i++){ string cols_name = metadata.getcolumnname(i+1); object cols_value = resultset.getobject(cols_name); if(cols_value == null){ cols_value = ""; } field field = cls.getdeclaredfield(cols_name); field.setaccessible(true); //打开javabean的访问权限 field.set(resultobject, cols_value); } list.add(resultobject); } return list; } /** * 释放数据库连接 */ public void releaseconn(){ if(resultset != null){ try{ resultset.close(); }catch(sqlexception e){ e.printstacktrace(); } } } /** * @param args */ public static void main(string[] args) throws sqlexception { // todo auto-generated method stub jdbcutils jdbcutils = new jdbcutils(); jdbcutils.getconnection(); /*******************增*********************/ /* string sql = "insert into userinfo (username, pswd) values (?, ?), (?, ?), (?, ?)"; listparams = new arraylist(); params.add("小明"); params.add("123xiaoming"); params.add("张三"); params.add("zhangsan"); params.add("李四"); params.add("lisi000"); try { boolean flag = jdbcutils.updatebypreparedstatement(sql, params); system.out.println(flag); } catch (sqlexception e) { // todo auto-generated catch block e.printstacktrace(); } */ /*******************删*********************/ //删除名字为张三的记录 /* string sql = "delete from userinfo where username = ?"; listparams = new arraylist(); params.add("小明"); boolean flag = jdbcutils.updatebypreparedstatement(sql, params); */ /*******************改*********************/ //将名字为李四的密码改了 /* string sql = "update userinfo set pswd = ? where username = ? "; listparams = new arraylist(); params.add("lisi88888"); params.add("李四"); boolean flag = jdbcutils.updatebypreparedstatement(sql, params); system.out.println(flag); */ /*******************查*********************/ //不利用反射查询多个记录 /* string sql2 = "select * from userinfo "; list<map> list = jdbcutils.findmoderesult(sql2, null); system.out.println(list); */ //利用反射查询 单条记录 string sql = "select * from userinfo where username = ? "; listparams = new arraylist(); params.add("李四"); userinfo userinfo; try { userinfo = jdbcutils.findsimplerefresult(sql, params, userinfo.class); system.out.print(userinfo); } catch (exception e) { // todo auto-generated catch block e.printstacktrace(); } } }
+----------+-------------+------+-----+---------+----------------+
是用nvicat提前创建好的:
因为有两个接口用到了反射，因此对应的javabean userinfo.java代码如下:
package domain; import java.io.serializable; public class userinfo implements serializable{ /** * */ private static final long serialversionuid = 1l; private int id;private string username; private string pswd; public userinfo() {// todo auto-generated constructor stub} public int getid() {return id;} public void setid(int id) {this.id = id;} public string getusername() {return username;} public void setusername(string username) {this.username = username;} public string getpswd() {return pswd;} public void setpswd(string pswd) {this.pswd = pswd;} @override public string tostring() {return "userinfo [id=" + id + ", username=" + username + ", pswd="+ pswd + "]"; } }
补充说明:
1. 在安装完mysql-connector-java-gpl-5.1.26.exe后会发现找不到jar包，其实jar文件在c:/program files/mysql/mysql connector j目录下，有两个jar包：
用哪一个都ok。在java工程里新建一个文件夹libs，然后将mysql-connector-java-5.1.26-bin.jar拷贝过去，右键单击 add to build path就ok了。
2.抛开这个框架类jdbcutils.java来说，操作数据库的一般性步骤如下:
（1）连接数据库,加载驱动: class.forname(driver); driver = "com.mysql.jdbc.driver";这本身就是反射！！
(2) 利用用户名和密码及数据库的名字连接，这一步才是真正的连接:
connection = drivermanager.getconnection(url, username, password);
其中：string url = "jdbc:mysql://localhost:3306/mydb";
(3)编写一个sql语句，其中的参数用?来代替，然后将参数写到list里。
执行:pstmt = connection.preparestatement(sql); 然后将参数从list里取出来填充到pstmt里。
(4)如果是增、删、改执行:result = pstmt.executeupdate(); 其中的result是执行完影响的数据库里的行数，也即几条记录。如果是查询执行:resultset = pstmt.executequery(); 返回的类型是resultset类型。之后就是把resultset 弄成map或list
3.关于查询操作，在得到resultset后利用getmetadata得到表的结构信息，如getcolumncount()得到有多少个列。string cols_name = metadata.getcolumnname(i+1); 得到每个列的属性名称，如是id、username还是pswd.然后从object cols_value = resultset.getobject(cols_name);取出来，放到map或list
4.关于查询里利用的反射操作，步骤如下:
(1) t resultobject = cls.newinstance(); 利用class文件的newinstance()方法创建一个实例。
(2)在通过getcolumncount()得到有多少个列之后，进入循环，
string cols_name = metadata.getcolumnname(i+1);
读取每一列的属性名字和放的值。通过属性的名字cols_name进行反射:field field = cls.getdeclaredfield(cols_name);这样就得到了field 等于类里的成员变量，field.setaccessible(true); //打开javabean的访问权限 在利用set方法将从数据库中查出来的cols_value通过javabean 也即定义的userinfo这个类的 set方法赋进去。field.set(resultobject, cols_value);
5.一般意义上，要利用java的反射需要以下步骤
(1)加载class对象，这个一般有两种方式：class cls1 = userinfo.class 或
class cls2 = class.forname("domain.userinfo") 后者是利用包名+类名的方法。
(2)反射出来class之后干啥事呢？一个类不外乎构造函数、成员变量、成员函数。所以得到class之后就可以干这三件事。
a、关于构造函数，获得constructor 有四种方法:
constructor getconstructor(class[] params) constructor[] getconstructors() constructor getdeclaredconstructor(class[] params) constructor[] getdeclaredconstructors()
这四个函数，如果不传参数则是获得所有的构造函数，得到的是一个集合。如果传特定的参数，则是寻找这个特定的构造函数，不带declared是获得公共的public，带了declared是可以获得私有构造函数。 得到构造函数后就可以利用反射创建实例了：
constructor con1[] = cls1.getdeclaredconstructors();
b、关于成员变量，同样有四种方法:
public field getdeclaredfield(string name) 获取任意指定名字的成员
本文封装的jdbcutils类就是利用这种方式操作类里的私有成员变量，记得要setaccessible打开开关。如下：
field field = cls.getdeclaredfield(cols_name);
c、关于成员函数，也有四种方法:
public method[] getmethods() 获取所有的共有方法的集合
参数1：方法名 参数2：参数类型集合
下面是利用文中的userinfo这个类写的一个完成的反射例子，拿到setusername（string username）方法，然后反射。再拿到getusername()方法再反射，然后打印出结果:
class clcs = userinfo.class;
在反射方法的时候，method f = clcs.getdeclaredmethod(setusername, string.class); 原函数里的输入参数是什么类型，就写什么类型.class. 如原来的setxxx需要输入参数string，反射的时候就写string.class.
6. javabean是反射的一种，反射对构造函数之类的没任何要求，javabean要求这个类必须继承serializable即可串行化，另外构造函数必须为public. 另外，就是javabean在得到某个field后可以直接调用set和get，而不必再反射得到method后再执行。
最后，反射是在程序运行的时候而非编译时！！！
参考：链接1 链接2 链接3
以上就是利用java针对mysql封装的jdbc框架类jdbcutils完整实现(包含增删_mysql的内容。