[关闭]
@Wishes 2018-09-14T13:02:57.000000Z 字数 2248 阅读 509
private static final Query<List<Map<String, Object>>, String, String, QueryTools> query = (sourceId, sqlStr, tools) -> {
    List<Map<String, Object>> result = tools.queryToList(sourceId, sqlStr);
    assert result != null && result.size() == 1: String.format("cmdb sql_config 执行 %s 语句有误", sqlStr);
    String sql = result.get(0).get("sql").toString();

    return tools.queryToList(sourceId, sql);
};

private static final Query<String, String, String, QueryTools> querySql = (sourceId, sqlStr, tools) -> {
    List<Map<String, Object>> result = tools.queryToList(sourceId, sqlStr);
    assert result != null && result.size() == 1: String.format("cmdb sql_config 执行 %s 语句有误", sqlStr);
    return result.get(0).get("sql").toString();
};

public static final Query<List<Map<String, Object>>, String, Integer, QueryTools> queryAllData;
public static final Query<List<Map<String, Object>>, String, String, QueryTools> queryAllDataByStr;
public static final Query<List<Map<String, Object>>, String, String, QueryTools> exec;
static {
    queryAllData = query.compose(sqlId ->String.format("select * from sql_config where id = %d", sqlId));
    queryAllDataByStr = (sourceId, sqlStr, tools) -> tools.queryToList(sourceId, sqlStr);
    exec = (sourceId, sqlStr, tools) -> tools.queryToList(sourceId, sqlStr);
}

private static final Query<List<Map<String, Object>>, String, String, QueryTools> query = (sourceId, sqlStr, tools) -> {
    List<Map<String, Object>> result = tools.queryToList(sourceId, sqlStr);
    assert result != null && result.size() == 1: String.format("cmdb sql_config 执行 %s 语句有误", sqlStr);
    String sql = result.get(0).get("sql").toString();

    return tools.queryToList(sourceId, sql);
};

private static final Query<String, String, String, QueryTools> querySql = (sourceId, sqlStr, tools) -> {
    List<Map<String, Object>> result = tools.queryToList(sourceId, sqlStr);
    assert result != null && result.size() == 1: String.format("cmdb sql_config 执行 %s 语句有误", sqlStr);
    return result.get(0).get("sql").toString();
};

public static final Query<List<Map<String, Object>>, String, Integer, QueryTools> queryAllData;
public static final Query<List<Map<String, Object>>, String, String, QueryTools> queryAllDataByStr;
public static final Query<List<Map<String, Object>>, String, String, QueryTools> exec;
static {
    queryAllData = query.compose(sqlId ->String.format("select * from sql_config where id = %d", sqlId));
    queryAllDataByStr = (sourceId, sqlStr, tools) -> tools.queryToList(sourceId, sqlStr);
    exec = (sourceId, sqlStr, tools) -> tools.queryToList(sourceId, sqlStr);
}
添加新批注
在作者公开此批注前,只有你和作者可见。
回复批注