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