MySQL常见的脚本语句格式参考指南

更新时间：2022年06月07日 16:37:56 作者：lang20150928

无论是运维、开发、测试,还是架构师,数据库技术是一个必备加薪神器,下面这篇文章主要给大家介绍了关于MySQL常见的脚本语句格式参考指南的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下

表整体（TABLE ）操作

针对数据库的表进行新增操作，考虑到脚本可重复执行，有以下两种方案

使用TRYADDTABLE存储过程

CALL TRYADDTABLE('ACT_GE_PROPERTY', 'CREATE TABLE ACT_GE_PROPERTY  (
  NAME_ varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  VALUE_ varchar(600) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  REV_ decimal(22, 0) NULL DEFAULT NULL,
  PRIMARY KEY (NAME_) USING BTREE,
  INDEX SYS_C001769640(NAME_) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;')

使用原生判断语句

CREATE TABLE IF NOT EXISTS ACT_GE_PROPERTY  (
  NAME_ varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  VALUE_ varchar(600) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  REV_ decimal(22, 0) NULL DEFAULT NULL,
  PRIMARY KEY (NAME_) USING BTREE,
  INDEX SYS_C001769640(NAME_) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

使用以上两种方式可能存在一个问题，就是数据库中存在一个表结构不同的表，此时以上的语句其实就是无效的，很多人都会采用先删表然后再建表的方式，如下所示

DROP TABLE IF EXISTS ACT_GE_PROPERTY;
CREATE TABLE ACT_GE_PROPERTY  (
  NAME_ varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  VALUE_ varchar(600) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  REV_ decimal(22, 0) NULL DEFAULT NULL,
  PRIMARY KEY (NAME_) USING BTREE,
  INDEX SYS_C001769640(NAME_) USING BTREE
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

但是删除表是存在巨大风险的，如果只是一些缓存表倒还好，如果是存放重要业务数据或者参数信息的表，删除表会导致程序运行失败。所以是不允许直接删除表的，那么如何避免数据库存在同样表名而结构不同呢？可以考虑在建表语句后面添加一个查询语句，其中包含完整的字段。

SELECT NAME_,VALUE_,REV_ FROM ACT_GE_PROPERTY LIMIT 0,1;

一旦表结构不一致，就需要考虑针对表字段的增删操作以及数据同步操作。

删除表的操作是存在巨大风险的，删除表之前必须准备评估是否导致业务数据丢失的问题。

表字段（COLUMN ）操作

新增表字段

通过TRYADDTABCOLUMN存储过程保证可重复执行。

CALL TRYADDTABCOLUMN('ACT_GE_PROPERTY','VALUE_ ','varchar(600) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL');

修改表字段

原生语句已经支持可重复执行，直接使用即可

ALTER TABLE ACT_GE_PROPERTY MODIFY COLUMN VALUE_ varchar(200) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL;

删除表字段

删除表字段同样是存在巨大风险的，需要仔细评估。可能会涉及的场合就是将某个字段替换为另一个字段（二者名称不一致）。通过先删除字段然后再添加字段会导致原来数据丢失，MySQL中可以通过ALTER TABLE CHANGE语句来修改字段。但是没法保证可重复性。

-- 将ACT_GE_PROPERTY字段VALUE_的名字修改为VALUE2_
-- 对应的MySQL原语句 ALTER TABLE ACT_GE_PROPERTY CHANGE VALUE_ VALUE2_ varchar(200) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL;
CALL TRYCHANGETABCOLUMN('ACT_GE_PROPERTY','VALUE_','VALUE2_','varchar(200) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL');
-- 将ACT_GE_PROPERTY字段VALUE2_的名字修改为VALUE_
CALL TRYCHANGETABCOLUMN('ACT_GE_PROPERTY','VALUE2_','VALUE_','varchar(200) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL');

表索引（INDEX ）操作

添加索引

主要考虑可重复执行问题，首先通过TRYDROPINDEX删除索引。然后再创建索引

-- 创建普通索引
CALL TRYDROPINDEX('ACT_GE_PROPERTY','IDX_REV_');
CREATE INDEX IDX_REV_ ON ACT_GE_PROPERTY (REV_ ASC)  USING BTREE;
-- 创建唯一索引
CALL TRYDROPINDEX('ACT_GE_PROPERTY','IDX_VALUE_');
CREATE UNIQUE INDEX IDX_VALUE_ ON ACT_GE_PROPERTY (VALUE_ ASC)  USING BTREE;
-- 多个字段的索引
CALL TRYDROPINDEX('ACT_GE_PROPERTY','IDX_VALUE_REV_');
CREATE UNIQUE INDEX IDX_VALUE_REV_ ON ACT_GE_PROPERTY (VALUE_ ASC,REV_ ASC)  USING BTREE;

删除索引

考虑可重复执行问题，直接使用存储过程。

CALL TRYDROPINDEX('ACT_GE_PROPERTY','IDX_REV_');
CALL TRYDROPINDEX('ACT_GE_PROPERTY','IDX_VALUE_');
CALL TRYDROPINDEX('ACT_GE_PROPERTY','IDX_VALUE_REV_');

表数据操作

新增数据

绝大多数的表新增数据都只需考虑先根据主键或者关键字删除，然后插入数据即可。如下所示

DELETE FROM act_ge_property WHERE NAME_ IN('next.dbid','schema.history','schema.version');
INSERT INTO act_ge_property(NAME_, VALUE_, REV_) VALUES ('next.dbid', '1215401', 12155);
INSERT INTO act_ge_property(NAME_, VALUE_, REV_) VALUES ('schema.history', 'create(5.15.1)', 1);
INSERT INTO act_ge_property(NAME_, VALUE_, REV_) VALUES ('schema.version', '5.15.1', 1);
COMMIT;

以上表是没有数字型的主键的，如果涉及到数据型主键的，有两种方案：

第一种采用主键自增，只用在表结构定义的时候将主键字段设置为AUTO_INCREMENT即可。

第二种模仿oracle中的序列，在mysql中通过表SEQUENCE维护这些序列信息。在插入数据的时候，需要通过存储过程getSequenceNextVal获取序列值（其中S_TSYS_CUSTOMER对应SEQUENCE表的SEQ_NAME字段）

DELETE FROM TSYS_CUSTOMER WHERE S_CODE = 'PY2022';
INSERT INTO `TSYS_CUSTOMER`(`S_ID`, `S_CODE`, `C_CODE`, `C_NAME`) VALUES (getSequenceNextVal('S_TSYS_CUSTOMER'),  'PY2022', 'PUFA_BANK', '浦银自营');
COMMIT;

但是有部分的表是不允许这样操作的，比如TPARA表、SEQUENCE表。前者在规范（http://191.168.0.126/svn/xIR_Web_J2EE/2.银行资管/文档/技术文档/脚本规范/初始化TPARA数据脚本规范.html）中已经详述，后者在规范（http://191.168.0.126/svn/xIR_Web_J2EE/2.银行资管/文档/技术文档/脚本规范/MySQL序列操作规范.html）中详述。

TPARA表新增数据

CALL TRYEXCUTEIFNOTEXISTS('TPARA','P_CODE','IsUsedInstVerifyApproval','
 INSERT INTO TPARA(P_ID, P_NAME, P_CODE, P_VALUE, P_VALUE_NAME, P_TYPE, P_ISVISIBLE, P_ENUM_VALUE, P_ENUM_TYPE, P_ISMULTI, P_CREAT_DATE, P_REMARK) VALUES (''31020'', ''是否使用指令验证审批流程'', ''IsUsedInstVerifyApproval'', ''false'', ''否'', ''3'', ''1'', ''true_是@false_否'', ''1'', ''0'', ''20171124'', NULL)
');

SEQUENCE表新增数据

CALL TRYADDSEQUENCE('S_TTRD_AUTH_PORTAL_CONFIG', 'INSERT INTO SEQUENCE(SEQ_NAME, CURRENT_VAL, INCREMENT_VAL, MIN_VAL, MAX_VAL, CACHE_SIZE) VALUES (''S_TTRD_AUTH_PORTAL_CONFIG'', 1, 1, 0, 9223372036854775807, 20)');

新增表数据类似于初始化操作，如果这个数据不会变化，无论操作多少次都是一样的，先删除后插入没有任何问题。但是这个数据可能会被修改的时候，就要考虑你的脚本会不会因为重复执行导致业务没法操作了。比如序列初始化的时候是1，然后在程序里使用了一段时间，再次执行你的脚本，数据库的序列值回去了，程序肯定会报错的（对应的主键值已经存在了）。

FUNCTION 函数操作

DROP FUNCTION IF EXISTS GZB_GET_PRECISION_VALUE;
-- 在创建函数语句前修改默认分割符
DELIMITER $
CREATE FUNCTION GZB_GET_PRECISION_VALUE(VAL VARCHAR(100),V_CASH_ACCT_ID VARCHAR(10)) RETURNS VARCHAR(100) 
BEGIN
  DECLARE  RET_VAL VARCHAR(100);
  DECLARE V_INDEX_PRECISION INTEGER ;
  DECLARE V_CALC_TYPE VARCHAR(1);
  IF VAL IS NULL OR V_CASH_ACCT_ID IS NULL THEN
  SET RET_VAL=COALESCE(VAL, '0');
    RETURN RET_VAL;
  ELSE
  SELECT MAX(PRC.INDEX_PRECISION), MAX(PRC.CALC_TYPE)
    INTO V_INDEX_PRECISION, V_CALC_TYPE
    FROM V_GZB_INDEX_PRECISION PRC
    INNER JOIN TTRD_WMPS_DEFINE WPS
      ON PRC.I_CODE = WPS.I_CODE
     AND PRC.A_TYPE = WPS.A_TYPE
     AND PRC.M_TYPE = WPS.M_TYPE
    INNER JOIN TTRD_ACC_CASH ACC_CASH
    ON WPS.UNIT_ID = ACC_CASH.PC1
   WHERE WPS.ZMCP_FLAG = '0'
     AND INSTR(WPS.I_CODE, 'TEMP') = 0
     AND PRC.F_CODE = 'NAV_OTHER'
     AND ACC_CASH.ACCID = V_CASH_ACCT_ID;
  END IF;
   IF COALESCE(V_CALC_TYPE, '1') = '1' THEN
      SET RET_VAL = LEFT(VAL, INSTR(VAL,'.')+COALESCE(V_INDEX_PRECISION, 8));
   ELSE
    SET RET_VAL = ROUND(VAL, COALESCE(V_INDEX_PRECISION, 8));
   END IF;
    RETURN RET_VAL;
-- 结束时使用指定的分隔符    
END $
--  最后修改分割符为默认值
DELIMITER ;

PROCEDURE 存储过程操作

DROP PROCEDURE IF EXISTS TRYADDTABCOLUMN;

DELIMITER $
CREATE PROCEDURE `TRYADDTABCOLUMN`(IN tableName VARCHAR(100),IN colName VARCHAR(50),IN colType VARCHAR(1000))
BEGIN
    DECLARE colCount INT;
    SELECT COUNT(*) INTO colCount FROM information_schema.COLUMNS WHERE TABLE_NAME = tableName AND COLUMN_NAME = colName;
    IF(colCount = 0) THEN
  -- @表示全局变量 相当于php $ 拼接赋值 INTO 必须要用全局变量不然语句会报错
  SET @add_sql = CONCAT('ALTER TABLE ',tableName,' ADD COLUMN ',colName,' ',colType,';');
  -- 预处理需要执行的动态SQL，其中stmt是一个变量
  PREPARE stmt FROM @add_sql;
  -- 执行SQL语句
  EXECUTE stmt;
  -- 释放掉预处理段
  deallocate prepare stmt;
END IF;
END $
DELIMITER ;

附录

TRYADDTABLE存储过程

DROP PROCEDURE
    IF
    EXISTS TRYADDTABLE;

DELIMITER $
CREATE PROCEDURE `TRYADDTABLE`(IN tableName VARCHAR(50),IN createTableSql VARCHAR(3000))
BEGIN
    DECLARE tableCount INT;
    SELECT COUNT(*) INTO tableCount FROM information_schema.TABLES WHERE TABLE_NAME = tableName;
    IF(tableCount = 0) THEN
	  -- @表示全局变量 相当于php $ 拼接赋值 INTO 必须要用全局变量不然语句会报错
    SET @create_sql = createTableSql;
    -- 预处理需要执行的动态SQL，其中stmt是一个变量
    PREPARE stmt FROM @create_sql;
    -- 执行SQL语句
    EXECUTE stmt;
    -- 释放掉预处理段
    deallocate prepare stmt;
END IF;
END $
DELIMITER ;

TRYADDTABCOLUMN存储过程

DROP PROCEDURE
    IF
    EXISTS TRYADDTABCOLUMN;

DELIMITER $
CREATE PROCEDURE `TRYADDTABCOLUMN`(IN tableName VARCHAR(100),IN colName VARCHAR(50),IN colType VARCHAR(1000))
BEGIN
    DECLARE colCount INT;
    SELECT COUNT(*) INTO colCount FROM information_schema.COLUMNS WHERE TABLE_NAME = tableName AND COLUMN_NAME = colName;
    IF(colCount = 0) THEN
  -- @表示全局变量 相当于php $ 拼接赋值 INTO 必须要用全局变量不然语句会报错
  SET @add_sql = CONCAT('ALTER TABLE ',tableName,' ADD COLUMN ',colName,' ',colType,';');
  -- 预处理需要执行的动态SQL，其中stmt是一个变量
  PREPARE stmt FROM @add_sql;
  -- 执行SQL语句
  EXECUTE stmt;
  -- 释放掉预处理段
  deallocate prepare stmt;
END IF;
END $
DELIMITER ;

TRYDROPINDEX存储过程

DROP PROCEDURE
    IF
    EXISTS TRYDROPINDEX;

DELIMITER $
CREATE PROCEDURE `TRYDROPINDEX`(IN tableName VARCHAR ( 2000 ), IN indexName VARCHAR ( 2000 ))
BEGIN
    DECLARE row1 INT;
    SELECT
    COUNT( * ) INTO row1
    FROM
    INFORMATION_SCHEMA.STATISTICS
    WHERE
    TABLE_SCHEMA = (SELECT DATABASE())
    AND TABLE_NAME = tableName
    AND INDEX_NAME = indexName;
    IF
    ( row1 > 0 ) THEN
    SET @exeuteSQL = CONCAT( 'ALTER table ', tableName, ' DROP INDEX ', indexName );
    PREPARE stmt FROM @exeuteSQL;
    EXECUTE stmt;
    DEALLOCATE PREPARE stmt;
END IF;
END $
DELIMITER ;

TRYCHANGETABCOLUMN存储过程

DROP PROCEDURE IF EXISTS TRYCHANGETABCOLUMN;

delimiter //
CREATE PROCEDURE TRYCHANGETABCOLUMN (IN tableName VARCHAR(50),IN origiColName VARCHAR(50),IN targetColName VARCHAR(50),IN targetColType VARCHAR(100))
BEGIN
	DECLARE colCount INT;
  SELECT COUNT(*) INTO colCount FROM information_schema.COLUMNS WHERE TABLE_NAME = tableName AND COLUMN_NAME = targetColName;
	IF(colCount > 0) THEN
		SET @excute_sql = CONCAT('ALTER TABLE ',tableName,' MODIFY COLUMN ',targetColName,' ',targetColType,';');
	ELSE
		SET @excute_sql = CONCAT('ALTER TABLE ',tableName,' CHANGE ',origiColName,' ',targetColName,' ',targetColType,';');
	END IF;
	-- 预处理需要执行的动态SQL，其中stmt是一个变量
	PREPARE stmt FROM @excute_sql;
	-- 执行SQL语句
	EXECUTE stmt;
	-- 释放掉预处理段
	deallocate prepare stmt;
END //
delimiter ;

总结

到此这篇关于MySQL常见的脚本语句格式南的文章就介绍到这了,更多相关MySQL脚本语句格式内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

一文详解MySQL中数据表的外连接
因为 MySQL 是关系型数据库，数据是拆分重组在多个数据表里面的。所以我们势必要从多个数据表中提取数据，通过 SQL 语句的内连接与外连接就能够实现多表查询了，本文就来讲讲MySQL的外连接
2022-08-08
MySQL实现数据更新的示例详解
这篇文章主要为大家详细介绍了MySQL实现数据更新的相关资料，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-02-02
MySQL存储时间类型选择的问题讲解
今天小编就为大家分享一篇关于MySQL存储时间类型选择的问题讲解，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧
2019-03-03
MySQL用B+树作为索引结构有什么好处
这篇文章主要介绍了MySQL用B+树作为索引结构有什么好处，帮助大家更好的理解和使用MySQL 索引，感兴趣的朋友可以了解下
2021-01-01
mysql执行脚本导入表和数据后中文注释乱码的问题解决
本人在使用不同版本下进行操作时,就会出现中文乱码的问题,,例如我本地安装mysql8,服务器安装的是mysql5,然后本地连接服务器的mysql后,执行SQL脚本之后发现中文全部乱码,所以本文介绍了mysql执行脚本导入表和数据后中文注释乱码的问题解决,需要的朋友可以参考下
2024-04-04
MySQL数据误删除的快速解决方法（MySQL闪回工具）
Binlog2sql是一个Python开发开源的MySQL Binlog解析工具，能够将Binlog解析为原始的SQL，也支持将Binlog解析为回滚的SQL，去除主键的INSERT SQL，是DBA和运维人员数据恢复好帮手，下面小编通过教程给大介绍MySQL数据误删除的快速解决方法，一起看看吧
2019-10-10
MySQL学习笔记之数据的增、删、改实现方法
这篇文章主要介绍了MySQL学习笔记之数据的增、删、改实现方法,简单介绍了mysql实现数据的增、删、改相关语法与使用技巧,需要的朋友可以参考下
2016-09-09
Mysql将字符串按照指定字符分割的正确方法
字符串分割是我们开发中经常会遇到的一个需求,下面这篇文章主要给大家介绍了关于Mysql将字符串按照指定字符分割的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2022-05-05
MySQL中用通用查询日志找出查询次数最多的语句的教程
这篇文章主要介绍了MySQL中用通用查询日志找出查询次数最多的语句的教程,文中附带了通用查询日志的开启和清除技巧,需要的朋友可以参考下
2015-12-12
mysq启动失败问题及场景分析
这篇文章主要介绍了mysq启动失败问题及解决方法,通过问题分析定位特殊场景解析给大家带来完美解决方案，需要的朋友可以参考下
2021-07-07