详解JDBC数据库链接及相关方法的封装

详解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数据库链接及相关方法的封装的实例详解，如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

# JDBC数据库链接及相关方法的封装  # 数据库的链接封装  # 关于JDBC的简单封装(实例讲解)  # 简单通用JDBC辅助类封装(实例)  # 基于JDBC封装的BaseDao(实例代码)  # java的jdbc简单封装方法  # 的是  # 加载  # 行数  # 如有  # 希望能  # 只在  # 造成了  # 并不能  # 太少  # 谢谢大家  # 不带  # 能达到  # 想用  # 学了  # 创建一个  # 存在问题  # 转化成  # 是否存在  # 三周  # 返回值 

相关文章： 广东专业制作网站有哪些,广东省能源集团有限公司官网？  建站主机服务器选型指南与性能优化方案解析  装修招标网站设计制作流程,装修招标流程？    建站之星3.0如何解决常见操作问题？  太平洋网站制作公司,网络用语太平洋是什么意思？  潮流网站制作头像软件下载,适合母子的网名有哪些？  微信小程序制作网站有哪些,微信小程序需要做网站吗？  建站之星安装失败：服务器环境不兼容？  高性能网站服务器配置指南：安全稳定与高效建站核心方案  如何在云虚拟主机上快速搭建个人网站？  h5网站制作工具有哪些,h5页面制作工具有哪些？  C++如何使用std::optional？（处理可选值）  再谈Python中的字符串与字符编码（推荐）  洛阳网站制作公司有哪些,洛阳的招聘网站都有哪些？  网站视频制作书签怎么做,ie浏览器怎么将网站固定在书签工具栏？  制作网页的网站有哪些,电脑上怎么做网页？  网站制作新手教程,新手建设一个网站需要注意些什么？  建站主机是否等同于虚拟主机？  为什么Go需要go mod文件_Go go mod文件作用说明  天河区网站制作公司,广州天河区如何办理身份证？需要什么资料有预约的网站吗？  建站之星CMS建站配置指南：模板选择与SEO优化技巧  如何快速辨别茅台真假？关键步骤解析  Python文件管理规范_工程实践说明【指导】  建站上市公司网站建设方案与SEO优化服务定制指南  合肥做个网站多少钱,合肥本地有没有比较靠谱的交友平台？  制作网站的过程怎么写,用凡科建站如何制作自己的网站？  ,想在网上投简历，哪几个网站比较好？  如何处理“XML格式不正确”错误 常见XML well-formed问题解决方法  建站与域名管理如何高效结合？  已有域名和空间如何快速搭建网站？  高端智能建站公司优选：品牌定制与SEO优化一站式服务  清单制作人网站有哪些,近日“兴风作浪的姑奶奶”引起很多人的关注这是什么事情？  制作表格网站有哪些,线上表格怎么弄？  建站之星如何取消后台验证码生成？  建站之星如何开启自定义404页面避免用户流失？  湖北网站制作公司有哪些,湖北清能集团官网？  建站主机选购指南：核心配置与性价比推荐解析  建站主机助手选型指南：2025年热门推荐与高效部署技巧  微信h5制作网站有哪些,免费微信H5页面制作工具？  南京网站制作费用,南京远驱官方网站？  制作电商网页,电商供应链怎么做？  佛山企业网站制作公司有哪些,沟通100网上服务官网？  济南网站制作的价格,历城一职专官方网站？  如何在云主机上快速搭建网站？  定制建站哪家更专业可靠？推荐榜单揭晓  logo在线制作免费网站在线制作好吗,DW网页制作时，如何在网页标题前加上logo？  如何选择长沙网站建站模板？H5响应式与品牌定制哪个更优？  矢量图网站制作软件,用千图网的一张矢量图做公司app首页，该网站并未说明版权等问题，这样做算不算侵权？应该如何解决？  如何快速查询网址的建站时间与历史轨迹？