java执行SQL语句实现查询的通用方法详解

完成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语句实现查询的通用方法详解的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题，如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！

原文链接：http://blog.csdn.net/woaini1115077272/article/details/47856941