详解JDBC数据库链接及相关方法的封装
使用的是MySQL数据库,首先导入驱动类,然后根据数据库URL和用户名密码获得数据的链接。由于使用的是MySQL数据库,它的URL一般为,jdbc:mysql://主机地址:端口号/库名。
下面是封装的具体类,用到了泛型和反射,不过还存在些问题,就是对使用的泛型对象有些限制,只能用于泛型类对象属性名与数据库表中列名相同的对象,而且初始化对象的方法必须为set+属性名的方法。本来想通过返回值类型,参数列表来确定该属性初始化方法的,然而可能是目前学到的还是太少,只学了三周,所以并没有实现,感觉这个方法还是很low,以后还要继续完善。本来看到网上有用beanUtils包,利用map将查询的一列存起来,直接转化成该对象的,但是就是想试试新学到的反射。而且最后的垃圾回收器并不能如同C++的析构函数一样,所以关闭数据库链接的地方也需要改善。
实现代码:
publicclass Consql { privatestaticConsql consql=null;//单例设计模式 privateConnectionconn=null;//数据库链接 private final String url;//数据库url private final String username;//数据库用户名 private final Stringpassword;//数据库密码 //驱动类的加载 static{//以静态代码块的形式加载驱动类,静态代码块只在类加载的时候执行一次 try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); } } //构造函数 private Consql(String url,String username,Stringpassword) throws SQLException{ this.url = url; this.username = username; this.password=password; open();//创建连接 } privateConnectionopen() throws SQLException { try {//驱动器获取数据库链接 conn=DriverManager.getConnection(url, username,password); } catch (SQLException e) { // TODO Auto-generated catch block //e.printStackTrace(); throw e; } returnconn; } /** * 带限制条件查找 * @param sql 带占位符?的sql语句 * @param t 返回相关类型对象的类(T.class) * @param params 替换占位符的数据,为动态数组 * @returnArrayList* @throws SQLException */ public ArrayList select(String sql,Class t,Object...params) throws SQLException {//获取T类所有public方法 Method[] declaredMethods = t.getDeclaredMethods(); //创建一个盛放该类型对象集合 ArrayList arrayList=new ArrayList<>(); try (PreparedStatement pStatement=conn.prepareStatement(sql);) { for(inti=0;i Accessible(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; } returnarrayList; } /** * 数据插入 * @param sql 带占位符?的sql语句 * @param params 替换占位符的数据,动态数组 * @throws SQLException */ publicvoidinsert(String sql,Object...params) throws SQLException { try(PreparedStatement pStatement=conn.prepareStatement(sql);) { for(inti=0;i * @throws SQLException */ public ArrayList select(String sql,Class t) throws SQLException { Method[] declaredMethods = t.getDeclaredMethods(); ArrayList arrayList=new ArrayList<>(); try (PreparedStatement pStatement=conn.prepareStatement(sql);) { try(ResultSet rSet=pStatement.executeQuery();) { ResultSetMetaData rData=rSet.getMetaData(); intcolumnCount = rData.getColumnCount(); while (rSet.next()) { T a=t.newInstance(); for(inti=0;i [jdbc链接oracle数据库]详解JDBC数据库链接及相关方法的封装
http://m.bbyears.com/shujuku/135246.html
推荐访问: