一个通用查询（原创）

java 代码

package com.abc.www;

import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.*;
import java.util.ArrayList;

public class NewTestReflect {

public static void main(String[] args) throws Exception {
   NewTestReflect newtestreflect=new NewTestReflect();
   newtestreflect.select("select * from test", "com.tangshun.www.Person");
}

private static String getSetMethodName(String columnName) {
   return "set" + columnName.substring(0, 1).toUpperCase()
     + columnName.toLowerCase().substring(1);
}

/**
   * 需要提供sql语句，以及操作数据库表对应的类名字（包括包名）
   * 如：select * from test;则类名字应该是   包.Test
   * Test.java是一个简单的pojo，对数据库里面的字段只有相应的set get方法
   * 如果有必要，可以增加其他相关的构造方法等
   * @param sql
   * @param className
   * @return ArrayList
   */
public ArrayList select(String sql, String className) {
   Connection connection = null;
   PreparedStatement stmt = null;
   ResultSet rs = null;
   ArrayList paraList = new ArrayList();
   try {
    Class.forName("com.mysql.jdbc.Driver");
    connection = DriverManager.getConnection(
      "jdbc:mysql://localhost/test", "root", "123456");
    stmt = connection.prepareStatement(sql);
    rs = stmt.executeQuery();
    Object c1 = null;
    ResultSetMetaData rsmd = rs.getMetaData();//获得元数据
    int columnCount = rsmd.getColumnCount();//获得查询的列数个数
    while (rs.next()) {
     c1 = Class.forName(className).newInstance();//根据String型的类名，得到一个Object
     for (int i = 1; i <= columnCount; i++) {//循环设置该类的set方法的相关属性
      Method m = c1.getClass().getMethod(
        getSetMethodName(rsmd.getColumnName(i)),
        Class.forName(rsmd.getColumnClassName(i)));//获得方法
      m.invoke(c1, rs.getObject(rsmd.getColumnName(i)));//设置set，此处用ResultSet.getObject(String s)方法
     }
     paraList.add(c1);//增加到List中
    }
    Person p = (Person) paraList.get(0);
    System.out.println(p.getName());

   } catch (SQLException ex) {
    ex.printStackTrace();
   } catch (ClassNotFoundException e) {
    e.printStackTrace();
   } catch (NoSuchMethodException e) {
    e.printStackTrace();
   } catch (InvocationTargetException e) {
    e.printStackTrace();
   } catch (IllegalAccessException e) {
    e.printStackTrace();
   } catch (InstantiationException e) {
    e.printStackTrace();
   } finally {
    try {
     rs.close();
     rs = null;
    } catch (Exception ex) {
    }
    try {
     stmt.close();
     stmt = null;
    } catch (Exception ex) {
    }
   }
   try {
    connection.close();
    connection = null;
   } catch (Exception ex) {
   }

   return paraList;
}


}

分享到：

JIMI的学习

• 2007-05-22 12:59
• 浏览 4311
• 评论(7)
• 论坛回复 / 浏览 (7 / 6606)
• 分类:企业架构
• 查看更多

评论

7 楼 loveyt 2008-05-20  

多表怎么办?

6 楼 redbaron 2007-06-11  

将取得的arraylist  用最快捷的方式的传导页面上显示出来怎么做

5 楼 aone 2007-05-23  

breezedancer 写道

需要相应的javabean

Class.getMethod(String, Class[])说,它不要Class,它要Class[].
需要什么相应的javabean?

4 楼 breezedancer 2007-05-23  

需要相应的javabean

3 楼 aone 2007-05-23  

引用

Method m = c1.getClass().getMethod(getSetMethodName(rsmd.getColumnName(i)),Class.forName(rsmd.getColumnClassName(i)));//获得方法

getMethod()方法报错了.
The method getMethod(String, Class[]) in the type Class is not applicable for the arguments (String, Class)

2 楼 breezedancer 2007-05-22  

为了学习下反射而写

1 楼 lighter 2007-05-22  

呵呵,通用是通用,大多java的教科书大多有这么写的
为什么不用一下spring封装的JDBC,那一个用起来方便多