Java工具类如何实现数据库查询连接?

更新于
2026-10-04 12:24:43
2阅读来源:SEO基础
  • 内容介绍
  • 文章标签
  • 相关推荐

本文共计399个文字,预计阅读时间需要2分钟。

通过主键ID获取对象:

javapublic static T getObject(Class c, int id) { T t=null; ResultSet rs=null; try { // 获取所有列名 List columns=new ArrayList(); // 根据类生成列名 addColumnByClass(c, columns); // 生成SQL语句 String sql=SELECT + String.join(, , columns) + FROM + c.getSimpleName() + WHERE id=?; // 执行查询 rs=executeQuery(sql, id); if (rs.next()) { t=c.getDeclaredConstructor().newInstance(); for (String column : columns) { // 设置对象属性 setProperty(t, column, rs.getObject(column)); } } } catch (Exception e) { e.printStackTrace(); } finally { close(rs); } return t;}

gistfile1.txt

/**通过主键ID获取对象*/ public static T getObject(Class c,int id){ T t=null; ResultSet rs=null; try { //获取所有的列名 List columns=new ArrayList (); //生成列名 addColumnByClass(c,columns); //生成SQL语句 String sql=getSelectSql(columns,c); rs=getReusultSet(sql, id); if(rs.next()) t= SetInfo(c, columns, rs); return t; } catch (SQLException e) { e.printStackTrace(); } catch (IllegalArgumentException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); }finally{ close(); } return t; } /**通过SQL语句和参数,查询整个集合*/ public static List getListBySql(Class c,String sql,List plist){ List list=new ArrayList (); ResultSet rs=null; try { //列名集合 List columns=new ArrayList (); //赋值列名集合 //生成列名 addColumnByClass(c,columns); rs=getReusultSet(sql, plist); while (rs.next()) { list.add(SetInfo(c, columns, rs)); } } catch (SQLException e) { e.printStackTrace(); }finally{ //此处的结果集对象也应该放在close关闭 try { rs.close(); } catch (SQLException e) { e.printStackTrace(); } close(); } return list; } /**通过SQL语句和参数,查询整个集合*/ public static T getObject(Class c,String sql,List plist){ T t=null; ResultSet rs=null; try { //列名集合 List columns=new ArrayList (); //赋值列名集合 //生成列名 addColumnByClass(c,columns); rs=getReusultSet(sql, plist); if (rs.next()) { t=SetInfo(c, columns, rs); } } catch (SQLException e) { e.printStackTrace(); }finally{ //此处的结果集对象也应该放在close关闭 try { rs.close(); } catch (SQLException e) { e.printStackTrace(); } close(); } return t; }

本文共计399个文字,预计阅读时间需要2分钟。

通过主键ID获取对象:

javapublic static T getObject(Class c, int id) { T t=null; ResultSet rs=null; try { // 获取所有列名 List columns=new ArrayList(); // 根据类生成列名 addColumnByClass(c, columns); // 生成SQL语句 String sql=SELECT + String.join(, , columns) + FROM + c.getSimpleName() + WHERE id=?; // 执行查询 rs=executeQuery(sql, id); if (rs.next()) { t=c.getDeclaredConstructor().newInstance(); for (String column : columns) { // 设置对象属性 setProperty(t, column, rs.getObject(column)); } } } catch (Exception e) { e.printStackTrace(); } finally { close(rs); } return t;}

gistfile1.txt

/**通过主键ID获取对象*/ public static T getObject(Class c,int id){ T t=null; ResultSet rs=null; try { //获取所有的列名 List columns=new ArrayList (); //生成列名 addColumnByClass(c,columns); //生成SQL语句 String sql=getSelectSql(columns,c); rs=getReusultSet(sql, id); if(rs.next()) t= SetInfo(c, columns, rs); return t; } catch (SQLException e) { e.printStackTrace(); } catch (IllegalArgumentException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); }finally{ close(); } return t; } /**通过SQL语句和参数,查询整个集合*/ public static List getListBySql(Class c,String sql,List plist){ List list=new ArrayList (); ResultSet rs=null; try { //列名集合 List columns=new ArrayList (); //赋值列名集合 //生成列名 addColumnByClass(c,columns); rs=getReusultSet(sql, plist); while (rs.next()) { list.add(SetInfo(c, columns, rs)); } } catch (SQLException e) { e.printStackTrace(); }finally{ //此处的结果集对象也应该放在close关闭 try { rs.close(); } catch (SQLException e) { e.printStackTrace(); } close(); } return list; } /**通过SQL语句和参数,查询整个集合*/ public static T getObject(Class c,String sql,List plist){ T t=null; ResultSet rs=null; try { //列名集合 List columns=new ArrayList (); //赋值列名集合 //生成列名 addColumnByClass(c,columns); rs=getReusultSet(sql, plist); if (rs.next()) { t=SetInfo(c, columns, rs); } } catch (SQLException e) { e.printStackTrace(); }finally{ //此处的结果集对象也应该放在close关闭 try { rs.close(); } catch (SQLException e) { e.printStackTrace(); } close(); } return t; }