网上发现的一个不错的使用jdbc进行增删改查的封装类,(没有测试,

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了网上发现的一个不错的使用jdbc进行增删改查的封装类,(没有测试,，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3818字，纯文字阅读大概需要6分钟。

内容图文

package com.sj.utils;import java.lang.reflect.Field;import java.lang.reflect.InvocationTargetException;import java.lang.reflect.Method;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.S

package com.sj.utils;
import java.lang.reflect.Field;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;

public class BaseDao {
	/**
	*查询方法
	*/
	public static List findAll(Object obj,Connection conn) throws Exception{
		Class clazz=obj.getClass();
		//获取传入的实体中的所有的方法
		Method[] m=clazz.getMethods();
		//获取传入实体中的所有的属性
		Field[] f=clazz.getDeclaredFields();
		//建立结果集List接收对象
		List list=new ArrayList();
		//创建sql语句
		String sql="select * from  "+obj.getClass().getSimpleName().toLowerCase();
		System.out.println(sql);
		//System.out.println(sql);
		//预编译sql语句
		PreparedStatement pst=conn.prepareStatement(sql);
		//执行预编译的语句,获取结果集
		ResultSet rs=pst.executeQuery();
		//从结果集中循环取出放入结果集List
		while(rs.next()){
			Object obj2=clazz.newInstance();
			
			for(int i=0;i<f.length;i++){
				//取出属性名
				String n=f[i].getName();
				//获取结果集的单个的对象
				Object ob=rs.getObject(i+1);
				if(ob==null){
					ob="a";//防止数据为null时引发空指针异常
				}
				//判断单个结果的对象类型
				if(ob.getClass().equals(java.lang.String.class)){
					
					/*
					 * 拼接Set方法。
					 */
					for(int j=0;j<m.length;j++){
						if(("set"+n).equalsIgnoreCase(m[j].getName())){
							//执行指定的对象中的方法,并肩参数传入
							m[j].invoke(obj2, rs.getString(n));
						}
					}
					
				}else{
					for(int j=0;j<m.length;j++){
						if(("set"+n).equalsIgnoreCase(m[j].getName())){
							m[j].invoke(obj2, rs.getInt(n));
						}
					}
				}
				
			}
			list.add(obj2);
			
		}
		
		return list;
	}
	
	/**
	*保存方法
	*/
	public static void save(Object obj,Connection conn) throws IllegalAccessException, IllegalArgumentException, InvocationTargetException, SQLException{
		Class clazz=obj.getClass();
		Method[] m=clazz.getDeclaredMethods();
		Field[] f=clazz.getDeclaredFields();

		String table=clazz.getSimpleName().toLowerCase();

		String sql="";
		for(int i=0;i<f.length;i++){
			sql=sql+f[i].getName()+",";
		}
		sql=sql.substring(0, sql.length()-1);
		String sql2="";
	
		for(int j=0;j<f.length;j++){
			
			String str="get"+f[j].getName();
			
			for(int k=0;k<m.length;k++){
				
				if(str.equalsIgnoreCase(m[k].getName())){
					//判断。这个地方有bug
					/*
					 * new 出来到对象没有这个方法需要的属性
					 */
			
					Object p=m[k].invoke(obj);
			
					if(p==null){
						p="null";
						sql2=sql2+p+",";
					}else{
					sql2=sql2+"'"+p+"'"+",";
					}
				}
			}	
			
		}
		sql2=sql2.substring(0,sql2.length()-1);
		sql="insert into "+table+"("+sql+")"+" values"+"("+sql2+")";
		System.out.println(sql);
		PreparedStatement pst=conn.prepareStatement(sql);
		pst.executeUpdate();
	}	
	
	/**
	*更新数据
	*/
	public static void update(Object obj,Connection conn) throws Exception{
        //修改
        Class clazz=obj.getClass();
        Method[] m=clazz.getMethods();
        Field[] f=clazz.getDeclaredFields();
        /*
         * 拼接Sql
         */
        String str1="";
        String str3="";
        for(int i=0;i<f.length;i++){
            //str1=str1+","+f[i].getName()+"="+"?";
            for(int j=0;j<m.length;j++){
                String str2="get"+f[i].getName();
                if(str2.equalsIgnoreCase(m[j].getName())){
                    str1=str1+f[i].getName()+"="+"'"+m[j].invoke(obj)+"'"+",";
                    if("getId".equalsIgnoreCase(m[j].getName())){
                     str3=m[j].invoke(obj).toString();
                    }
                }
            }
        }
        str1=str1.substring(0,str1.length()-1);
        String sql="update "+clazz.getSimpleName().toLowerCase()+" set "+str1+" where id="+"'"+str3+"'";
        System.out.println(sql);
      
        PreparedStatement pst=conn.prepareStatement(sql);
        pst.execute();
       
    }
	
	/**
	*根据id删除数据
	*/
	public static void delById(Object obj,String id,Connection conn) throws SQLException{
		 Class clazz=obj.getClass();
		 String table=clazz.getSimpleName();
		 String sql="delete from "+table+" where id="+"'"+id+"'";
		 System.out.println(sql);
		 conn.prepareStatement(sql).executeUpdate();
	}
	
}

内容总结

以上是互联网集市为您收集整理的网上发现的一个不错的使用jdbc进行增删改查的封装类,(没有测试,全部内容，希望文章能够帮你解决网上发现的一个不错的使用jdbc进行增删改查的封装类,(没有测试,所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端