迁移数据到历史表SQL

有时工作需要需要把当前表的数据，移到历史表中，而历史表基本是以时间（年）为后缀来命名历史表的，如 A_2011，A_2012，在移数据时，要按数据的时间，移到不同的表中，且由于如果数据有同步。一次处理的数据不能太大。否则同步链会被Block.所以需要批理处理。

下面是一个通用的写法，可以作为参考！（这个应该是出自邹建大侠之手，因为需要写这样的处理，去找了下类似代码，找到的）

-- row batch:                100
-- row Process limit:       50000
-- data keep days:          90
-- */
CREATE PROCEDURE dbo.TransferNInvoiceToHistoryBeforeDay@FromDate char(10)
AS
SET NOCOUNT ON;-- current trancount
DECLARE@__trancount int;
SELECT@__trancount = @@TRANCOUNT;BEGIN TRYDECLARE@row_batch int,@row_limit int,@row_process int,@row_count int,@date_begin datetime,@date_end datetime;-- row batch and data keep dateSELECT@row_batch = 100,                                   -- each batch process rows@row_limit = 50000,                         -- total row process limit@date_end = @FromDate,--DATEDIFF(Day, 90, GETDATE()),  -- process top date@row_process = 0;                                              -- process rows total-- ===========================================-- get process begin date and rowsSELECT@date_begin = MIN(InvoiceDate),@row_count = COUNT(*)FROM 需要处理的当前表名   WITH(NOLOCK)WHERE InvoiceDate < @date_end;IF @row_count = 0        RETURN;ELSE IF @date_begin IS NULLBEGINRAISERROR(N'column InvoiceDate include NULL value, please fix it', 16, 1)ENDIF @row_limit IS NULL OR @row_limit <= 0SET @row_limit = @row_count;RAISERROR('%d rows need process, current process limit %d rows', 10, 1, @row_count, @row_limit) WITH NOWAIT-- ===========================================-- process by yearDECLARE@date datetime;SET @date = @date_begin;WHILE @row_process < @row_limitAND @date < @date_endBEGIN-- process date and sqlDECLARE@sql nvarchar(4000),@_date_begin datetime,@_date_end datetime;SELECT@_date_begin = @date,@_date_end = CASEWHEN DATEDIFF(Year, @_date_begin, @date_end) = 0 THEN @date_endELSE DATEADD(Year, YEAR(@_date_begin) - 1899, 0)END,@date = @_date_end,@row_count = @row_batch,@sql = N'
DECLARE @tb_id TABLE(invoiceNumber intPRIMARY KEY
);
INSERT @tb_id
SELECT TOP(@row_batch)invoiceNumber
FROM Nact.dbo.NewEgg_InvoiceMaster A
WHERE InvoiceDate >= @_date_beginAND InvoiceDate < @_date_end;DELETE A
OUTPUT deleted.*INTO 历史表名不带时间部份' + RTRIM(Year(@_date_begin)) + N'
FROM 当前表名 A,@tb_id B
WHERE A.invoiceNumber = B.invoiceNumber;
';-- ===========================================-- process by batch for yearWHILE @row_process < @row_limitAND @row_count = @row_batchBEGIN-- move dataIF @__trancount = 0BEGIN TRAN;ELSESAVE TRAN __TRAN_SavePoint;EXEC sys.sp_executesql@sql,N'@row_batch int,@_date_begin datetime,@_date_end datetime                    ',@row_batch, @_date_begin, @_date_end;SELECT@row_count = @@ROWCOUNT,@row_process = @row_process + @row_count;IF XACT_STATE() = 1 AND @__trancount = 0COMMIT;ENDENDIF @__trancount = 0BEGINIF XACT_STATE() = -1ROLLBACK TRAN;ELSEBEGIN       WHILE @@TRANCOUNT > 0COMMIT TRAN;ENDEND
END TRY
BEGIN CATCHIF XACT_STATE() <> 0BEGINIF @__trancount = 0ROLLBACK TRAN;ELSE IF XACT_STATE() = 1 AND @@TRANCOUNT > @__trancountROLLBACK TRAN __TRAN_SavePoint;ENDDECLARE@__error_number int,@__error_message nvarchar(2048),@__error_severity int,@__error_state int,@__error_line int,@__error_procedure nvarchar(126),@__user_name nvarchar(128),@__host_name nvarchar(128);SELECT@__error_number = ERROR_NUMBER(),@__error_message = ERROR_MESSAGE(),@__error_severity = ERROR_SEVERITY(),@__error_state = ERROR_STATE(),@__error_line = ERROR_LINE(),@__error_procedure = ERROR_PROCEDURE(),@__user_name = SUSER_SNAME(),@__host_name = HOST_NAME();RAISERROR(N'User: %s, Host: %s, Procedure: %s, Error %d, Level %d, State %d, Line %d, Message: %s ',@__error_severity,1,@__user_name,@__host_name,@__error_procedure,@__error_number,@__error_severity,@__error_state,@__error_line,@__error_message);
END CATCHGO

迁移数据到历史表SQL相关推荐

mysql游标表间数据迁移_MySQL存储过程--通过游标遍历和异常处理迁移数据到历史表...
-- 大表数据迁移,每天凌晨1点到5点执行,执行间隔时间10分钟,迁移旧数据到历史表.DELIMITER $$ USE `dbx`$$ DROP PROCEDURE IF EXISTS `pro_xx ...
mysql游标表间数据迁移_FalseMySQL存储过程--gt;通过游标遍历和异常处理迁移数据到历史表-mysql-第二电脑网...
-- 大表数据迁移,每天凌晨1点到5点执行,执行间隔时间10分钟,迁移旧数据到历史表.DELIMITER $$ USE `dbx`$$ 电脑技术网对<FalseMySQL存储过程-->通过 ...
mysql存储过程表迁移for_MySQL存储过程--通过游标遍历和异常处理迁移数据到历史表 (转)...
-- 大表数据迁移,每天凌晨1点到5点执行,执行间隔时间10分钟,迁移旧数据到历史表. DELIMITER $$ USE `dbx`$$ DROP PROCEDURE IF EXISTS `pro_x ...
MySQL存储过程 -- 通过游标遍历和异常处理迁移数据到历史表
-- 大表数据迁移,每天凌晨1点到5点执行,执行间隔时间10分钟,迁移旧数据到历史表. DELIMITER $$ USE `dbx`$$ DROP PROCEDURE IF EXISTS `pro_x ...
mysql 将三个月的数据导到历史表_迁移数据到历史表，减少业务表中数据压力 Mysql...
#数据迁移存储过程 DROP PROCEDURE IF EXISTS `delete_platform_patient`; DELIMITER ;; CREATE DEFINER=`root`@`%` ...
Mysql定义DELETE操作触发器，将删除数据存入历史表
Mysql定义DELETE操作触发器,将删除数据存入历史表 SQL如下: // An highlighted blockDELIMITER $$ CREATE TRIGGER <触发器名称> ...
MySql定期备份数据到历史表的解决方案
前言互联网项目最大不瓶颈还是在于数据库,80%的数据请求只针对20%的数据:特别是电商项目,体现的更为明显,大量的数据请求,即使MySql在一主多从,读写分离,使用了Elasticsearch.Me ...
mysql定时任务，把7天的数据存到历史表，再删除7天前的数据
查看mysql事件是否已开启,ON开,OFF关. SHOW VARIABLES LIKE 'event_scheduler'1:新建存储过程.use 数据库名; delimiter$$ #设置mysq ...
mysql导vertica_vertica从其他表迁移数据到新表（insertinto语句用法实例）
#例:迁移微博用户数据. 由于源表weiboFriend与目标表weiboUser的表结构不完全相同,因此在语句不但要严排列字段顺序,而且还要用缺省(如:'' 等)补齐源表中没有的字段具体SQL语句 ...

迁移数据到历史表SQL

迁移数据到历史表SQL相关推荐

最新文章

热门文章