mysql数据更新（如何对MySQL数据库中的数据进行实时同步）

本文目录

• 如何对MySQL数据库中的数据进行实时同步
• 利用mysql存储过程循环插入新数据并更新
• MYSQL数据库字段内容如何批量更新

如何对MySQL数据库中的数据进行实时同步

具体操作：

1、在分析型数据库上创建目标表，数据更新类型为实时写入，字段名称和MySQL中的建议均相同；

2、在阿里云数据传输的控制台上创建数据订阅通道，并记录这个通道的ID；

3、配置dts-ads-writer/app.conf文件，配置方式如下：所有配置均保存在app.conf中，运行前请保证配置正确；修改配置后，请重启writer，基本配置：

注意事项：

1、RDSforMySQL表和分析型数据库中表的主键定义必须完全一致；如果不一致会出现数据不一致问题。如果需要调整RDS/分析型数据库表的主键，建议先停止writer进程；

2、一个插件进程中分析型数据库db只能是一个，由adsJdbcUrl指定；

3、一个插件进程只能对应一个数据订阅通道；如果更新通道中的订阅对象时，需要重启进程。

利用mysql存储过程循环插入新数据并更新

DROP PROCEDURE IF EXISTS excute_job_v340;

create procedure excute_job_v340()

begin 

        declare rdevid int; //声明参数

        declare rech_id int;

        declare slot int;

        declare new_rech_id int;

        declare new_price DOUBLE;//声明参数

        declare done INT DEFAULT FALSE;////声明结束标识参数

    --  声明游标

        DECLARE rdevrech_id CURSOR FOR

                select r.id as rdevid,r.rechargeconfig_id as rech_id,r.slot_no as slot from b_device_tbl dev

                LEFT JOIN r_device_rechargeconfig_tbl r on dev.id= r.device_id

                where dev.dev_typedef_id =7 and dev.masterid is not NULL  and r.rechargeconfig_type=4 and r.is_deleted=0 and                 r.slot_no is not  NULL;

-- 将结束标志绑定到游标

        DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;

-- 打开游标

        OPEN  rdevrech_id;   

-- 遍历

        read_loop: LOOP

-- 取值

                FETCH  NEXT from rdevrech_id INTO rdevid,rech_id,slot;

                IF done THEN

                        LEAVE read_loop;

                END IF;// 结束判断

                select price into new_price from c_device_rechargeconfig_item_tbl where rechargeconfig_id =rech_id limit 1;

                INSERT INTO `c_device_rechargeconfig_tbl` (  `type`, `style_id`, `is_default`, `dev_type_code`, `is_deleted`,                 `create_time`, `slot_no`)

                VALUES ( ’4’, NULL, ’0’, ’0’, ’0’, ’2019-08-19 15:59:24’,slot );

                select max(id) into new_rech_id from c_device_rechargeconfig_tbl ;

                INSERT INTO  `c_device_rechargeconfig_item_tbl` (  `price`, `goods`, `description`, `is_deleted`, `create_time`,                         `rechargeconfig_id` )

                        VALUES (  new_price,new_price, ’0.00’, ’0’, ’2019-08-19 15:59:24’, new_rech_id);

                update r_device_rechargeconfig_tbl set rechargeconfig_id=new_rech_id where id=rdevid;

        END LOOP;

        CLOSE rdevrech_id;

end；

call excute_job_v340() ;//调用执行

MYSQL数据库字段内容如何批量更新

MYSQL数据库字段内容批量更新：
利用sql中case when结构可以根据不同的条件批量更新，举例如下：
UPDATE order
SET display_order = CASE id
WHEN 1 THEN ’value’
WHEN 2 THEN ’value’
WHEN 3 THEN ’value’
END
WHERE id IN (1,2,3)
这句sql的意思是，更新display_order 字段，如果id=1 则display_order 的值为3，如果id=2 则 display_order 的值为4，如果id=3 则 display_order 的值为5。