您好,登錄后才能下訂單哦!
完成SQL查詢 并將查詢結果放入Vector容器,以便其他程序使用
/* * 執行sql查詢語句 */ public static <T> Vector<T> executeQuery(Class<T> clazz, String sql, Object... args) { Connection conn = null; PreparedStatement preparedstatement = null; ResultSet rs = null; Vector<T> vecRs = new Vector<T>(); T obj = null; try { conn = JDBCTools.getConnection(); preparedstatement = conn.prepareStatement(sql); // 通過sql語句來判斷選擇了那些列 for (int i = 0; i < args.length; i++) { preparedstatement.setObject(i + 1, args[i]); } // 利用sql查詢獲取結果集 // 利用反射創建實體類的對象 // 獲取結果街的別名Stud_id 獲取JDBC的元數據 // 獲取結果集每一列的值,結合上一步得到一個Map鍵值對 // 鍵:列的別名 值:列的值 // 在利用反射對實體類對象的屬性賦值 // 屬性為Map的鍵 值為Map的值 rs = preparedstatement.executeQuery(); // 獲取元數據 ResultSetMetaData rsmd = rs.getMetaData(); Map<String, Object> mapMetaData = new HashMap<String, Object>(); // 打印一列的列名 while (rs.next()) { //獲取數據表中滿足要求的一行數據,并放入Map中 for (int i = 0; i < rsmd.getColumnCount(); i++) { String columnLabel = rsmd.getColumnLabel(i + 1); Object columnValue = rs.getObject(columnLabel); // System.out.println(columnLabel); mapMetaData.put(columnLabel, columnValue); } //將Map中的數據通過反射初始化T類型對象 if (mapMetaData.size() > 0) { obj = clazz.newInstance(); for (Map.Entry<String, Object> 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語句實現查詢的通用方法詳解的全部內容,希望對大家有所幫助。感興趣的朋友可以繼續參閱本站其他相關專題,如有不足之處,歡迎留言指出。感謝朋友們對本站的支持!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。