MySQL存储过程跨数据库操作同步数据
2011-10-13 15:58
946 查看
BEGIN DECLARE deliverstatus,smlen,datacoding,total int; DECLARE tsid,srcaddr,destaddr,servicetype,smcontent,linkid,sequenceno,recvtime,state,resulttime,extcode,applicationid varchar(50) ; set total = 0; while total < 20 do set tsid=''; select deliver_status,sm_len,data_coding,to_sp_id,src_addr,dest_addr,service_type,sm_content,link_id,sequence_no,recv_time,state,result_time,extcode_,applicationid_ into deliverstatus,smlen,datacoding,tsid,srcaddr,destaddr,servicetype,smcontent,linkid,sequenceno,recvtime,state,resulttime,extcode,applicationid from tlc_to_sp where applicationid_ = 'sms_db' limit 0,1; if tsid <> '' then if resulttime <> '' and recvtime <> '' then insert into kingterdb.sms_inbox(MASSMSID,SOURCEADDR,RECEIVETIME,MESSAGECONTENT,REQUESTTIME,extcode,applicationid) values(tsid,srcaddr,resulttime,smcontent,recvtime,extcode,applicationid); elseif resulttime = '' then insert into kingterdb.sms_inbox(MASSMSID,SOURCEADDR,RECEIVETIME,MESSAGECONTENT,REQUESTTIME,extcode,applicationid) values(tsid,srcaddr,now(),smcontent,recvtime,extcode,applicationid); elseif recvtime = '' then insert into kingterdb.sms_inbox(MASSMSID,SOURCEADDR,RECEIVETIME,MESSAGECONTENT,REQUESTTIME,extcode,applicationid) values(tsid,srcaddr,resulttime,smcontent,now(),extcode,applicationid); else insert into kingterdb.sms_inbox(MASSMSID,SOURCEADDR,RECEIVETIME,MESSAGECONTENT,REQUESTTIME,extcode,applicationid) values(tsid,srcaddr,now(),smcontent,now(),extcode,applicationid); end if; insert into tlc_to_sp_his(deliver_status,sm_len,data_coding,to_sp_id,src_addr,dest_addr,service_type,sm_content,link_id,sequence_no,recv_time,state,result_time,extcode_,applicationid_) values(deliverstatus,smlen,datacoding,tsid,srcaddr,destaddr,servicetype,smcontent,linkid,sequenceno,recvtime,state,resulttime,extcode,applicationid); end if; delete from tlc_to_sp where to_sp_id in(select to_sp_id from tlc_to_sp_his where applicationid_ = 'sms_db'); set total = total + 1; end while; END此存储过程在newppp数据库中插入数据到kingterdb数据库的表中。
相关文章推荐
- 【转】MYSQL 存储过程定时操作数据库
- mysql利用存储过程实现对数据库数据的迁移
- MySQL的存储过程的参数不能与操作的数据库表的字段相同,而且还是不区分大小写的。
- mysql 存储过程一个简单的循环遍历操作数据
- mysql存储过程使用CURSOR操作多列数据实用案例
- sqlserver中不同服务器的数据库数据同步存储过程
- MySQL存储过程详解 mysql 存储过程mysql存储过程详解 1. 存储过程简介 我们常用的操作数据库语言SQL语句在执行的时候需要要先编译,然后执行,而存储过程(Stored
- php在执行mysql存储过程后执行其他数据库操作问题解决方法
- 操作大文本数据存储在数据库中 mysql中有个lob
- 数据库操作_连接SQL Server数据库示例;连接ACCESS数据库;连接到 Oracle 数据库示例;SqlCommand 执行SQL命令示例;SqlDataReader 读取数据示例;使用DataAdapter填充数据到DataSet;使用DataTable存储数据库表;将数据库数据填充到 XML 文件;10 使用带输入参数的存储过程;11 使用带输入、输出参数的存储过程示;12 获得数据库中表的数目和名称;13 保存图片到SQL Server数据库示例;14 获得插入记录标识号;Exce
- mysql存储过程对900w数据进行操作测试
- 一个MySQL清除数据库所有表数据保留表结构的存储过程
- Mysql_知识总结03(级联操作+多表查询【左外连接查询*重点掌握】+数据库的存储过程)
- php操作mysql两个数据库中表的数据同步
- JSP数据库操作例程-存储过程
- 数据库学习篇之数据存储引擎(mysql)
- MySQL快速插入大批量数据存储过程
- 【Mysql之自我练习<一>】利用存储过程,造大量测试数据(注:私用的,为了不遗失)
- MySQL中的数据库和数据表的操作
- 利用存储过程来消除数据库中冗余的数据