[ISSUE #8312] Create ConfigInfoBetaMapper.(#8312) (#9118)

2022-09-10 14:41:46 +08:00 · 2022-09-10 14:41:46 +08:00 · f44b28461a
commit f44b28461a
parent 3ebd3b74ff
1 changed files with 93 additions and 0 deletions
--- a/plugin/datasource/src/main/java/com/alibaba/nacos/plugin/datasource/mapper/ConfigInfoBetaMapper.java
+++ b/plugin/datasource/src/main/java/com/alibaba/nacos/plugin/datasource/mapper/ConfigInfoBetaMapper.java
@ -0,0 +1,93 @@
+/*
+ * Copyright 1999-2022 Alibaba Group Holding Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.alibaba.nacos.plugin.datasource.mapper;
+
+/**
+ * The beta config info mapper.
+ *
+ * @author hyx
+ **/
+
+public interface ConfigInfoBetaMapper {
+    
+    /**
+     * Add beta configuration information.
+     * The default sql:
+     * INSERT INTO config_info_beta(data_id,group_id,tenant_id,app_name,content,md5,beta_ips,src_ip,
+     * src_user,gmt_create,gmt_modified,encrypted_data_key) VALUES(?,?,?,?,?,?,?,?,?,?,?,?)
+     *
+     * @return The sql of adding beta configuration information.
+     */
+    String addConfigInfo4Beta();
+    
+    /**
+     * Update beta configuration information.
+     * The default sql:
+     * UPDATE config_info_beta SET content=?, md5=?, beta_ips=?, src_ip=?,src_user=?,gmt_modified=?,app_name=?,encrypted_data_key=?
+     * WHERE data_id=? AND group_id=? AND tenant_id=?
+     *
+     * @return The sql of updating beta configuration information.
+     */
+    String updateConfigInfo4Beta();
+    
+    /**
+     * Update beta configuration information.
+     * UPDATE config_info_beta SET content=?, md5=?, beta_ips=?, src_ip=?,src_user=?,gmt_modified=?,app_name=?
+     * WHERE data_id=? AND group_id=? AND tenant_id=? AND (md5=? or md5 is null or md5='')
+     *
+     * @return The sql of updating beta configuration information.
+     */
+    String updateConfigInfo4BetaCas();
+    
+    /**
+     * Delete configuration information, physical deletion.
+     * The default sql:
+     * DELETE FROM config_info_beta WHERE data_id=? AND group_id=? AND tenant_id=
+     *
+     * @return The sql of deleting configuration information, physical deletion.
+     */
+    String removeConfigInfo4Beta();
+    
+    /**
+     * Query beta configuration information based on dataId and group.
+     * The default sql:
+     * SELECT id,data_id,group_id,tenant_id,app_name,content,beta_ips,encrypted_data_key
+     * FROM config_info_beta WHERE data_id=? AND group_id=? AND tenant_id=?
+     *
+     * @return The sql of querying beta configuration information based on dataId and group.
+     */
+    String findConfigInfo4Beta();
+    
+    /**
+     * Query the count of beta configuration information.
+     * The default sql:
+     * SELECT count(*) FROM config_info_beta
+     *
+     * @return The sql of querying the count of beta configuration information.
+     */
+    String count();
+    
+    /**
+     * Query all beta config info for dump task.
+     * The default sql:
+     * SELECT t.id,data_id,group_id,tenant_id,app_name,content,md5,gmt_modified,beta_ips,encrypted_data_key
+     * FROM ( SELECT id FROM config_info_beta  ORDER BY id LIMIT ?,?  ) g, config_info_beta t WHERE g.id = t.id
+     *
+     * @return The sql of querying all beta config info for dump task.
+     */
+    String findAllConfigInfoBetaForDumpAllFetchRows();
+}