aaa.zip_oracle

package com.iflytek.sms.dao.impl.db4; import java.lang.reflect.Method; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.util.ArrayList; import java.util.Date; import java.util.List; public class OrmUtil { private static String driverClassName = "oracle.jdbc.OracleDriver"; // 驱动字符串 private static String url = "jdbc:oracle:thin:@172.22.247.11:1521:orcl";// 数据库连接字符串 private static String user = "ztc_lizq"; // 用户名 private static String password = "1111";// 密码 static { // 1、加载数据库驱动 try { Class.forName(driverClassName); } catch (ClassNotFoundException e) { e.printStackTrace(); } } private static Connection getConnection() throws SQLException { return DriverManager.getConnection(url, user, password); } private static void close(ResultSet rs, PreparedStatement ps, Connection conn) { // 7、关闭对象，释放资源 if (rs != null) { try { rs.close(); } catch (SQLException e) { e.printStackTrace(); } } if (ps != null) { try { ps.close(); } catch (SQLException e) { e.printStackTrace(); } } if (conn != null) { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } private static int executeUpdate(String sql, Object... params) { int row = 0; Connection conn = null; PreparedStatement ps = null; try { // 2、获取数据库连接 conn = getConnection(); // 3、获取对象（负责执行SQL语句） ps = conn.prepareStatement(sql); // 4、如果SQL中有占位符，进行参数赋值 for (int i = 0; i < params.length; i++) { ps.setObject(i + 1, params[i]); } // 5、执行SQL命令 row = ps.executeUpdate(); } catch (Exception e) { e.printStackTrace(); } finally { // 6、关闭对象，释放资源 close(null, ps, conn); } return row; } @SuppressWarnings("unchecked") private static <T> List<T> executeQuery(Class<?> cla, String sql, Object... params) { List<T> list = new ArrayList<T>(); Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; try { // 2、获取数据库连接 conn = OrmUtil.getConnection(); // 3、获取对象（负责执行SQL语句） ps = conn.prepareStatement(sql); // 4、如果SQL中有占位符，进行参数赋值 for (int i = 0; i < params.length; i++) { ps.setObject(i + 1, params[i]); } // 5、执行SQL命令 rs = ps.executeQuery(); // 获取结果的元数据(结果的结构) ResultSetMetaData rsmt = rs.getMetaData(); int colCount = rsmt.getColumnCount();// 获取列数 // for (int i = 1; i <= colCount; i++) { // String colName = rsmt.getColumnLabel(i);// 列名 // String colType = rsmt.getColumnTypeName(i);// 列的数据类型 // } // 6、循环处理结果集 T obj = null; // Student obj = null; Method[] methods = cla.getDeclaredMethods(); while (rs.next()) { obj = (T) cla.newInstance(); for (Method m : methods) { if (m.getName().startsWith("set")) { String name = m.getName().substring(3);// 属性名 for (int i = 1; i <= colCount; i++) { String colName = rsmt.getColumnLabel(i);// 列名 // 结果集存在该列 if (colName.equalsIgnoreCase(name)) { Object data = null; if (m.getParameterTypes().length > 0 && m.getParameterTypes()[0] == int.class) { data = rs.getInt(colName);// 该列的值 } else { data = rs.getObject(colName); } if (data != null) { m.invoke(obj, data);// 通过set方法将取出的列值赋值给刚才创建的对象obj } break; } } } } list.add(obj); } } catch (Exception e) { e.printStackTrace(); } finally { // 7、关闭对象，释放资源 OrmUtil.close(rs, ps, conn); } return list; } public static boolean add(Object obj) { Class<?> cla = obj.getClass(); StringBuffer sql = new StringBuffer(); sql.append("insert into "); sql.append(cla.getName().substring(cla.getName().lastIndexOf(".") + 1)); sql.append("("); StringBuffer values = new StringBuffer(); List<Object> params = new ArrayList<Object>(); Method[] methods = cla.getDeclaredMethods(); for (Method m : methods) { String name = m.getName(); if (name.startsWith("get")) { // 获取属性名（列名） String colName = name.substring(3); // 拼接列名 sql.append(colName + ","); // 拼占位符，id直接为seq.nextval if (colName.equalsIgnoreCase("id")) { values.append("seq.nextval,"); } else { values.append("?,"); } // 拼参数值，id除外 if (!colName.equalsIgnoreCase("id")) { Object val = null; try { val = m.invoke(obj); } catch (Exception e) { e.printStackTrace(); } if (val != null && m.getReturnType() == Date.class) { Date d = (Date) val; params.add(new java.sql.Date(d.getTime())); } else { params.add(val); } } } } sql.deleteCharAt(sql.length() - 1);// 删除多余的, values.deleteCharAt(values.length() - 1);// 删除多余的, sql.append(")"); sql.append(" values (" + values + ")"); int row = executeUpdate(sql.toString(), params.toArray()); return row > 0 ? true : false; } public static boolean edit(Object obj) { Class<?> cla = obj.getClass(); StringBuffer sql = new StringBuffer(); sql.append("update "); sql.append(cla.getName().substring(cla.getName().lastIndexOf(".") + 1)); sql.append(" set "); List<Object> params = new ArrayList<Object>(); Method[] methods = cla.getDeclaredMethods(); for (Method m : methods) { String name = m.getName(); if (name.startsWith("get")) { // 获取属性名（列名） String colName = name.substring(3); // 拼占位符，id直接为seq.nextval if (!colName.equalsIgnoreCase("id")) { sql.append(colName + "=?,"); Object val = null; try { val = m.invoke(obj); } catch (Exception e) { e.printStackTrace(); } if (val != null && m.getReturnType() == Date.class) { Date d = (Date) val; params.add(new java.sql.Date(d.getTime())); } else { params.add(val); } } } } sql.deleteCharAt(sql.length() - 1);// 删除多余的, sql.append(" where id=?"); Method m; try { m = cla.getDeclaredMethod("getId"); params.add(m.invoke(obj)); } catch (Exception e) { e.printStackTrace(); } int row = executeUpdate(sql.toString(), params.toArray()); return row > 0 ? true : false; } public static boolean delete(Class<?> cla, int id) { StringBuffer sql = new StringBuffer(); sql.append("delete from "); sql.append(cla.getName().substring(cla.getName().lastIndexOf(".") + 1)); sql.append(" where id=?"); int row = executeUpdate(sql.toString(), id); return row > 0 ? true : false; } // 根据主键获取对象 public static <T> T getObject(Class<?> cla, int id) { String sql = "select * from " + cla.getName().substring(cla.getName().lastIndexOf(".") + 1) + " where id=?"; List<T> list = OrmUtil.<T> executeQuery(cla, sql, id); if (list != null && list.size() > 0) { return list.get(0); } return null; } public static <T> List<T> query(Class<?> cla, String order, String where, Object... params) { StringBuffer sql = new StringBuffer(); sql.append("select * from "); sql.append(cla.getName().substring(cla.getName().lastIndexOf(".") + 1)); if (order != null && !order.trim().equals("")) { sql.append(" order by " + order); } else { sql.append(" order by id"); } if (where != null && !where.trim().equals("")) { sql.append(" where " + where); } List<T> list = OrmUtil.<T> executeQuery(cla, sql.toString(), params); return list; } }