详解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数据库链接及相关方法的封装的实例详解,如有疑问请留言或者到本站社区交流讨论,感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
华山资源网 Design By www.eoogi.com
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
华山资源网 Design By www.eoogi.com
暂无评论...
更新日志
2024年12月25日
2024年12月25日
- 小骆驼-《草原狼2(蓝光CD)》[原抓WAV+CUE]
- 群星《欢迎来到我身边 电影原声专辑》[320K/MP3][105.02MB]
- 群星《欢迎来到我身边 电影原声专辑》[FLAC/分轨][480.9MB]
- 雷婷《梦里蓝天HQⅡ》 2023头版限量编号低速原抓[WAV+CUE][463M]
- 群星《2024好听新歌42》AI调整音效【WAV分轨】
- 王思雨-《思念陪着鸿雁飞》WAV
- 王思雨《喜马拉雅HQ》头版限量编号[WAV+CUE]
- 李健《无时无刻》[WAV+CUE][590M]
- 陈奕迅《酝酿》[WAV分轨][502M]
- 卓依婷《化蝶》2CD[WAV+CUE][1.1G]
- 群星《吉他王(黑胶CD)》[WAV+CUE]
- 齐秦《穿乐(穿越)》[WAV+CUE]
- 发烧珍品《数位CD音响测试-动向效果(九)》【WAV+CUE】
- 邝美云《邝美云精装歌集》[DSF][1.6G]
- 吕方《爱一回伤一回》[WAV+CUE][454M]