万能的JDBC工具类。通过反射机制直接简单处理数据库操作

通过学习其它大神的经验，从而自己研究这套代码，感谢那些分享知识的大神，因此我也将自己整理的内容贡献出来，以供大家共同进步。谢谢。

这两个类，可以做好后直接生成一个jar文件，从而下次项目直接导入jar文件就可以调用了。

MyJDBC.properties 这个文件放在项目文件的src文件下，里面的配置内容如下：

conURL=jdbc:sqlserver://192.168.1.1:1433;databaseName=数据库名称
cname=com.microsoft.sqlserver.jdbc.SQLServerDriver
dbA=登录名
dbpassword=密码

其他的数据库也是一样的配置，只需要更改上面的配置信息就行了。

package com.YY.util;import java.io.IOException;import java.io.InputStream;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import java.util.Properties;public class BaseConnection {private static String conURL = "";private static String cname = "";private static String dbA = "";private static String dbpassword = "";static{try {//获取外部配置的数据库链接信息InputStream ips =BaseConnection.class.getClassLoader().getResourceAsStream("MyJDBC.properties");Properties props = new Properties();try {props.load(ips);} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}try {ips.close();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}conURL = props.getProperty("conURL");cname =	props.getProperty("cname");dbA = props.getProperty("dbA");dbpassword = props.getProperty("dbpassword");} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}//public static Connection getConnection() {Connection conn = null;try {Class.forName(cname);conn = DriverManager.getConnection(conURL, dbA, dbpassword);} catch (Exception e) {e.printStackTrace();}return conn;}public static void closeRes(Connection conn, PreparedStatement ps){try {if ( conn != null ) {conn.close();}if ( ps != null ) {ps.close();}} catch ( Exception e ) {e.printStackTrace();}}public static void closeRes(Connection conn, PreparedStatement ps,ResultSet rs){try {if ( conn != null ) {conn.close();}if ( ps != null ) {ps.close();}if ( rs != null ) {rs.close();}} catch ( Exception e ) {e.printStackTrace();}}}package com.YY.util;import java.lang.reflect.Field;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.util.ArrayList;public class BaseDAO {//万能的获取全部内容public static ArrayList getList(Class c1){ArrayList ar = new ArrayList();Connection conn = BaseConnection.getConnection();PreparedStatement ps = null;ResultSet rs = null;String sql = "Select * from "+ c1.getSimpleName();Field[] fi = c1.getDeclaredFields();try{ps = conn.prepareStatement(sql);rs = ps.executeQuery();while(rs.next()){Object ob = c1.newInstance();//实例化类对象for(Field ff :fi){ff.setAccessible(true);ff.set(ob, rs.getObject(ff.getName()));}ar.add(ob);}}catch(Exception e){e.printStackTrace();}finally{BaseConnection.closeRes(conn, ps, rs);}return ar;}//万能的获取ID主键的一条数据。public static Object getObById(Class c1,int id){Object ob = null;Connection conn = BaseConnection.getConnection();PreparedStatement ps = null;ResultSet rs = null;Field[] fi = c1.getDeclaredFields();String sql = "Select * from "+ c1.getSimpleName()+" where "+ fi[0].getName()+" = "+id;try{ps = conn.prepareStatement(sql);rs = ps.executeQuery();while(rs.next()){ob = c1.newInstance();//实例化类对象for(Field ff :fi){ff.setAccessible(true);ff.set(ob, rs.getObject(ff.getName()));}}}catch(Exception e){e.printStackTrace();}finally{BaseConnection.closeRes(conn, ps, rs);}return ob;}//万能的获取Where 条件后 的数据。public static ArrayList getList(Class c1,String whereSql){ArrayList ar = new ArrayList();Connection conn = BaseConnection.getConnection();PreparedStatement ps = null;ResultSet rs = null;String sql = "Select * from "+ c1.getSimpleName() +" "+ whereSql;Field[] fi = c1.getDeclaredFields();try{ps = conn.prepareStatement(sql);rs = ps.executeQuery();while(rs.next()){Object ob = c1.newInstance();//实例化类对象for(Field ff :fi){ff.setAccessible(true);ff.set(ob, rs.getObject(ff.getName()));}ar.add(ob);}}catch(Exception e){e.printStackTrace();}finally{BaseConnection.closeRes(conn, ps, rs);}return ar;}//插入的万能方法。public static boolean Insert(Object ob){boolean f = false;Connection conn = BaseConnection.getConnection();PreparedStatement ps = null;Class c1 = ob.getClass();Field[] fi = c1.getDeclaredFields();StringBuffer Sql = new StringBuffer();StringBuffer Sql1 = new StringBuffer();Sql.append("insert into ").append(c1.getSimpleName()).append(" (");for(int i =1 ;i<fi.length;i++){fi[i].setAccessible(true);Sql.append(fi[i].getName());Sql1.append("?");if(i!= fi.length -1){Sql.append(",");Sql1.append(",");}}Sql.append(") ").append("values (").append(Sql1).append(");");try{System.out.println(Sql.toString());ps = conn.prepareStatement(Sql.toString());for(int i =1;i<fi.length;i++){fi[i].setAccessible(true);ps.setObject(i, fi[i].get(ob));}int a = ps.executeUpdate();if(a>0){f = true;}}catch(Exception e){e.printStackTrace();}finally{BaseConnection.closeRes(conn, ps);}return f;}//万能更新public static boolean update(Object ob){boolean b = false;Connection conn = BaseConnection.getConnection();PreparedStatement ps = null;Class c1 = ob.getClass();Field[] fi = c1.getDeclaredFields();StringBuffer sb = new StringBuffer();sb.append("update ").append(c1.getSimpleName()).append(" set ");for(int i = 1; i<fi.length;i++){sb.append(fi[i].getName());sb.append(" = ? ");if(i!= fi.length -1){sb.append(" , ");}}sb.append(" where ");sb.append(fi[0].getName()).append(" =?");try{System.out.println(sb.toString());ps = conn.prepareStatement(sb.toString());for(int i=1;i<fi.length ; i++){fi[i].setAccessible(true);ps.setObject(i, fi[i].get(ob));}fi[0].setAccessible(true);ps.setObject(fi.length, fi[0].get(ob));int a = ps.executeUpdate();if(a>0){b=true;}}catch(Exception e){e.printStackTrace();}return b;}//万能删除public static boolean delete(Class c1 ,int id){boolean b = false;Connection conn = BaseConnection.getConnection();PreparedStatement ps = null;Field[] fi = c1.getDeclaredFields();String Sql = "Delete from "+c1.getSimpleName()+" Where "+fi[0].getName()+" = ?";try{ps = conn.prepareStatement(Sql);ps.setObject(1, id);int a = ps.executeUpdate();if(a>0){b=true;}}catch(Exception e){e.printStackTrace();}finally{BaseConnection.closeRes(conn, ps);}return b;}//万能删除public static boolean delete(Class c1 ,String WhereSql){boolean b = false;Connection conn = BaseConnection.getConnection();PreparedStatement ps = null;Field[] fi = c1.getDeclaredFields();String Sql = "Delete from "+c1.getSimpleName()+" "+WhereSql;try{ps = conn.prepareStatement(Sql);int a = ps.executeUpdate();if(a>0){b=true;}}catch(Exception e){e.printStackTrace();}finally{BaseConnection.closeRes(conn, ps);}return b;}}