如何按月("Both" 年和月)对 Table 进行分区并自动创建每月分区?
How to Partition a Table by Month ("Both" YEAR & MONTH) and create monthly partitions automatically?
我正在尝试按 年 和 月 对 Table 进行分区。我将通过其进行分区的列是具有 ISO 格式(“20150110”、20150202 等)的日期时间类型列。
例如,我有 2010 年、2011 年、2012 年的销售数据。我希望数据按年分区,每年也按月分区。 (2010/01, 2010/02, ... 2010/12, 2011/01, ... 2015/01...)
E.X:
2010 年 1 月销售额、2010 年 2 月销售额、2011 年 1 月销售额、2011 年 2 月销售额、2012 年 12 月销售额等
我的问题是:这可能吗?如果是,我如何使用 SSIS 自动执行该过程?
SSIS 是一个 ETL(提取、转换、加载)。这不是您想要做的。
您只需要动态创建 DDL 语句即可。
我使用以下季度,但如果您愿意,它也适用于 1、2 或 X 个月。
If you want to partition the table, you first need to create the file, filegroups and partionned table and set the partitionning manually
在具有 int 标识 PK 和 datetime2 分区列的 table 上为 2015 年第一季度(第一季度之前和第二季度之后)创建 N+1 个分区。
更新它以添加月份、每月或任何您需要的...
先创建N个文件组:
Alter Database [Test] Add Filegroup [Part_Before2015]
Go
Alter Database Test Add Filegroup [Part_201501]
Go
Alter Database Test Add Filegroup [Part_201504]
Go
为每个文件组添加一个文件:
Alter Database [Test] Add FILE ( NAME = N'Part_Before2015', FILENAME = N'...\Part_Before2015.ndf' , SIZE = 5120KB , FILEGROWTH = 1024KB ) TO Filegroup [Part_Before2015]
Alter Database [Test] Add FILE ( NAME = N'Part_201501', FILENAME = N'...\Part_201501.ndf' , SIZE = 5120KB , FILEGROWTH = 1024KB ) TO Filegroup [Part_201501]
Alter Database [Test] Add FILE ( NAME = N'Part_201504', FILENAME = N'...\Part_201504.ndf' , SIZE = 5120KB , FILEGROWTH = 1024KB ) TO Filegroup [Part_201504]
在 datetime2 类型(或日期甚至日期时间)上创建分区函数:
Create Partition Function RangePartFunction (datetime2)
as Range Right For Values ('20150101', '20150401')
在每个文件组 (N+1) 上使用分区函数创建分区方案:
Create Partition Scheme RangePartScheme as Partition RangePartFunction
To ([Part_Before2015], [Part_201501], [Part_201504])
在其分区方案上创建分区 table:
Create TABLE [PartitionTable] (id int identity(0, 1) not null, date datetime2 not null, text char(8000))
On RangePartScheme (date) ;
在分区列和分区方案上添加聚集索引:
Create Clustered Index IDX_Part On dbo.PartitionTable(date)
On RangePartScheme (date);
在id栏添加PK:
Alter Table dbo.PartitionTable Add COntraint PK_Part Primary Key Nonclustered(id, date);
Build the query used to add extra file groups after the right boundary and split the last partition
- 查看分区方案扩展和分区函数拆分
- 审查使用的 DMV
查看所有这些以及如何使用它来创建动态 SQL
Declare @currentDate datetime2
Declare @endDate datetime2 = '20160701' -- new end date
Declare @dateAdd int = 3 -- Add 3 month = 1 Quarter
-- Get Current boundaries
Select @currentDate = DATEADD(MONTH, @dateAdd,Cast(MAX(value) as datetime2)) From sys.partition_range_values as r
Inner Join sys.partition_functions as f on r.function_id = f.function_id
Where f.name = 'RangePartFunction'
-- Get all quarters between max and end date
; with d(id, date, name) as (
Select 0, @currentDate, Convert(char(6), @currentDate, 112)
Union All
Select id+1, DATEADD(MONTH, @dateAdd, date), Convert(char(6), DATEADD(MONTH, @dateAdd, date), 112)
From d Where d.date <= @endDate
)
Select * From (
Select id = id*10, query = 'If Not Exists(Select 1 From sys.filegroups Where name = ''Part_'+name+''')
Begin
Print ''Create Filegroup [Part_'+name+']''
Alter Database [Test] Add Filegroup [Part_'+name+']
End
GO'
From d
Union All
Select id*10+1, 'If Not Exists(Select 1 From sys.sysfiles Where name = ''Part_'+name+''')
Begin
Print ''Create File [Part_'+name+'.ndf]''
Alter Database [Test] Add FILE ( NAME = N''Part_'+name+''', FILENAME = N''C:\DB\MSSQL11.MSSQLSERVER\MSSQL\DATA\Part_'+name+'.ndf'' , SIZE = 5120KB , FILEGROWTH = 1024KB ) TO Filegroup [Part_'+name+']
End
GO'
From d
Union All
Select id*10+2, 'Print ''Add Range [Part_'+name+']''
Alter Partition Scheme RangePartScheme Next Used [Part_'+name+']
Go'
From d
Union All
Select id*10+3, 'Print ''Split Function ['+Convert(char(8), date, 112)+']''
Alter Partition Function RangePartFunction() Split Range ('''+Convert(char(8), date, 112)+''');
Go'
From d
) as q order by id
此查询的输出是 SQL 个查询的列表,这些查询必须按 运行 的顺序排列。
Execute the dynamic SQL
- 可以手动执行(在SSMS中复制粘贴)
- 它可以在 while 循环中执行,也可以使用游标执行,游标将逐行执行输出 table(使用 sp_executesql)
Automation
- 创建执行 SQL 查询的 SQL 服务器作业:运行 用于创建动态 SQL 的查询,将其输出保存到 table 变量,然后使用 loop/cursor
执行每个语句
如果您想每月 运行 并确保始终创建接下来的 12 个月,请使用此 Set @endDate = DATEADD(MONTH, 12, getdate())
Finally
它将输出 4*N 行,用于函数的最后一个边界和@endDate 之间的 N 个缺失季度:
- 创建文件组
- 在文件组上创建文件
- 扩展分区方案的范围
- 分割分区函数的范围
您可以使用光标或 while 循环逐行 运行 它,或者您可以将它复制并粘贴到 SMSS 中。
- 它也可以通过作业自动化,即。
@endDate = DATEADD(MONTH, 3, getdate()
将创建接下来的 3 个月
- 如果您想要按月分区,请将@dateAdd 更改为 1
- 添加您自己的列或检查
Link
创建工作 = https://www.mssqltips.com/sqlservertip/3052/simple-way-to-create-a-sql-server-job-using-tsql/
sp_executesql = https://technet.microsoft.com/en-us/library/ms188001%28v=sql.110%29.aspx
While 循环 = https://dba.stackexchange.com/questions/57933/can-exec-work-with-while-loop-of-cursor
好像没有SQL服务器落后那么多,什么4-5年?很好
而且我认为您需要将 sp_executesql 和 运行 之后的查询字符串粘贴在一起
我正在尝试按 年 和 月 对 Table 进行分区。我将通过其进行分区的列是具有 ISO 格式(“20150110”、20150202 等)的日期时间类型列。
例如,我有 2010 年、2011 年、2012 年的销售数据。我希望数据按年分区,每年也按月分区。 (2010/01, 2010/02, ... 2010/12, 2011/01, ... 2015/01...)
E.X:
2010 年 1 月销售额、2010 年 2 月销售额、2011 年 1 月销售额、2011 年 2 月销售额、2012 年 12 月销售额等
我的问题是:这可能吗?如果是,我如何使用 SSIS 自动执行该过程?
SSIS 是一个 ETL(提取、转换、加载)。这不是您想要做的。 您只需要动态创建 DDL 语句即可。
我使用以下季度,但如果您愿意,它也适用于 1、2 或 X 个月。
If you want to partition the table, you first need to create the file, filegroups and partionned table and set the partitionning manually
在具有 int 标识 PK 和 datetime2 分区列的 table 上为 2015 年第一季度(第一季度之前和第二季度之后)创建 N+1 个分区。 更新它以添加月份、每月或任何您需要的...
先创建N个文件组:
Alter Database [Test] Add Filegroup [Part_Before2015] Go Alter Database Test Add Filegroup [Part_201501] Go Alter Database Test Add Filegroup [Part_201504] Go
为每个文件组添加一个文件:
Alter Database [Test] Add FILE ( NAME = N'Part_Before2015', FILENAME = N'...\Part_Before2015.ndf' , SIZE = 5120KB , FILEGROWTH = 1024KB ) TO Filegroup [Part_Before2015] Alter Database [Test] Add FILE ( NAME = N'Part_201501', FILENAME = N'...\Part_201501.ndf' , SIZE = 5120KB , FILEGROWTH = 1024KB ) TO Filegroup [Part_201501] Alter Database [Test] Add FILE ( NAME = N'Part_201504', FILENAME = N'...\Part_201504.ndf' , SIZE = 5120KB , FILEGROWTH = 1024KB ) TO Filegroup [Part_201504]
在 datetime2 类型(或日期甚至日期时间)上创建分区函数:
Create Partition Function RangePartFunction (datetime2) as Range Right For Values ('20150101', '20150401')
在每个文件组 (N+1) 上使用分区函数创建分区方案:
Create Partition Scheme RangePartScheme as Partition RangePartFunction To ([Part_Before2015], [Part_201501], [Part_201504])
在其分区方案上创建分区 table:
Create TABLE [PartitionTable] (id int identity(0, 1) not null, date datetime2 not null, text char(8000)) On RangePartScheme (date) ;
在分区列和分区方案上添加聚集索引:
Create Clustered Index IDX_Part On dbo.PartitionTable(date) On RangePartScheme (date);
在id栏添加PK:
Alter Table dbo.PartitionTable Add COntraint PK_Part Primary Key Nonclustered(id, date);
Build the query used to add extra file groups after the right boundary and split the last partition
- 查看分区方案扩展和分区函数拆分
- 审查使用的 DMV
查看所有这些以及如何使用它来创建动态 SQL
Declare @currentDate datetime2 Declare @endDate datetime2 = '20160701' -- new end date Declare @dateAdd int = 3 -- Add 3 month = 1 Quarter -- Get Current boundaries Select @currentDate = DATEADD(MONTH, @dateAdd,Cast(MAX(value) as datetime2)) From sys.partition_range_values as r Inner Join sys.partition_functions as f on r.function_id = f.function_id Where f.name = 'RangePartFunction' -- Get all quarters between max and end date ; with d(id, date, name) as ( Select 0, @currentDate, Convert(char(6), @currentDate, 112) Union All Select id+1, DATEADD(MONTH, @dateAdd, date), Convert(char(6), DATEADD(MONTH, @dateAdd, date), 112) From d Where d.date <= @endDate ) Select * From ( Select id = id*10, query = 'If Not Exists(Select 1 From sys.filegroups Where name = ''Part_'+name+''') Begin Print ''Create Filegroup [Part_'+name+']'' Alter Database [Test] Add Filegroup [Part_'+name+'] End GO' From d Union All Select id*10+1, 'If Not Exists(Select 1 From sys.sysfiles Where name = ''Part_'+name+''') Begin Print ''Create File [Part_'+name+'.ndf]'' Alter Database [Test] Add FILE ( NAME = N''Part_'+name+''', FILENAME = N''C:\DB\MSSQL11.MSSQLSERVER\MSSQL\DATA\Part_'+name+'.ndf'' , SIZE = 5120KB , FILEGROWTH = 1024KB ) TO Filegroup [Part_'+name+'] End GO' From d Union All Select id*10+2, 'Print ''Add Range [Part_'+name+']'' Alter Partition Scheme RangePartScheme Next Used [Part_'+name+'] Go' From d Union All Select id*10+3, 'Print ''Split Function ['+Convert(char(8), date, 112)+']'' Alter Partition Function RangePartFunction() Split Range ('''+Convert(char(8), date, 112)+'''); Go' From d ) as q order by id
此查询的输出是 SQL 个查询的列表,这些查询必须按 运行 的顺序排列。
Execute the dynamic SQL
- 可以手动执行(在SSMS中复制粘贴)
- 它可以在 while 循环中执行,也可以使用游标执行,游标将逐行执行输出 table(使用 sp_executesql)
Automation
- 创建执行 SQL 查询的 SQL 服务器作业:运行 用于创建动态 SQL 的查询,将其输出保存到 table 变量,然后使用 loop/cursor 执行每个语句
如果您想每月 运行 并确保始终创建接下来的 12 个月,请使用此 Set @endDate = DATEADD(MONTH, 12, getdate())
Finally
它将输出 4*N 行,用于函数的最后一个边界和@endDate 之间的 N 个缺失季度:
- 创建文件组
- 在文件组上创建文件
- 扩展分区方案的范围
- 分割分区函数的范围
您可以使用光标或 while 循环逐行 运行 它,或者您可以将它复制并粘贴到 SMSS 中。
- 它也可以通过作业自动化,即。
@endDate = DATEADD(MONTH, 3, getdate()
将创建接下来的 3 个月 - 如果您想要按月分区,请将@dateAdd 更改为 1
- 添加您自己的列或检查
Link
创建工作 = https://www.mssqltips.com/sqlservertip/3052/simple-way-to-create-a-sql-server-job-using-tsql/
sp_executesql = https://technet.microsoft.com/en-us/library/ms188001%28v=sql.110%29.aspx
While 循环 = https://dba.stackexchange.com/questions/57933/can-exec-work-with-while-loop-of-cursor
好像没有SQL服务器落后那么多,什么4-5年?很好
而且我认为您需要将 sp_executesql 和 运行 之后的查询字符串粘贴在一起