MySQL 批量Dll操作(转)

概述

本章节介绍使用游标来批量进行表操作,包括批量添加索引、批量添加字段等。如果对存储过程、变量定义、预处理还不是很熟悉先阅读我前面写过的关于这三个概念的文章,只有先了解了这三个概念才能更好的理解这篇文章。

 

MySQL变量和条件:http://www.cnblogs.com/chenmh/p/5203429.html

PREPARE 预处理语句:http://www.cnblogs.com/chenmh/articles/5308085.html

MySQL存储过程和函数:http://www.cnblogs.com/chenmh/p/5201473.html

正文

光标声明

声明光标

DECLARE cursor_name CURSOR FOR select_statement

这个语句声明一个光标。也可以在子程序中定义多个光标,但是一个块中的每一个光标必须有唯一的名字。

注意:SELECT语句不能有INTO子句。

打开光标

OPEN cursor_name

这个语句打开先前声明的光标。

前进光标

FETCH cursor_name INTO var_name [, var_name] ...

这个语句用指定的打开光标读取下一行(如果有下一行的话),并且前进光标指针。

关闭光标

CLOSE cursor_name

这个语句关闭先前打开的光标。

 

批量添加索引

共享一个批量添加索引的游标,当一个库中有上百张表结构一样但是名称不一样的表,这个时候批量操作就变得简单了。

#删除创建存储过程DROP PROCEDURE IF EXISTS FountTable;
DELIMITER $$
CREATE PROCEDURE FountTable()
BEGIN
    DECLARE TableName varchar(64);     #声明游标
    DECLARE cur_FountTable CURSOR FOR SELECT TABLE_NAME FROM information_schema.TABLES WHERE TABLE_SCHEMA='front' AND TABLE_NAME LIKE 'student%';
    DECLARE EXIT HANDLER FOR not found CLOSE cur_FountTable;
    #打开游标
    OPEN cur_FountTable;
    REPEAT
         FETCH cur_FountTable INTO TableName;
         #定义预处理
         SET @SQLSTR1 = CONCAT('create index Flag on ','`',TableName,'`',' (Flag); ');
         SET @SQLSTR2 = CONCAT('create index State on ','`',TableName,'`',' (State); ');
         SET @SQLSTR3 = CONCAT('create index upload on ','`',TableName,'`',' (upload); ');
         SET @SQLSTR4 = CONCAT('create index ccFlag on ','`',TableName,'`',' (lockFlag); ');
         SET @SQLSTR5 = CONCAT('create index comes on ','`',TableName,'`',' (comes); ');
         ###SET @SQLSTR=CONCAT(@SQLSTR1,@SQLSTR2,@SQLSTR3,@SQLSTR4,@SQLSTR5 );
         PREPARE STMT1 FROM @SQLSTR1;
         PREPARE STMT2 FROM @SQLSTR2;
         PREPARE STMT3 FROM @SQLSTR3;
         PREPARE STMT4 FROM @SQLSTR4;
         PREPARE STMT5 FROM @SQLSTR5;
         EXECUTE STMT1;
         EXECUTE STMT2;
         EXECUTE STMT3;
         EXECUTE STMT4;
         EXECUTE STMT5;
         DEALLOCATE PREPARE STMT1;
         DEALLOCATE PREPARE STMT2;
         DEALLOCATE PREPARE STMT3;
         DEALLOCATE PREPARE STMT4;
         DEALLOCATE PREPARE STMT5;
        # SELECT @SQLSTR;

    UNTIL 0 END REPEAT;
    #关闭游标
    CLOSE cur_FountTable;

END $$
DELIMITER ;

CALL FountTable();

这里有几个细节:

  • 在声明游标的时候记得修改自己需要查询的条件
  • 在预处理这里也需要改成对应的字段
  • 在定义条件变量的时候这里我使用的是EXIT就是遇到错误就中断,当然也可以使用CONTINUE 。

 

注意:由于mysql在存储过程当中无法将查询出来的变量名直接作为表名来用,所以这里要用到动态拼接SQL的方法,但是通常的SET CONCAT的方法并不管用,所以这里就使用了PREPARE来进行预编译。

 

总结

批量处理虽然有时候能提高工作的效率,但是带来的潜在危险也是挺大了,所以在执行之前必须要非常有把握你执行的语句对数据的影响,否则在生成环境就非常危险了

 

http://www.cnblogs.com/chenmh/p/5308146.html

时间: 2024-10-28 05:36:14

MySQL 批量Dll操作(转)的相关文章

mysql-VS引用Mysql 的Connector NET中的MySql Data dll有好几个,区别是

问题描述 VS引用Mysql 的Connector NET中的MySql Data dll有好几个,区别是 Mysql中选择引用Connector .NET中的MySql.Data.dll有v2.0.V4.0.V4.5的,用哪个好?这几个有什么区别?如果我是用VS2012的话用哪个,VS2010的话用哪个,VS2013的话用哪个??本人是接触mysql没多久不是很清楚,希望哪位大神解释清楚.谢谢. 解决方案 VS2008/2005用V2.0 VS2010可以用V4.0 VS2012/2013/2

并发-请教一个mysql批量更新时的deadlock问题?

问题描述 请教一个mysql批量更新时的deadlock问题? 数据是mysql 5.6 表引擎是innoDB,DAO是mybatis3 有个表,比如是订单-物品表,里面保存每个订单的所有物品清单 字段有:record_id(记录id,自增长),order_id(订单id),good_id(物品id)等其他字段.. 有个数据同步的业务场景 需要在一个事务里 先根据order_id做删除操作,delete from xxx where order_id=xx 然后再批量增加订单-物品清单inser

批量处理-mysql 批量提交数据,在存储过程中,分别判断是更新,还是插入,怎么统计更新了多少条,插入了多少条

问题描述 mysql 批量提交数据,在存储过程中,分别判断是更新,还是插入,怎么统计更新了多少条,插入了多少条 存储过程中计数器初始设置为零,每成功一次加1, 问题是,批量处理后,计数器每次都被重置,没有实现累加 求解救 解决方案 计数写全局变量,不要用局部变量 解决方案二: 如果是用JDBC批量提交数据的话,会返回一个int值标识插入或者修改或者删除了多少条记录的. 解决方案三: 你是否定义为局部变量了,或者是你没有执行增加操作,一直是在赋值.

MySQL连接数据库时出现ArgumentNullException异常在 MySql.Data.dll 中发生

问题描述 usingSystem;usingSystem.Collections.Generic;usingSystem.Linq;usingSystem.Text;usingSystem.Threading.Tasks;usingMySql.Data.MySqlClient;usingSystem.Data;namespaceSellingSystem{classstucls{MySqlConnectiontconn=newMySqlConnection();MySqlDataAdapterm

mysql 批量更新与批量更新多条记录的不同值实现方法_Mysql

批量更新 mysql更新语句很简单,更新一条数据的某个字段,一般这样写: 复制代码 代码如下: UPDATE mytable SET myfield = 'value' WHERE other_field = 'other_value'; 如果更新同一字段为同一个值,mysql也很简单,修改下where即可: 复制代码 代码如下:  UPDATE mytable SET myfield = 'value' WHERE other_field in ('other_values');  这里注意

MyBatis魔法堂:各数据库的批量Update操作

一.前言     MyBatis的update元素的用法与insert元素基本相同,因此本篇不打算重复了.本篇仅记录批量update操作的sql语句,懂得SQL语句,那么MyBatis部分的操作就简单了. 注意:下列批量更新语句都是作为一个事务整体执行,要不全部成功,要不全部回滚.   二.MSSQL的SQL语句 WITH R AS( SELECT 'John' as name, 18 as age, 42 as id UNION ALL SELECT 'Mary' as name, 20 as

mysql 批量更新与批量更新多条记录的不同值

批量更新 mysql更新语句很简单,更新一条数据的某个字段,一般这样写:  代码如下 复制代码 UPDATE mytable SET myfield = 'value' WHERE other_field = 'other_value'; 如果更新同一字段为同一个值,mysql也很简单,修改下where即可:  代码如下 复制代码  UPDATE mytable SET myfield = 'value' WHERE other_field in ('other_values'); 这里注意 '

Mysql批量插入和更新的性能

问题描述 利用Hibernate,连接池使用的是BoneCP,做了一个MySql批量插入和批量更新的Demo,出现了下面两个问题. 1.批量插入.我采用的是原生态的JDBC,每次批量插入60条数据左右(数据量不固定),循环3000次.每次在循环到100次左右的时候,会出现"com.jolbox.bonecp.ConnectionPartition - BoneCP detected an unclosed connection and will now attempt to close it f

mysql批量更新多条记录的同一个字段为不同值的方法_Mysql

首先mysql更新数据的某个字段,一般这样写: UPDATE mytable SET myfield = 'value' WHERE other_field = 'other_value'; 也可以这样用in指定要更新的记录: UPDATE mytable SET myfield = 'value' WHERE other_field in ('other_values'); 这里注意 'other_values' 是一个逗号(,)分隔的字符串,如:1,2,3 如果更新多条数据而且每条记录要更新