nacos配置服务源码解析之添加配置

1.可以发现接口路径是：/v1/cs/configs
2.可以看到standalone模式下数据库使用的是derby（java语言编写的内嵌数据库，遵循jdbc和sql标准）

3.通过源码发现，添加配置的时候并没有直接将配置数据放到数据库，而是先放到SQL_ConTEXT ，

private static final ThreadLocal> SQL_ConTEXT = ThreadLocal.withInitial(ArrayList::new);

最后再遍历SQL_ConTEXT 通过jdbcTemplate来执行sql

  default Boolean update(TransactionTemplate transactionTemplate, JdbcTemplate jdbcTemplate,
            List contexts, BiConsumer consumer) {
        return transactionTemplate.execute(status -> {
            String[] errSql = new String[] {null};
            Object[][] args = new Object[][] {null};
            try {
                contexts.forEach(pair -> {
                    errSql[0] = pair.getSql();
                    args[0] = pair.getArgs();
                    LoggerUtils.printIfDebugEnabled(LogUtil.DEFAULT_LOG, "current sql : {}", errSql[0]);
                    LoggerUtils.printIfDebugEnabled(LogUtil.DEFAULT_LOG, "current args : {}", args[0]);
                    jdbcTemplate.update(pair.getSql(), pair.getArgs());
                });
                if (consumer != null) {
                    consumer.accept(Boolean.TRUE, null);
                }
                return Boolean.TRUE;
            } catch (BadSqlGrammarException | DataIntegrityViolationException e) {
                FATAL_LOG.error("[db-error] sql : {}, args : {}, error : {}", errSql[0], args[0], e.toString());
                if (consumer != null) {
                    consumer.accept(Boolean.FALSE, e);
                }
                return Boolean.FALSE;
            } catch (CannotGetJdbcConnectionException e) {
                FATAL_LOG.error("[db-error] sql : {}, args : {}, error : {}", errSql[0], args[0], e.toString());
                throw e;
            } catch (DataAccessException e) {
                FATAL_LOG.error("[db-error] DataAccessException sql : {}, args : {}, error : {}", errSql[0], args[0],
                        ExceptionUtil.getAllExceptionMsg(e));
                throw e;
            }
        });
    }

4.添加配置的时候，执行了下面的几条sql

 final String sql =
                "INSERT INTO config_info(id, data_id, group_id, tenant_id, app_name, content, md5, src_ip, src_user, gmt_create,"
                        + "gmt_modified, c_desc, c_use, effect, type, c_schema) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";

        final String sql = "INSERT INTO his_config_info (id,data_id,group_id,tenant_id,app_name,content,md5,"
                + "src_ip,src_user,gmt_modified,op_type) VALUES(?,?,?,?,?,?,?,?,?,?,?)";

config_info是配置信息表