Skip to content

Commit 98a8abe

Browse files
authored
[3.1.3-release][SQL] Fix t_ds_fav table does not exist when rolling upgrade (#13337)
* Fix t_ds_fav table does not exist when rolling upgrade
1 parent 0691d6a commit 98a8abe

File tree

2 files changed

+35
-1
lines changed

2 files changed

+35
-1
lines changed

Diff for: dolphinscheduler-dao/src/main/resources/sql/upgrade/3.1.3_schema/mysql/dolphinscheduler_ddl.sql

+25
Original file line numberDiff line numberDiff line change
@@ -14,3 +14,28 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17+
18+
DROP PROCEDURE IF EXISTS ut_dolphin_T_t_ds_fav;
19+
delimiter d//
20+
CREATE PROCEDURE ut_dolphin_T_t_ds_fav()
21+
BEGIN
22+
IF EXISTS (SELECT 1 FROM information_schema.TABLES
23+
WHERE TABLE_NAME='t_ds_fav'
24+
AND TABLE_SCHEMA=(SELECT DATABASE()))
25+
THEN
26+
ALTER TABLE t_ds_fav RENAME t_ds_fav_task;
27+
END IF;
28+
END;
29+
d//
30+
31+
delimiter ;
32+
CALL ut_dolphin_T_t_ds_fav;
33+
DROP PROCEDURE ut_dolphin_T_t_ds_fav;
34+
35+
CREATE TABLE IF NOT EXISTS t_ds_fav_task
36+
(
37+
id serial NOT NULL,
38+
task_name varchar(64) NOT NULL,
39+
user_id int NOT NULL,
40+
PRIMARY KEY (id)
41+
);

Diff for: dolphinscheduler-dao/src/main/resources/sql/upgrade/3.1.3_schema/postgresql/dolphinscheduler_ddl.sql

+10-1
Original file line numberDiff line numberDiff line change
@@ -14,4 +14,13 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
ALTER TABLE t_ds_fav RENAME TO t_ds_fav_task;
17+
18+
ALTER TABLE IF EXISTS t_ds_fav RENAME TO t_ds_fav_task;
19+
20+
CREATE TABLE IF NOT EXISTS t_ds_fav_task
21+
(
22+
id serial NOT NULL,
23+
task_name varchar(64) NOT NULL,
24+
user_id int NOT NULL,
25+
PRIMARY KEY (id)
26+
);

0 commit comments

Comments
 (0)