这篇文章主要介绍了java执行sql语句实现查询的通用方法详解，具有一定借鉴价值，需要的朋友可以参考下。
完成SQL查询 并将查询结果放入Vector容器，以便其他程序使用
/* * 执行SQL查询语句 */ public static Vector executeQuery(Class clazz, String sql, Object... args) { Connection conn = null; PreparedStatement preparedstatement = null; ResultSet rs = null; Vector vecRs = new Vector(); T obj = null; try { conn = JDBCTools.getConnection(); preparedstatement = conn.prepareStatement(sql); // 通过sql语句来判断选择了那些列 for (int i = 0; i mapMetaData = new HashMap(); // 打印一列的列名 while (rs.next()) { //获取数据表中满足要求的一行数据，并放入Map中 for (int i = 0; i 0) { obj = clazz.newInstance(); for (Map.Entry entry : mapMetaData.entrySet()) { String fieldkey = entry.getKey(); Object fieldvalue = entry.getValue(); // System.out.println(fieldkey + ":" + fieldvalue); ReflectionUtils.setFieldValue(obj, fieldkey, fieldvalue); //通过反射赋值 } } //将对象装入Vector容器 vecRs.add(obj); } } catch (Exception e) { e.printstacktrace(); } return vecRs; }
其中使用到的工具类方法
获取数据库连接JDBCTools.getConnection()
/* * 获取数据库的连接 */ public static Connection getConnection() throws Exception { Connection conn = null; String driver = null; String jdbcUrl = null; String username = null; String password = null; // 获取Properties对象 Properties properties = new Properties(); InputStream in = JDBCTools.class.getClassLoader().getResourceAsstream("jdbc.properties"); properties.load(in); driver = properties.getProperty("driver"); jdbcUrl = properties.getProperty("jdbcUrl"); username = properties.getProperty("user"); password = properties.getProperty("password"); Class.forName(driver); conn = DriverManager.getConnection(jdbcUrl, username, password); return conn; }
ReflectionUtils.setFieldValue(obj,fieldkey,fieldvalue);
将obj对象的fieldkey属性赋值为fieldvalue
//设置对象的属性 public static void setFieldValue(Object obj,String fieldName,Object value){ Field field=getDeclaredField(obj, fieldName); if(field==null){ throw new IllegalArgumentException("Could not find field["+ fieldName+"] on target ["+obj+"]"); } makeAccessiable(field); try{ field.set(obj, value); } catch(illegalaccessexception e){ System.out.println("不可能抛出的异常"); } } //判断field的修饰符是否是public,并据此改变field的访问权限 public static void makeAccessiable(Field field){ if(!Modifier.isPublic(field.getModifiers())){ field.setAccessible(true); } } //获取field属性，属性有可能在父类中继承 public static Field getDeclaredField(Object obj,String fieldName){ for (Class> clazz=obj.getClass(); clazz!=Object.class; clazz=clazz.getSuperclass()){ try{ return clazz.getDeclaredField(fieldName); } catch(Exception e){ } } return null; }
总结
以上就是本文关于java执行sql语句实现查询的通用方法详解的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题，如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！
