详解JDBC数据库链接及相关方法的封装
程序员文章站
2023-11-14 16:09:16
详解jdbc数据库链接及相关方法的封装
使用的是mysql数据库,首先导入驱动类,然后根据数据库url和用户名密码获得数据的链接。由于使用的是mysql数据库,它的ur...
详解jdbc数据库链接及相关方法的封装
使用的是mysql数据库,首先导入驱动类,然后根据数据库url和用户名密码获得数据的链接。由于使用的是mysql数据库,它的url一般为,jdbc:mysql://主机地址:端口号/库名。
下面是封装的具体类,用到了泛型和反射,不过还存在些问题,就是对使用的泛型对象有些限制,只能用于泛型类对象属性名与数据库表中列名相同的对象,而且初始化对象的方法必须为set+属性名的方法。本来想通过返回值类型,参数列表来确定该属性初始化方法的,然而可能是目前学到的还是太少,只学了三周,所以并没有实现,感觉这个方法还是很low,以后还要继续完善。本来看到网上有用beanutils包,利用map将查询的一列存起来,直接转化成该对象的,但是就是想试试新学到的反射。而且最后的垃圾回收器并不能如同c++的析构函数一样,所以关闭数据库链接的地方也需要改善。
实现代码:
public class consql { private static consql consql=null;//单例设计模式 private connection conn=null;//数据库链接 private final string url;//数据库url private final string username;//数据库用户名 private final string password;//数据库密码 //驱动类的加载 static{//以静态代码块的形式加载驱动类,静态代码块只在类加载的时候执行一次 try { class.forname("com.mysql.jdbc.driver"); } catch (classnotfoundexception e) { e.printstacktrace(); } } //构造函数 private consql(string url,string username,string password) throws sqlexception{ this.url = url; this.username = username; this.password = password; open();//创建连接 } private connection open() throws sqlexception { try {//驱动器获取数据库链接 conn=drivermanager.getconnection(url, username, password); } catch (sqlexception e) { // todo auto-generated catch block //e.printstacktrace(); throw e; } return conn; } /** * 带限制条件查找 * @param sql 带占位符?的sql语句 * @param t 返回相关类型对象的类(t.class) * @param params 替换占位符的数据,为动态数组 * @return arraylist<t> * @throws sqlexception */ public <t> arraylist<t> select(string sql,class<t> t,object...params) throws sqlexception {//获取t类所有public方法 method[] declaredmethods = t.getdeclaredmethods(); //创建一个盛放该类型对象集合 arraylist<t> arraylist=new arraylist<>(); try (preparedstatement pstatement=conn.preparestatement(sql);) { for(int i=0;i<params.length;i++) { pstatement.setobject(i+1, params[i]); } try(resultset rset=pstatement.executequery();) { resultsetmetadata rdata=rset.getmetadata(); //获取查询到结果表的列数 int columncount = rdata.getcolumncount(); while (rset.next()) { t a=t.newinstance();//创建泛型类实例 for(int i=0;i<columncount;i++) {//获得方数组里的set方法,这里造成了局限性,只能数据库表列名与对象名一致,且只能是set方法 string astring="set"+rdata.getcolumnname(i+1); for (method method : declaredmethods) { if(method.getparametercount()==1&&method.getreturntype().tostring().equals("void")&&method.getname().equalsignorecase(astring)) {//这里存在问题,前两个判断条件基本没用,主要是最初不想用上面拼串的方式来判断是不是调用该参数的方法 method.setaccessible(true); //利用反射调用该方法 method.invoke(a, rset.getobject(i+1)); break; } } } arraylist.add(a); } } catch (instantiationexception e) { // todo auto-generated catch block e.printstacktrace(); } catch (illegalaccessexception e) { // todo auto-generated catch block e.printstacktrace(); } catch (illegalargumentexception e) { // todo auto-generated catch block e.printstacktrace(); } catch (invocationtargetexception e) { // todo auto-generated catch block e.printstacktrace(); } } catch (sqlexception e) { // todo auto-generated catch block throw e; } return arraylist; } /** * 数据插入 * @param sql 带占位符?的sql语句 * @param params 替换占位符的数据,动态数组 * @throws sqlexception */ public void insert(string sql,object...params) throws sqlexception { try(preparedstatement pstatement=conn.preparestatement(sql);) { for(int i=0;i<params.length;i++) { pstatement.setobject(i+1, params[i]); } pstatement.executeupdate(); } catch (sqlexception e) { // todo auto-generated catch block throw e; } } /** * 数据更新 * @param sql 带占位符?的sql语句 * @param params 替换占位符的数据,动态数组 * @throws sqlexception */ public void update(string sql,object...params) throws sqlexception { try(preparedstatement pstatement=conn.preparestatement(sql);) { for(int i=0;i<params.length;i++) { pstatement.setobject(i+1, params[i]); } pstatement.executeupdate(); } catch (sqlexception e) { // todo auto-generated catch block throw e; } } /** * 带限制条件删除 * @param sql 带占位符?的sql语句 * @param params 替换占位符的数据,动态数组 * @throws sqlexception */ public void delete(string sql,object...params) throws sqlexception { try(preparedstatement pstatement=conn.preparestatement(sql);) { for(int i=0;i<params.length;i++) { pstatement.setobject(i+1, params[i]); } pstatement.executeupdate(); } catch (sqlexception e) { // todo auto-generated catch block throw e; } } /** * 删除全部,不带有限制 * @param sql * @throws sqlexception */ public void deleteall(string sql) throws sqlexception { try(preparedstatement pstatement=conn.preparestatement(sql);) { pstatement.executeupdate(); } catch (sqlexception e) { // todo auto-generated catch block throw e; } } /** * 无限制条件查找 * @param sql * @param t 泛型类t.class * @return arraylist<t> * @throws sqlexception */ public <t> arraylist<t> select(string sql,class<t> t) throws sqlexception { method[] declaredmethods = t.getdeclaredmethods(); arraylist<t> arraylist=new arraylist<>(); try (preparedstatement pstatement=conn.preparestatement(sql);) { try(resultset rset=pstatement.executequery();) { resultsetmetadata rdata=rset.getmetadata(); int columncount = rdata.getcolumncount(); while (rset.next()) { t a=t.newinstance(); for(int i=0;i<columncount;i++) { string astring="set"+rdata.getcolumnname(i+1); for (method method : declaredmethods) { if(method.getname().equalsignorecase(astring)) { method.setaccessible(true); method.invoke(a, rset.getobject(i+1)); break; } } } arraylist.add(a); } } catch (instantiationexception e) { // todo auto-generated catch block e.printstacktrace(); } catch (illegalaccessexception e) { // todo auto-generated catch block e.printstacktrace(); } catch (illegalargumentexception e) { // todo auto-generated catch block e.printstacktrace(); } catch (invocationtargetexception e) { // todo auto-generated catch block e.printstacktrace(); } } catch (sqlexception e) { // todo auto-generated catch block throw e; } return arraylist; } /** * 返回表中数据行数 * @param tablename 数据库表名 * @return 行数 * @throws sqlexception */ public int count(string tablename) throws sqlexception { string sql="select count(*) from "+tablename; try(preparedstatement pstatement=conn.preparestatement(sql); resultset rsset=pstatement.executequery(); ) { if(rsset.next()) { return rsset.getint(1); } } catch (sqlexception e) { // todo auto-generated catch block throw e; } return 0; } /** * 判断数据是否存在 * @param sql 带占位符?的sql语句 * @param params 替换占位符的数据,动态数组 * @return boolean * @throws sqlexception */ public boolean isexist(string sql,object...params) throws sqlexception { try(preparedstatement pstatement=conn.preparestatement(sql);) { for(int i=0;i<params.length;i++) { pstatement.setobject(i+1, params[i]); } try(resultset rsset=pstatement.executequery();) { if(rsset.next()) { return true; } } finally { } } catch (sqlexception e) { // todo auto-generated catch block throw e; } return false; } /** * 创建实例 * @param url 数据库url * @param username 用户名 * @param password 密码 * @return consql对象 * @throws sqlexception */ public static consql getnewinstance(string url,string username,string password) throws sqlexception { if(consql==null) consql=new consql(url, username, password); return consql; } //垃圾回收,貌似并不能达到析构函数的效果 protected void finalize() throws throwable { if(conn!=null) { conn.close(); } super.finalize(); } }
以上就是详解jdbc数据库链接及相关方法的封装的实例详解,如有疑问请留言或者到本站社区交流讨论,感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
推荐阅读