数据库操作sql封装（insert）

**

数据库插入（insert）sql封装

**

1. 封装工具类

public class DBUtil {
    public String column;  //插入列名
    public String values;   //插入值
    public String condition;
public static DBUtil insert(String seqName,   obj){
......}
}

2. insert具体实现

public static DBUtil insert(String seqName, obj){

    //seqName 表对应ID索引
    Field[] fields = obj.getClass().getDeclaredFields();   //类列值
    
    //父类
    Field[] parentFields = obj.getClass().getSuperclass().getDeclaredFields();  
    
    String columnString =  Entity.FIELD_CREATE_DATE + \",\" ;
    String valuesString = \"SYSDATE,\";


    
    for(int i = 0, j=parentFields.length; i <j; i++){
        String fieldName = parentFields[i].getName();
          fieldValue = DBUtil.getFieldValueByName(parentFields[i].getName(), obj);


        if(!ValidatorUtil.is Empty(fieldValue)){
            if(fieldName.equals( Entity.FIELD_REMARK)){
                columnString = columnString +  Entity.FIELD_REMARK + \",\";
                valuesString = valuesString + \"\'\" + fieldValue + \"\',\";
            }

            if(fieldName.equals( Entity.FIELD_CREATE_USER_ID)){
                columnString = columnString +  Entity.FIELD_CREATE_USER_ID + \",\";
                valuesString = valuesString + fieldValue + \",\";
            }

            if(fieldName.equals( Entity.FIELD_CREATE_USER)){
                columnString = columnString +  Entity.FIELD_CREATE_USER + \",\";
                valuesString = valuesString + \"\'\" + fieldValue + \"\',\";
            }

            if(fieldName.equals( Entity.FIELD_STATUS)){
                columnString = columnString +  Entity.FIELD_STATUS + \",\";
                valuesString = valuesString + fieldValue + \",\";
            }

            if(fieldName.equals( Entity.FIELD_DWDM)){
                columnString = columnString +  Entity.FIELD_DWDM + \",\";
                valuesString = valuesString + \"\'\" + fieldValue + \"\',\";
            }

            if (fieldName.equals( Entity.FIELD_UPDATE_USER)) {
                columnString = columnString +  Entity.FIELD_UPDATE_USER + \",\";
                valuesString = valuesString + \"\'\" + fieldValue + \"\',\";
            }

            if (fieldName.equals( Entity.FIELD_UPDATE_USER_ID)) {
                columnString = columnString +  Entity.FIELD_UPDATE_USER_ID + \",\";
                valuesString = valuesString + \"\'\" + fieldValue + \"\',\";
            }
        }

    }
    
    for (int i = 0, j=fields.length; i < j; i++) {
        String fieldType = fields[i].getType().toString();
        String fieldName = fields[i].getName();
          fieldValue = DBUtil.getFieldValueByName(fields[i].getName(), obj);
        
        if (fieldType.equals(\"class java.lang.Long\") && fieldName.equals(\"ID\")) {
            if(!ValidatorUtil.is Empty(fieldValue)){
                columnString = columnString + fieldName + \",\";
                valuesString = valuesString + fieldValue + \",\";
            }else{
                columnString = columnString + fieldName + \",\";
                valuesString = valuesString + seqName + \".nextval,\";
            }
        }
        
        // 如果值不为null
        if (!ValidatorUtil.is Empty(fieldValue)) {
            if (fieldType.equals(\"class java.lang.String\")) {
                columnString = columnString + fieldName + \",\";
                valuesString = valuesString + \"\'\" + fieldValue + \"\',\";
            } else if (fieldType.equals(\"class java.util.Date\")) {
                columnString = columnString + fieldName + \",\";
                String dateString = DateUtil.defaultStringToString(fieldValue.toString(), \"yyyy-MM-dd HH:mm:ss\");
                valuesString = valuesString + \" to_date(\'\" + dateString + \"\', \'yyyy/mm/dd hh24:mi:ss\'),\";
            }else if (!fieldName.equals(\"ID\")) {
                columnString = columnString + fieldName + \",\";
                valuesString = valuesString + fieldValue + \",\";
            }
        }
    }
    
    DBUtil db = new DBUtil();
    if(!ValidatorUtil.isEmpty(columnString) && !ValidatorUtil.isEmpty(valuesString)){
        db.setColumn(columnString.substring(0, columnString.lastIndexOf(\",\")));
        db.setValues(valuesString.substring(0, valuesString.lastIndexOf(\",\")));
    }
    
    System.out.println(db.getColumn());
    System.out.println(db.getValues());
    
    return db;
}

3. insert具体实现

this.bankAccountDao.insertBankAccount(DBUtil.insert(entity.SEQ_NAME, entity));