Java 动态拼接sql 放弃xml文件 直接连接jdbc

标签：gets   执行   state   nta   getc   LIDS   空值   sql   stat   

package com.cn.sdjr.common;

import java.util.List;
import java.util.Map;

public class Config {
    //            参数名称/参数值/值补充/是否必填/字段类型/是否主键
//默认值                    /    /    /F不必填  /F字符串  /F不是主键
//默认值                    /    /    /T必填    /T数字、布尔  /T是主键
    public static String getOrder(String sort,Map<String,Object> m){
        String[] condArray = sort.split(":");
        if("".equals(condArray[0])){
            return condArray[1]+" "+ condArray[2];
        }else{
            return condArray[1]+" "+ m.get(condArray[0].trim())+" "+condArray[2];
        }
    }
    //分页有三种可能  limit      ""  "index#page" limit 1,2     "index#OFFSET#page" limit 1 offset 2
    //:index:page::F:F
    //offset:index:page::T:D
    public static String getPaging(String paging,Map<String,Object> m){
        String[] condArray = paging.split(":");
        return " LIMIT "+m.get(condArray[1])+" "+condArray[0]+" "+ m.get(condArray[2]);
    }
    //  参数名称/参数值/值补充/是否必填/字段类型/是否主键
    //  name:a.name=:‘‘:s:F:F
    // 例  ：nodeid:a.nodeid=:D:i:F:#
    // 例  ： nodeid:a.nodename like ‘%:%‘D:s:F:#
    public static String getCondition(String cond,Map<String,Object> m){
        if(cond==null || cond ==""){//空值过滤
            return "";
        }
        String[] condArray = cond.split("#");
        StringBuffer sb = new StringBuffer();
        for(int i = 0; i < condArray.length; i++) {
            String[] condA = condArray[i].split(":");
            if (condA.length == 1) {
                sb.append(condA[0]);
                continue;
            }
            Object val = m.get(condA[0]);
            if (val == null || "".equals(val)) {//为空需要判断 是否为必填
                if ("T".equals(condA[3])) {//默认不是必填
                    throw new RuntimeException("参数‘" + condA[0] + "’是必填项！");
                }
            }
            if ("T".equals(condA[4])) {//判断是否是  数字 布尔
                if (val instanceof Integer || val instanceof Boolean || val instanceof Float) {
                    sb.append(condA[1]).append(val).append(condA[2]).append(" ");
                    continue;
                }
                throw new RuntimeException("sql字段‘" + condA + "’类型定义错误！");
            }
            if (val.toString().contains(" or ")) {
                throw new RuntimeException("参数" + val + "存在违法字符 or！");
            }
            sb.append(condA[1]).append(val).append(condA[2]).append(" ");
        }
        return sb+"";
    }

    public static String getInsert(String cond,Map<String,Object> m){
        String[] condArray = cond.split("#");
        StringBuffer sbKey = new StringBuffer();
        StringBuffer sbVal = new StringBuffer();
        Boolean flag = true;// 第一个不加逗号
        for(int i = 0; i < condArray.length; i++){
            String[] condA = condArray[i].split(":");
            Object val= m.get(condA[0].trim());
            if("".equals(val) && val==null){
                if("T".equals(condA[5])){//判断主键
                    if(flag){
                        flag=false;
                    }else{
                        sbKey.append(",");
                        sbVal.append(",");
                    }
                    //sbKey.append(condA[0]).append(" ");
                    //sbVal.append("‘").append(priKey()).append("‘");
                    continue;
                }
                if("T".equals(condA[3])){//默认F不是必填
                    throw new RuntimeException("参数‘"+val+"’不能为空！");
                }
                continue;
            }

            if(flag){
                flag=false;
            }else{
                sbKey.append(",");
                sbVal.append(",");
            }
            sbKey.append(condA[0]).append(" ");
            if("T".equals(condA[4])) {
                if (val instanceof Integer || val instanceof Boolean) {
                    sbVal.append(val);
                    continue;
                }
                throw new RuntimeException("sql字段‘"+condA+"’类型定义错误！");
            }
            sbVal.append("‘").append(val).append("‘");
        }
        return "(" +sbKey+")  VALUES (" +sbVal +")";
    }
    public static String[] batchInsert(String cond,List<Map<String,Object>> map){
        String[] sqls={};
        int num =0;
        String sql="";
        List<Map<String,Object>> newmap= null ;
        for (Map<String,Object> m :map){
            num++;
            newmap.add(m);
            if(num % 10==0){
                sql=getMoreInsert(cond, newmap);
                sqls[(num/10)-1]=sql;
                sql="";
            }
        }
        sqls[num/10]=sql;
        return sqls;
    }
    public static String getMoreInsert(String cond,List<Map<String,Object>> map) {
        String[] condArray = cond.split("#");
        StringBuffer sbKey = new StringBuffer();
        StringBuffer sbVal = new StringBuffer();
        boolean flag = false;
        for (Map<String, Object> m : map) {
            boolean isFirst=true;
            if (flag) {// 非第一个 不需要再便历一遍数据字段
                sbVal.append(",(");
                for (int i = 0; i < condArray.length; i++) {
                    String[] condA = condArray[i].split(":");
                    Object val = m.get(condA[0].trim());
                    //不是第一个字段 必须添加逗号
                    if(isFirst){
                        isFirst=false;
                    }else{
                        sbVal.append(",");
                    }
                    // 判断值是否为空
                    if ("".equals(val) || val == null) {
                        if ("T".equals(condA[3])) { //是必填项  报出错误
                            throw new RuntimeException("参数‘" + val + "’不能为空！");
                        }
                        if ("T".equals(condA[5])) { // 是主键  添加主键
                            //    sbVal.append("‘").append(priKey()).append("‘");
                            continue;
                        }
                        sbVal.append(" null "); continue;
                    }
                    if ("T".equals(condA[4])) { //判断字段类型 是否符合定义1
                        if (val instanceof Integer || val instanceof Boolean || val instanceof Boolean) {
                            sbVal.append(val);
                            continue;
                        }
                        throw new RuntimeException("sql字段‘" + condA + "’类型定义错误！");
                    }
                    sbVal.append("‘").append(val).append("‘");
                }
            }
            //第一次遍历需要 insert into (id,name,birth,gae,) values (‘101‘,‘小米‘,‘2021-01-01‘,1);
            sbVal.append("(");
            sbKey.append("(");
            flag = true;
            for (int i = 0; i < condArray.length; i++) {
                String[] condA = condArray[i].split(":");
                Object val = m.get(condA[0].trim());
                //每个字段都需要便历
                if(isFirst){
                    isFirst=false;
                }else{
                    sbVal.append(",");
                    sbKey.append(",");
                }
                // 判断值是否为空
                if ("".equals(val) || val == null) {
                    if ("T".equals(condA[3])) { //是必填项  报出错误
                        throw new RuntimeException("参数‘" + val + "’不能为空！");
                    }
                    if ("T".equals(condA[5])) { // 是主键  添加主键
                        sbKey.append(condA[0]).append(" ");
                        //    sbVal.append("‘").append(priKey()).append("‘");
                        continue;
                    }
                    sbKey.append(condA[0]).append(" ");
                    sbVal.append(" null ");
                    continue;
                }
                if ("T".equals(condA[4])) { //判断字段类型 是否符合定义
                    if (val instanceof Integer || val instanceof Boolean || val instanceof Boolean) {
                        sbKey.append(condA[0]).append(" ");
                        sbVal.append(val);
                        continue;
                    }
                    throw new RuntimeException("sql字段‘" + condA + "’类型定义错误！");
                }
                sbVal.append("‘").append(val).append("‘");
            }
            sbVal.append(")");
            sbKey.append(")");
        }
        return sbKey + " VALUES " + sbVal + ";";
    }

}



//////////////////////////////////////////////////////////////////////////////////////////////////////

//组装 删除sql
public class BuildDeleteSql {
    public static String getDeletesql(Map<String,String> sqlslice, Map<String,Object> param){
        String keyword = sqlslice.get("keyword");//关键字  必须
        String mtable = sqlslice.get("mtable");//表   必须   不加工
        String statecond = sqlslice.get("statecond");//附加部分 不加工
        String dynconds = sqlslice.get("dynconds");//条件  过滤条件
        String ending = sqlslice.get("ending");//结束的部分
        StringBuffer sb = new StringBuffer();
        statecond=statecond==null?"":statecond;
        ending =ending==null?"":ending;
        dynconds = dynconds==null||dynconds==""?"":Config.getCondition(dynconds,param);
        sb.append(keyword).append(" ").append(mtable).append(" ")
                .append(statecond).append(" ").append(dynconds).append(" ").append(ending);
        return sb+"";
    }
}

/////////////////////////////////////////////////////////////////////////////////////////////////////////
//组装 查询sql

public class BuildSelectSql {
    public static String getQuerySql(Map<String,String> sqlslice, Map<String,Object> param){
        String rank = sqlslice.get("rank");//关键字  必须
        String keyword = sqlslice.get("keyword");//关键字  必须
        String mtable = sqlslice.get("mtable");//表   必须   不加工
        String mindynfactor = sqlslice.get("mindynfactor");// 增改字段  查询字段的条件
        String related = sqlslice.get("related");//附加部分 不加工
        String majdynfactor = sqlslice.get("majdynfactor");//条件  过滤条件
        String ending = sqlslice.get("ending");//结束的部分
        StringBuffer sb = new StringBuffer();
        related=related==null?"":related;
        ending =ending==null?"":ending;
        String sort = param.get("sort")==null?"":param.get("sort")+"";//排序
        String paging =param.get("paging")==null?"":param.get("paging")+""; //分页
        // String sort = sqlslice.get("sort");//排序
        //String paging =sqlslice.get("paging"); //分页
       // sort =sort==null||sort==""?"":Config.getOrder(sort,param);//排序
        //paging = Config.getPaging(paging,param); //分页
        majdynfactor = majdynfactor==null||majdynfactor==""?"":Config.getCondition(majdynfactor,param);
        mindynfactor = mindynfactor==null||mindynfactor==""?"":Config.getCondition(mindynfactor,param);
        sb.append(keyword).append(" ").append(mtable)
                .append(" ").append(mindynfactor).append(" ").append(related).append(" ")
                .append(majdynfactor).append(" ").append(sort).append(" ").append(paging)
                .append(" ").append(ending);
        return sb.toString();
    }
}

///////////////////////////////////////////////////////////////////////////////////////////////

//组装更新sql

public class BuildUpdateSql {
    public static String getUpdatesql(Map<String,String> sqlslice, Map<String,Object> param) {
        String keyword = sqlslice.get("keyword");//关键字  必须
        String mtable = sqlslice.get("mtable");//表   必须   不加工
        String joinon = sqlslice.get("joinon");// 增改字段  查询字段的条件
        String statecond = sqlslice.get("statecond");//附加部分 不加工
        String dynconds = sqlslice.get("dynconds");//条件  过滤条件
        String ending = sqlslice.get("ending");//结束的部分
        StringBuffer sb = new StringBuffer();
        statecond=statecond==null?"":statecond;
        ending =ending==null?"":ending;
            dynconds = dynconds==null||dynconds==""?"":Config.getCondition(dynconds,param);
            joinon = joinon==""?"":Config.getCondition(joinon,param);
            sb.append(keyword).append(" ").append(mtable).append(" ")
                    .append(joinon).append(" ").append(statecond).append(" ")
                    .append(dynconds).append(" ").append(ending);
        return sb+"";
    }
}

///////////////////////////////////////////////////////////////////////////////////////////////
//组装插入sql

public class BulidInsertSql {
    public static String getAddSql(Map<String,String> sqlslice, Map<String,Object> param) {
        String keyword = sqlslice.get("keyword");//关键字  必须
        String mtable = sqlslice.get("mtable");//表   必须   不加工
        String dynconds = sqlslice.get("dynconds");//条件  过滤条件
        StringBuffer sb = new StringBuffer();
        dynconds = dynconds==null||dynconds==""?"":Config.getInsert(dynconds,param);
        sb.append(keyword).append(" ").append(mtable).append(" ")
                .append(dynconds).append(" ");
        return sb+"";
    }
}




//多逻辑在同一个方法执行

 public Map Logic(String[] sqlids, Map param) {
        Map m = new HashMap();
        m.putAll(param);
        m.putAll(redisUtil.hmget(param.get("token")+""));
        for (String sqlid : sqlids) {//循环sqlid
            Map<String, String> sql = redisService.getSqlSplit(sqlid);//redis 读取; //获取sql片段  和指定有关的参数 名称
            String handler = sql.get("handler")+"";// 获取指定的参数名称
            Map<String,Object> sqlParam = (Map<String, Object>) param.get(handler);//   获取当前sql片段的参数
            m.putAll(sqlParam);
            /* 将数据 填充到 sqlParam*/
            for (String key:sqlParam.keySet()) {
                Object valuse=sqlParam.get(key);
                if(valuse!=null && !"".equals(valuse.toString())){
                    Object newobj =m.get(key);
                    sqlParam.put(key,newobj);
                }
            }
            if("update".equalsIgnoreCase(sql.get("keyword"))){
                String exeSql= BuildUpdateSql.getUpdatesql(sql,sqlParam);
                int n =jdbcTemplate.update(exeSql);
                continue;
            }
            if("insert".equalsIgnoreCase(sql.get("keyword"))){
                String exeSql= BulidInsertSql.getAddSql(sql, sqlParam);
                jdbcTemplate.execute(exeSql);
                continue;
            }
            if("delete".equalsIgnoreCase(sql.get("keyword"))){
                String exeSql= BuildDeleteSql.getDeletesql(sql,sqlParam);
                jdbcTemplate.execute(exeSql);
                continue;
            }
            if("select".equalsIgnoreCase(sql.get("keyword"))){
                String exeSql= BuildSelectSql.getQuerySql(sql,sqlParam);
                Map resMap =jdbcTemplate.queryForMap(exeSql);
                continue;
            }
            //     String exeSql = SqlBuild.getMiddleSql(sql, sqlParam);
//            Map ret =  ret = jdbc.execsql
//            if (ret == null) {
//                m.putAll(sqlParam);
//            } else {
//                m.putAll(ret);//添加数据到参数表
//            }
        }
        return m;
    }

Java 动态拼接sql 放弃xml文件 直接连接jdbc

标签：gets   执行   state   nta   getc   LIDS   空值   sql   stat   

原文地址：https://www.cnblogs.com/Java93/p/14412223.html