JDBC的封装类

在JAVA中JDBC的访问是比较麻烦的，为此可以使用封装的方法构建一个封装性较好的JDBC工具类，提高编程的可复用性。

具体的想法是：可以生成一个类封装JDBC的connection和statement的构建，使用Property配置文件来保存JDBC访问的路径以及驱动，这样可以有较好的可维护性，再使用反射特性构建一个DataUtil类封装JDBC获取的结果集，并把其显示出来。

1.首先新建一个jdbc.property文件存放jdbc的相关属性

jdbc.driver=com.mysql.jdbc.Driver  
jdbc.url=jdbc:mysql://localhost:3306/user  
jdbc.user=root  
jdbc.pass=123456  

package jdbc;  import java.io.IOException;  
import java.io.InputStream;  
import java.util.Properties;  /** * 属性工具类 */  
public class PropertiesUtil {  //属性列表  private static Properties properties = new Properties();  //配置文件的路径  private static String CONFIG = "/cfg/jdbc.properties";  //读取资源文件, 设置输入流  private static InputStream is = PropertiesUtil.class.getResourceAsStream(CONFIG);  //数据库驱动  public static String JDBC_DRIVER;  //jdbc连接url  public static String JDBC_URL;  //数据库用户名  public static String JDBC_USER;  //数据库密码  public static String JDBC_PASS;  static {  try {  //加载输入流  properties.load(is);  //获得配置的各个属性  JDBC_DRIVER = properties.getProperty("jdbc.driver");  JDBC_URL = properties.getProperty("jdbc.url");  JDBC_USER = properties.getProperty("jdbc.user");  JDBC_PASS = properties.getProperty("jdbc.pass");  } catch (IOException e) {  e.printStackTrace();  }  }  
}  

package jdbc;  import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.ResultSet;  
import java.sql.Statement;  public class JDBCExecutor{  //获得驱动  private static String DRIVER = PropertiesUtil.JDBC_DRIVER;  //获得url  private static String URL = PropertiesUtil.JDBC_URL;  //获得连接数据库的用户名  private static String USER = PropertiesUtil.JDBC_USER;  //获得连接数据库的密码  private static String PASS = PropertiesUtil.JDBC_PASS;  //连接对象  private Connection connection;  //维护一个本类型的对象  private static JDBCExecutor jdbcExecutor;  //Statement对象,可以执行SQL语句并返回结果  private Statement stmt;  //私有构造器  private JDBCExecutor() {  try {  //初始化JDBC驱动并让驱动加载到jvm中  Class.forName(DRIVER);  //创建数据库连接  connection = DriverManager.getConnection(URL, USER, PASS);  //创建Statement对象  stmt = connection.createStatement();  } catch (Exception e) {  throw new JDBCException(e.getMessage());  }  }  //提供一个静态方法返回本类的实例  public static JDBCExecutor getJDBCExecutor() {  //如果本类所维护jdbcExecutor属性为空,则调用私有的构造器获得实例  if (jdbcExecutor == null) {  jdbcExecutor = new JDBCExecutor();  }  return jdbcExecutor;  }  /* * 执行一句查询的sql */  public ResultSet executeQuery(String sql) {  try {  //利用Statement对象执行参数的sql  ResultSet result = stmt.executeQuery(sql);  return result;  } catch (Exception e) {  throw new QueryException(e.getMessage());  }  }  //执行单句INSERT、UPDATE 或 DELETE 语句, 如果执行INSERT时, 返回主键  public int executeUpdate(String sql) {  int result = -1;  try {  //执行SQL语句  stmt.executeUpdate(sql);  //获得主键  ResultSet rs = stmt.getGeneratedKeys();  while(rs.next()) {  //返回最后一个主键  result = rs.getInt(1);  }  rs.close();  return result;  } catch (Exception e) {  throw new QueryException(e.getMessage());  }  }  
}  

package jdbc;  import java.lang.reflect.Field;  
import java.lang.reflect.Method;  
import java.sql.ResultSet;  
import java.util.ArrayList;  
import java.util.Collection;  import vo.User;  
import dao.impl.UserDAOImpl;  /** * 数据转换工具类 */  
public class DataUtil {  static UserDAOImpl us=new UserDAOImpl();  //将rs中的值封装成一个集合  public static Collection getDatas(Collection result, ResultSet rs, Class clazz) {  try {  while (rs.next()) {  //创建类的实例  Object vo = clazz.newInstance();  //获取本对象的属性  Field[] fields = clazz.getDeclaredFields();  //获取父类的属性  
//    Field[] superFields = clazz.getSuperclass().getDeclaredFields();  
//    //父类的属性和自己的属性相加  
//    Field[] allFields = addFields(superFields, fields);  //遍历所有的属性  for (Field field : fields) {  //获得setter方法的方法名  String setterMethodName = getSetterMethodName(field.getName());  //获得setter方法  Method setterMethod = clazz.getMethod(setterMethodName, field.getType());  invokeMethod(rs, field, vo, setterMethod);  }  result.add(vo);  }  rs.close();  } catch (Exception e) {  e.printStackTrace();  throw new DataException(e.getMessage());  }  return result;  }  //执行一个方法, 从ResultSet中获取一个字段的数据, 调用vo的setter方法  private static void invokeMethod(ResultSet rs, Field field, Object vo,   Method setterMethod) {  try {  //当使用ResultSet获取某个字段的时候, 如果没有该字段, 会出现SQLException, 在这里忽略该异常  String value = rs.getString(field.getName());  //从ResultSet中获取与该对象属性名一致的字段, 并执行setter方法  setterMethod.invoke(vo, value);  } catch (Exception e) {  //忽略异常  }  }  //根据属性名获得setter方法的方法名  private static String getSetterMethodName(String fieldName) {  String begin = fieldName.substring(0, 1).toUpperCase();  String end = fieldName.substring(1, fieldName.length());  String methodName = "set" + begin + end;  return methodName;  }  //测试方法  public static void main(String[] args) {  JDBCExecutor executor = JDBCExecutor.getJDBCExecutor();  us.AddUser(new User("111",12,"333"));  
//  ResultSet rs = executor.executeQuery("select * from user");  
//  Collection result = DataUtil.getDatas(new ArrayList(), rs,   
//    User.class);  
//  for (User user : result) {  
//   System.out.println(user.getName());  
//  }  }  
}  

                   转载自：http://blog.csdn.net/rommel1/article/details/7294501    -----------感谢作者的无私奉献

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！