|
@ -176,8 +176,8 @@ public class RedisInitService extends BaseJpaService {
|
|
|
* @return
|
|
|
*/
|
|
|
public int cacheAdapterMetadata (String id, boolean deleteAll){
|
|
|
String schemaSql = "SELECT adapter_version FROM rs_adapter_scheme WHERE id = " + id;
|
|
|
String metaSql = "SELECT src_dataset_code, src_metadata_code, metadata_id FROM rs_adapter_metadata WHERE scheme_id = " + id;
|
|
|
String schemaSql = "SELECT adapter_version FROM rs_adapter_scheme WHERE id = '" + id + "'";
|
|
|
String metaSql = "SELECT src_dataset_code, src_metadata_code, metadata_id FROM rs_adapter_metadata WHERE scheme_id = '" + id + "'";
|
|
|
Map<String, Object> schemaMap = jdbc.queryForMap(schemaSql);
|
|
|
List<Map<String, Object>> metaList = jdbc.queryForList(metaSql);
|
|
|
//清空相关Redis
|