From 82407bc869e6336c0484acbd038a32886f144a3f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=AD=99=E5=B0=8F=E4=BA=91?= Date: Thu, 15 Jan 2026 09:53:47 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=AE=B9=E5=99=A8=E5=8C=96?= =?UTF-8?q?=E7=9A=84=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sql/wvp.sql | 62 ++++++++++++++++++++++++++--------------------------- 1 file changed, 31 insertions(+), 31 deletions(-) diff --git a/sql/wvp.sql b/sql/wvp.sql index ddfc1b9..34d1360 100644 --- a/sql/wvp.sql +++ b/sql/wvp.sql @@ -523,38 +523,38 @@ create table IF NOT EXISTS wvp_jt_channel ( CREATE PROCEDURE `wvp_20240528`() BEGIN IF NOT EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_media_server' and column_name = 'transcode_suffix') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_media_server' and column_name = 'transcode_suffix') THEN ALTER TABLE wvp_media_server ADD transcode_suffix character varying(255); END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_media_server' and column_name = 'type') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_media_server' and column_name = 'type') THEN alter table wvp_media_server add type character varying(50) default 'zlm'; END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_media_server' and column_name = 'flv_port') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_media_server' and column_name = 'flv_port') THEN alter table wvp_media_server add flv_port integer; END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_media_server' and column_name = 'flv_ssl_port') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_media_server' and column_name = 'flv_ssl_port') THEN alter table wvp_media_server add flv_ssl_port integer; END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_media_server' and column_name = 'ws_flv_port') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_media_server' and column_name = 'ws_flv_port') THEN alter table wvp_media_server add ws_flv_port integer; END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_media_server' and column_name = 'ws_flv_ssl_port') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_media_server' and column_name = 'ws_flv_ssl_port') THEN alter table wvp_media_server add ws_flv_ssl_port integer; END IF; @@ -580,37 +580,37 @@ create table IF NOT EXISTS wvp_user_api_key ( CREATE PROCEDURE `wvp_20241222`() BEGIN IF EXISTS (SELECT column_name FROM information_schema.STATISTICS - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and INDEX_NAME = 'uk_wvp_device_channel_unique_device_channel') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and INDEX_NAME = 'uk_wvp_device_channel_unique_device_channel') THEN alter table wvp_device_channel drop index uk_wvp_device_channel_unique_device_channel; END IF; IF EXISTS (SELECT column_name FROM information_schema.STATISTICS - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and INDEX_NAME = 'uk_wvp_unique_stream_push_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and INDEX_NAME = 'uk_wvp_unique_stream_push_id') THEN alter table wvp_device_channel drop index uk_wvp_unique_stream_push_id; END IF; IF EXISTS (SELECT column_name FROM information_schema.STATISTICS - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and INDEX_NAME = 'uk_wvp_unique_stream_proxy_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and INDEX_NAME = 'uk_wvp_unique_stream_proxy_id') THEN alter table wvp_device_channel drop index uk_wvp_unique_stream_proxy_id; END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'data_type') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and column_name = 'data_type') THEN alter table wvp_device_channel add data_type integer not null; END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'data_device_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and column_name = 'data_device_id') THEN alter table wvp_device_channel add data_device_id integer not null; END IF; IF EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'device_db_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and column_name = 'device_db_id') THEN update wvp_device_channel wdc INNER JOIN (SELECT id, device_db_id from wvp_device_channel where device_db_id is not null ) ct on ct.id = wdc.id @@ -619,7 +619,7 @@ BEGIN END IF; IF EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'stream_push_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and column_name = 'stream_push_id') THEN update wvp_device_channel wdc INNER JOIN (SELECT id, stream_push_id from wvp_device_channel where stream_push_id is not null ) ct on ct.id = wdc.id @@ -628,7 +628,7 @@ BEGIN END IF; IF EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'stream_proxy_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and column_name = 'stream_proxy_id') THEN update wvp_device_channel wdc INNER JOIN (SELECT id, stream_proxy_id from wvp_device_channel where stream_proxy_id is not null ) ct on ct.id = wdc.id @@ -644,7 +644,7 @@ DROP PROCEDURE wvp_20241222; CREATE PROCEDURE `wvp_20241231`() BEGIN IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_stream_proxy' and column_name = 'relates_media_server_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_stream_proxy' and column_name = 'relates_media_server_id') THEN alter table wvp_stream_proxy add relates_media_server_id character varying(50); END IF; @@ -657,19 +657,19 @@ DROP PROCEDURE wvp_20241231; CREATE PROCEDURE `wvp_20250111`() BEGIN IF EXISTS (SELECT column_name FROM information_schema.STATISTICS - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_cloud_record' and INDEX_NAME = 'uk_stream_push_app_stream_path') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_cloud_record' and INDEX_NAME = 'uk_stream_push_app_stream_path') THEN alter table wvp_cloud_record drop index uk_stream_push_app_stream_path ; END IF; IF EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_cloud_record' and column_name = 'folder') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_cloud_record' and column_name = 'folder') THEN alter table wvp_cloud_record modify folder varchar(500) null; END IF; IF EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_cloud_record' and column_name = 'file_path') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_cloud_record' and column_name = 'file_path') THEN alter table wvp_cloud_record modify file_path varchar(500) null; END IF; @@ -683,19 +683,19 @@ DROP PROCEDURE wvp_20250111; CREATE PROCEDURE `wvp_20250211`() BEGIN IF EXISTS (SELECT column_name FROM information_schema.STATISTICS - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device' and column_name = 'keepalive_interval_time') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device' and column_name = 'keepalive_interval_time') THEN alter table wvp_device change keepalive_interval_time heart_beat_interval integer after as_message_channel; END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device' and column_name = 'heart_beat_count') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device' and column_name = 'heart_beat_count') THEN alter table wvp_device add heart_beat_count integer; END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device' and column_name = 'position_capability') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device' and column_name = 'position_capability') THEN alter table wvp_device add position_capability integer; END IF; @@ -710,35 +710,35 @@ CREATE PROCEDURE `wvp_20250312`() BEGIN DECLARE serverId VARCHAR(32) DEFAULT '你的服务ID'; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device' and column_name = 'server_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device' and column_name = 'server_id') THEN alter table wvp_device add server_id character varying(50); update wvp_device set server_id = serverId; END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_media_server' and column_name = 'server_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_media_server' and column_name = 'server_id') THEN alter table wvp_media_server add server_id character varying(50); update wvp_media_server set server_id = serverId; END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_stream_proxy' and column_name = 'server_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_stream_proxy' and column_name = 'server_id') THEN alter table wvp_stream_proxy add server_id character varying(50); update wvp_stream_proxy set server_id = serverId; END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_cloud_record' and column_name = 'server_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_cloud_record' and column_name = 'server_id') THEN alter table wvp_cloud_record add server_id character varying(50); update wvp_cloud_record set server_id = serverId; END IF; IF not EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_platform' and column_name = 'server_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_platform' and column_name = 'server_id') THEN alter table wvp_platform add server_id character varying(50); END IF; @@ -752,19 +752,19 @@ DROP PROCEDURE wvp_20250312; CREATE PROCEDURE `wvp_20250319`() BEGIN IF NOT EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'gps_speed') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and column_name = 'gps_speed') THEN alter table wvp_device_channel add gps_speed double precision; END IF; IF NOT EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'gps_altitude') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and column_name = 'gps_altitude') THEN alter table wvp_device_channel add gps_altitude double precision; END IF; IF NOT EXISTS (SELECT column_name FROM information_schema.columns - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and column_name = 'gps_direction') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and column_name = 'gps_direction') THEN alter table wvp_device_channel add gps_direction double precision; END IF; @@ -778,12 +778,12 @@ DROP PROCEDURE wvp_20250319; CREATE PROCEDURE `wvp_20250402`() BEGIN IF NOT EXISTS (SELECT column_name FROM information_schema.STATISTICS - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and INDEX_NAME = 'data_type') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and INDEX_NAME = 'data_type') THEN create index data_type on wvp_device_channel (data_type); END IF; IF NOT EXISTS (SELECT column_name FROM information_schema.STATISTICS - WHERE TABLE_SCHEMA = (SELECT DATABASE()) and table_name = 'wvp_device_channel' and INDEX_NAME = 'data_device_id') + WHERE TABLE_SCHEMA = 'wvp' and table_name = 'wvp_device_channel' and INDEX_NAME = 'data_device_id') THEN create index data_device_id on wvp_device_channel (data_device_id); END IF;