AiDOPWarehouse/server/Admin.NET.Web.Entry/UpdateScripts/1.0.573.sql

-- 1.0.573 B-2 / A-3 / A-4 / A-5 / C-4 staging / D-4 source columns
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='mdp_std_t8_kc_tz_head' AND COLUMN_NAME='zbrname')=0, 'ALTER TABLE `mdp_std_t8_kc_tz_head` ADD COLUMN `zbrname` varchar(100) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='mdp_std_t8_kc_tz_list' AND COLUMN_NAME='hw')=0, 'ALTER TABLE `mdp_std_t8_kc_tz_list` ADD COLUMN `hw` varchar(80) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='mdp_std_t8_kc_tz_list' AND COLUMN_NAME='ckcode')=0, 'ALTER TABLE `mdp_std_t8_kc_tz_list` ADD COLUMN `ckcode` varchar(80) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='mdp_std_t8_kc_tz_list' AND COLUMN_NAME='pcnoid')=0, 'ALTER TABLE `mdp_std_t8_kc_tz_list` ADD COLUMN `pcnoid` varchar(80) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='mdp_std_t8_kc_tz_list' AND COLUMN_NAME='kcsl')=0, 'ALTER TABLE `mdp_std_t8_kc_tz_list` ADD COLUMN `kcsl` decimal(18,6) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='mdp_std_s6_report' AND COLUMN_NAME='start_work_date')=0, 'ALTER TABLE `mdp_std_s6_report` ADD COLUMN `start_work_date` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;

CREATE TABLE IF NOT EXISTS mdp_stg_inv_trans_inbound (
  id BIGINT AUTO_INCREMENT PRIMARY KEY,
  tenant_id BIGINT NOT NULL DEFAULT 0,
  source_system VARCHAR(50) NULL,
  source_table VARCHAR(200) NULL,
  source_row_id VARCHAR(200) NULL,
  source_biz_key VARCHAR(300) NULL,
  raw_data JSON NULL,
  sync_batch_id VARCHAR(100) NULL,
  create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
  sync_time DATETIME NULL DEFAULT CURRENT_TIMESTAMP,
  process_status VARCHAR(20) NOT NULL DEFAULT 'PENDING',
  process_message VARCHAR(500) NULL,
  update_time DATETIME NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  UNIQUE KEY uk_source_key (tenant_id, source_system, source_table, source_biz_key),
  KEY idx_batch (sync_batch_id),
  KEY idx_src (source_table, source_row_id)
);

CREATE TABLE IF NOT EXISTS mdp_stg_wo_line (
  id BIGINT AUTO_INCREMENT PRIMARY KEY,
  tenant_id BIGINT NOT NULL DEFAULT 0,
  source_system VARCHAR(50) NULL,
  source_table VARCHAR(200) NULL,
  source_row_id VARCHAR(200) NULL,
  source_biz_key VARCHAR(300) NULL,
  raw_data JSON NULL,
  sync_batch_id VARCHAR(100) NULL,
  create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
  sync_time DATETIME NULL DEFAULT CURRENT_TIMESTAMP,
  process_status VARCHAR(20) NOT NULL DEFAULT 'PENDING',
  process_message VARCHAR(500) NULL,
  update_time DATETIME NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  UNIQUE KEY uk_source_key (tenant_id, source_system, source_table, source_biz_key),
  KEY idx_batch (sync_batch_id),
  KEY idx_src (source_table, source_row_id)
);

CREATE TABLE IF NOT EXISTS mdp_stg_wo_bom (
  id BIGINT AUTO_INCREMENT PRIMARY KEY,
  tenant_id BIGINT NOT NULL DEFAULT 0,
  source_system VARCHAR(50) NULL,
  source_table VARCHAR(200) NULL,
  source_row_id VARCHAR(200) NULL,
  source_biz_key VARCHAR(300) NULL,
  raw_data JSON NULL,
  sync_batch_id VARCHAR(100) NULL,
  create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
  sync_time DATETIME NULL DEFAULT CURRENT_TIMESTAMP,
  process_status VARCHAR(20) NOT NULL DEFAULT 'PENDING',
  process_message VARCHAR(500) NULL,
  update_time DATETIME NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  UNIQUE KEY uk_source_key (tenant_id, source_system, source_table, source_biz_key),
  KEY idx_batch (sync_batch_id),
  KEY idx_src (source_table, source_row_id)
);

CREATE TABLE IF NOT EXISTS mdp_stg_inv_bal_monthly (
  id BIGINT AUTO_INCREMENT PRIMARY KEY,
  tenant_id BIGINT NOT NULL DEFAULT 0,
  source_system VARCHAR(50) NULL,
  source_table VARCHAR(200) NULL,
  source_row_id VARCHAR(200) NULL,
  source_biz_key VARCHAR(300) NULL,
  raw_data JSON NULL,
  sync_batch_id VARCHAR(100) NULL,
  create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
  sync_time DATETIME NULL DEFAULT CURRENT_TIMESTAMP,
  process_status VARCHAR(20) NOT NULL DEFAULT 'PENDING',
  process_message VARCHAR(500) NULL,
  update_time DATETIME NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  UNIQUE KEY uk_source_key (tenant_id, source_system, source_table, source_biz_key),
  KEY idx_batch (sync_batch_id),
  KEY idx_src (source_table, source_row_id)
);

INSERT INTO mdp_stg_inv_trans_inbound
  (tenant_id, source_system, source_table, source_row_id, source_biz_key, raw_data, sync_batch_id, process_status, process_message, create_time, sync_time, update_time)
SELECT tenant_id, source_system, source_table, source_row_id, source_biz_key, raw_data, sync_batch_id, process_status, process_message, create_time, sync_time, update_time
FROM mdp_stg_t8_kc_tz_list
WHERE IFNULL(source_system,'') NOT IN ('T8','T8_V5_SQLSERVER')
  AND NOT EXISTS (
    SELECT 1 FROM mdp_stg_inv_trans_inbound n
    WHERE n.tenant_id=mdp_stg_t8_kc_tz_list.tenant_id
      AND IFNULL(n.source_system,'')=IFNULL(mdp_stg_t8_kc_tz_list.source_system,'')
      AND IFNULL(n.source_table,'')=IFNULL(mdp_stg_t8_kc_tz_list.source_table,'')
      AND n.source_biz_key=mdp_stg_t8_kc_tz_list.source_biz_key
  );

DELETE FROM mdp_stg_t8_kc_tz_list WHERE IFNULL(source_system,'') NOT IN ('T8','T8_V5_SQLSERVER');

UPDATE mdp_entity
SET target_table_name='mdp_stg_inv_trans_inbound', update_time=NOW()
WHERE entity_code='S5_INVENTORY_TXN' AND target_table_name<>'mdp_stg_inv_trans_inbound';

CREATE TABLE IF NOT EXISTS mdp_ship_recon_diff (
  id BIGINT AUTO_INCREMENT PRIMARY KEY,
  tenant_id BIGINT NOT NULL,
  source_system VARCHAR(50) NOT NULL,
  domain VARCHAR(50) NOT NULL,
  ord_nbr VARCHAR(120) NOT NULL,
  ord_line VARCHAR(50) NOT NULL,
  biz_date DATE NOT NULL,
  asn_qty DECIMAL(18,6) NOT NULL DEFAULT 0,
  inv_iss_so_qty DECIMAL(18,6) NOT NULL DEFAULT 0,
  diff_qty DECIMAL(18,6) NOT NULL,
  detected_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
  UNIQUE KEY uk_ship_recon (tenant_id, source_system, domain, ord_nbr, ord_line, biz_date)
);

UPDATE mdp_std_inv_trans
SET biz_doc_type='OTHER'
WHERE source_system='DOPDEMORQ_SQLSERVER' AND src_trans_type_raw='iss-so' AND biz_doc_type='SALES_SHIP';

UPDATE mdp_entity SET status=1, update_time=NOW()
WHERE entity_code IN ('S7_FQC_TASK_SQLSERVER','S7_FQC_RESULT_SQLSERVER','S7_FQC_RESULT_DETAIL_SQLSERVER')
  AND status=0;
INSERT INTO mdp_entity (`tenant_id`, `source_id`, `entity_code`, `entity_name`, `entity_type`, `source_table_name`, `source_api_path`, `api_config_id`, `target_table_name`, `sync_mode`, `incr_column`, `batch_size`, `response_data_path`, `dedup_key_path`, `last_cursor`, `last_sync_to`, `job_id`, `status`, `remark`, `create_time`, `update_time`, `TenantId`, `SourceId`, `EntityCode`, `EntityName`, `EntityType`, `SourceTableName`, `SourceApiPath`, `ApiConfigId`, `TargetTableName`, `SyncMode`, `IncrColumn`, `BatchSize`, `ResponseDataPath`, `DedupKeyPath`, `LastCursor`, `biz_key_expr`, `file_config_json`, `is_public_template`, `inbound_enabled`, `inbound_max_rows`, `stale_guard_enabled`, `silence_calendar`, `silence_alert_hours`)
SELECT `tenant_id`, `source_id`, 'S6_EMP_WORK_ORD_TRANS_SQLSERVER', '165报工流水', `entity_type`, 'EmpWorkOrdTransHist', `source_api_path`, `api_config_id`, 'mdp_stg_s6_report', `sync_mode`, `incr_column`, `batch_size`, `response_data_path`, `dedup_key_path`, `last_cursor`, `last_sync_to`, `job_id`, 1, 'S6_REPORT', NOW(), NOW(), `TenantId`, `SourceId`, `EntityCode`, `EntityName`, `EntityType`, `SourceTableName`, `SourceApiPath`, `ApiConfigId`, `TargetTableName`, `SyncMode`, `IncrColumn`, `BatchSize`, `ResponseDataPath`, `DedupKeyPath`, `LastCursor`, 'Domain,Trans,RecID', `file_config_json`, `is_public_template`, `inbound_enabled`, `inbound_max_rows`, `stale_guard_enabled`, `silence_calendar`, `silence_alert_hours`
FROM mdp_entity
WHERE entity_code='S7_FQC_TASK_SQLSERVER'
  AND NOT EXISTS (SELECT 1 FROM mdp_entity e2 WHERE e2.entity_code='S6_EMP_WORK_ORD_TRANS_SQLSERVER');
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ItemMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `ItemMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ItemMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `ItemMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='CustMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `CustMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='CustMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `CustMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='SuppMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `SuppMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='SuppMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `SuppMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='LocationMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `LocationMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='LocationMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `LocationMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='EmployeeMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `EmployeeMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='EmployeeMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `EmployeeMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='DepartmentMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `DepartmentMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='DepartmentMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `DepartmentMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='srm_purchase' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `srm_purchase` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='srm_purchase' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `srm_purchase` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ProductStructureMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `ProductStructureMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ProductStructureMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `ProductStructureMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ProductStructureOp' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `ProductStructureOp` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ProductStructureOp' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `ProductStructureOp` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='RoutingOpDetail' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `RoutingOpDetail` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='RoutingOpDetail' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `RoutingOpDetail` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='StdOpMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `StdOpMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='StdOpMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `StdOpMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='WorkCtrMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `WorkCtrMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='WorkCtrMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `WorkCtrMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='WorkCenter' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `WorkCenter` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='WorkCenter' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `WorkCenter` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='LineMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `LineMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='LineMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `LineMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ProdLineDetail' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `ProdLineDetail` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ProdLineDetail' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `ProdLineDetail` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='LineSkillMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `LineSkillMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='LineSkillMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `LineSkillMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='LineSkillDetail' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `LineSkillDetail` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='LineSkillDetail' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `LineSkillDetail` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='LinePost' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `LinePost` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='LinePost' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `LinePost` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='PersonSkill' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `PersonSkill` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='PersonSkill' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `PersonSkill` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='EmpSkills' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `EmpSkills` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='EmpSkills' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `EmpSkills` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='PersonSkillAssignment' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `PersonSkillAssignment` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='PersonSkillAssignment' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `PersonSkillAssignment` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectioncrit' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_inspectioncrit` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectioncrit' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_inspectioncrit` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspeccrit_entry' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_inspeccrit_entry` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspeccrit_entry' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_inspeccrit_entry` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectionfreq' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_inspectionfreq` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectionfreq' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_inspectionfreq` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectioninstru' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_inspectioninstru` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectioninstru' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_inspectioninstru` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectionitems' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_inspectionitems` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectionitems' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_inspectionitems` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspection_method' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_inspection_method` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspection_method' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_inspection_method` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectionstd' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_inspectionstd` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectionstd' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_inspectionstd` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectionstdentry' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_inspectionstdentry` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectionstdentry' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_inspectionstdentry` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_sampscheme' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_sampscheme` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_sampscheme' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_sampscheme` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectpro' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_inspectpro` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspectpro' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_inspectpro` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspro_ent' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_inspro_ent` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_inspro_ent' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_inspro_ent` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_quality_base_type' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_quality_base_type` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_quality_base_type' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_quality_base_type` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_jygf' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_jygf` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_jygf' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_jygf` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_jygfzb' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_jygfzb` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_jygfzb' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_jygfzb` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_gcjygf' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_gcjygf` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_gcjygf' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_gcjygf` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_gcjygfzb' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_gcjygfzb` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_gcjygfzb' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_gcjygfzb` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_fqcjygf' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_fqcjygf` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_fqcjygf' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_fqcjygf` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_fqcjygfzb' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_fqcjygfzb` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_fqcjygfzb' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_fqcjygfzb` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_oqcjygf' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_oqcjygf` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_oqcjygf' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_oqcjygf` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_oqcjygfzb' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_oqcjygfzb` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_oqcjygfzb' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_oqcjygfzb` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_ccjygf' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_ccjygf` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_ccjygf' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_ccjygf` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_ccjygfzb' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_ccjygfzb` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_ccjygfzb' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_ccjygfzb` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_lymjbmd' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `qms_lymjbmd` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='qms_lymjbmd' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `qms_lymjbmd` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ItemPackMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `ItemPackMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ItemPackMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `ItemPackMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='LocationShelfMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `LocationShelfMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='LocationShelfMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `LocationShelfMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='NbrControl' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `NbrControl` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='NbrControl' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `NbrControl` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='NbrTypeMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `NbrTypeMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='NbrTypeMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `NbrTypeMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='BarCodeType' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `BarCodeType` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='BarCodeType' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `BarCodeType` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='BarCodeNbr' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `BarCodeNbr` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='BarCodeNbr' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `BarCodeNbr` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='CostCtrMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `CostCtrMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='CostCtrMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `CostCtrMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='EmpWorkDutyMaster' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `EmpWorkDutyMaster` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='EmpWorkDutyMaster' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `EmpWorkDutyMaster` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='wms_rwzp' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `wms_rwzp` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='wms_rwzp' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `wms_rwzp` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0OrderReviewCycle' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `S0OrderReviewCycle` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0OrderReviewCycle' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `S0OrderReviewCycle` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0ProductDesignCycle' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `S0ProductDesignCycle` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0ProductDesignCycle' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `S0ProductDesignCycle` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0ContractReviewCycle' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `S0ContractReviewCycle` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0ContractReviewCycle' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `S0ContractReviewCycle` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0ContractReviewCycleBreakdown' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `S0ContractReviewCycleBreakdown` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0ContractReviewCycleBreakdown' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `S0ContractReviewCycleBreakdown` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='PriorityCode' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `PriorityCode` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='PriorityCode' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `PriorityCode` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ado_s0_sales_order_priority_rule' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `ado_s0_sales_order_priority_rule` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ado_s0_sales_order_priority_rule' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `ado_s0_sales_order_priority_rule` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0CategoryLeadTime' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `S0CategoryLeadTime` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0CategoryLeadTime' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `S0CategoryLeadTime` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0MaterialPlanCycle' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `S0MaterialPlanCycle` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0MaterialPlanCycle' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `S0MaterialPlanCycle` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0OrderScheduleCycle' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `S0OrderScheduleCycle` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0OrderScheduleCycle' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `S0OrderScheduleCycle` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='WorkOrdControl' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `WorkOrdControl` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='WorkOrdControl' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `WorkOrdControl` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ItemSubstituteDetail' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `ItemSubstituteDetail` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ItemSubstituteDetail' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `ItemSubstituteDetail` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ic_substitute' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `ic_substitute` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ic_substitute' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `ic_substitute` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ado_kitting_exclude_rule' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `ado_kitting_exclude_rule` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ado_kitting_exclude_rule' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `ado_kitting_exclude_rule` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='PreprocessElement' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `PreprocessElement` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='PreprocessElement' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `PreprocessElement` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='PreprocessElementParam' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `PreprocessElementParam` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='PreprocessElementParam' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `PreprocessElementParam` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ElementParam' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `ElementParam` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ElementParam' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `ElementParam` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0ProcessFlowCard' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `S0ProcessFlowCard` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='S0ProcessFlowCard' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `S0ProcessFlowCard` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='MaterialProcessElement' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `MaterialProcessElement` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='MaterialProcessElement' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `MaterialProcessElement` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ItemOpCondition' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `ItemOpCondition` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ItemOpCondition' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `ItemOpCondition` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ImageType' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `ImageType` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='ImageType' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `ImageType` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='QualitySegmentImage' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `QualitySegmentImage` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='QualitySegmentImage' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `QualitySegmentImage` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='DevMonitor' AND COLUMN_NAME='source_system')=0, 'ALTER TABLE `DevMonitor` ADD COLUMN `source_system` varchar(50) NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;
SET @sql := IF((SELECT COUNT(*) FROM information_schema.COLUMNS WHERE TABLE_SCHEMA=DATABASE() AND TABLE_NAME='DevMonitor' AND COLUMN_NAME='source_updated_at')=0, 'ALTER TABLE `DevMonitor` ADD COLUMN `source_updated_at` datetime NULL', 'DO 0');
PREPARE stmt FROM @sql; EXECUTE stmt; DEALLOCATE PREPARE stmt;