欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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