SQL Server数据库文件的还原与优化

|Font Size: | No Comments | Previous

  这个数据库的文件解压后有几十个GB,分成十几个库,我是参考知乎用户的回帖中介绍的步骤一步一步做下来的,其中有几处错误做了改正。

  由于这些mdf是从SQL Server 2000上创建的,想要直接附加它们,最高可以使用SQL Server 2008 R2,如果想在SQL Server 2012或更高版本的SQL Server上使用,请参考这里的操作,我这里使用的是SQL Server 2012。

  在实际操作过程中,请根据实际情况修改路径:

一、附加数据库

  由于没有日志文件,所以采用执行SQL语句的形式附加进数据库(注意QunInfo01~QunInfo11的命名不要改)。打开Microsoft SQL Server Management Studio,菜单栏右上角找到“新建查询按钮”,打执行下面的语句:

--附加数据库(MDF文件路径可根据需要修改)
sp_attach_single_file_db @dbname= 'GroupData01',@physname= 'D:\数据库\GroupData1_Data.MDF'
go
sp_attach_single_file_db @dbname= 'GroupData02',@physname= 'D:\数据库\GroupData2_Data.MDF'
go
sp_attach_single_file_db @dbname= 'GroupData03',@physname= 'D:\数据库\GroupData3_Data.MDF'
go
sp_attach_single_file_db @dbname= 'GroupData04',@physname= 'D:\数据库\GroupData4_Data.MDF'
go
sp_attach_single_file_db @dbname= 'GroupData05',@physname= 'D:\数据库\GroupData5_Data.MDF'
go
sp_attach_single_file_db @dbname= 'GroupData06',@physname= 'D:\数据库\GroupData6_Data.MDF'
go
sp_attach_single_file_db @dbname= 'GroupData07',@physname= 'D:\数据库\GroupData7_Data.MDF'
go
sp_attach_single_file_db @dbname= 'GroupData08',@physname= 'D:\数据库\GroupData8_Data.MDF'
go
sp_attach_single_file_db @dbname= 'GroupData09',@physname= 'D:\数据库\GroupData9_Data.MDF'
go
sp_attach_single_file_db @dbname= 'GroupData10',@physname= 'D:\数据库\GroupData10_Data.MDF'
go
sp_attach_single_file_db @dbname= 'GroupData11',@physname= 'D:\数据库\GroupData11_Data.MDF'
go
sp_attach_single_file_db @dbname= 'QunInfo01',@physname= 'D:\数据库\QunInfo1_Data.MDF'
go
sp_attach_single_file_db @dbname= 'QunInfo02',@physname= 'D:\数据库\QunInfo2_Data.MDF'
go
sp_attach_single_file_db @dbname= 'QunInfo03',@physname= 'D:\数据库\QunInfo3_Data.MDF'
go
sp_attach_single_file_db @dbname= 'QunInfo04',@physname= 'D:\数据库\QunInfo4_Data.MDF'
go
sp_attach_single_file_db @dbname= 'QunInfo05',@physname= 'D:\数据库\QunInfo5_Data.MDF'
go
sp_attach_single_file_db @dbname= 'QunInfo06',@physname= 'D:\数据库\QunInfo6_Data.MDF'
go
sp_attach_single_file_db @dbname= 'QunInfo07',@physname= 'D:\数据库\QunInfo7_Data.MDF'
go
sp_attach_single_file_db @dbname= 'QunInfo08',@physname= 'D:\数据库\QunInfo8_Data.MDF'
go
sp_attach_single_file_db @dbname= 'QunInfo09',@physname= 'D:\数据库\QunInfo9_Data.MDF'
go
sp_attach_single_file_db @dbname= 'QunInfo10',@physname= 'D:\数据库\QunInfo10_Data.MDF'
go
sp_attach_single_file_db @dbname= 'QunInfo11',@physname= 'D:\数据库\QunInfo11_Data.MDF'
go

  这样,得到了22个数据库,上千张表,查询耗时长,效率低,需要做进一步优化。

二、合并数据库

  把QunInfo01~11、GroupData01~11分别合并到两个库QunInfo、GroupData,然后使用用分区表提升性能。步骤如下:

1、创建新的库用于合并

  创建一个名为QunInfo的数据库,设置数据库为简单恢复模式。mdf、ldf文件保存路径根据需要更改,脚本如下:

USE [master]
GO
CREATE DATABASE [QunInfo] ON  PRIMARY 
( NAME = N'QunInfo', FILENAME = N'D:\DATA\QunInfo.mdf' , SIZE = 5120KB , MAXSIZE = UNLIMITED, FILEGROWTH = 1024KB )
 LOG ON 
( NAME = N'QunInfo_log', FILENAME = N'D:\DATA\QunInfo_log.ldf' , SIZE = 1024KB , MAXSIZE = 2048GB , FILEGROWTH = 10%)
GO

ALTER DATABASE [QunInfo] SET COMPATIBILITY_LEVEL = 100
GO

IF (1 = FULLTEXTSERVICEPROPERTY('IsFullTextInstalled'))
begin
EXEC [QunInfo].[dbo].[sp_fulltext_database] @action = 'enable'
end
GO

ALTER DATABASE [QunInfo] SET ANSI_NULL_DEFAULT OFF 
GO

ALTER DATABASE [QunInfo] SET ANSI_NULLS OFF 
GO

ALTER DATABASE [QunInfo] SET ANSI_PADDING OFF 
GO

ALTER DATABASE [QunInfo] SET ANSI_WARNINGS OFF 
GO

ALTER DATABASE [QunInfo] SET ARITHABORT OFF 
GO

ALTER DATABASE [QunInfo] SET AUTO_CLOSE OFF 
GO

ALTER DATABASE [QunInfo] SET AUTO_CREATE_STATISTICS ON 
GO

ALTER DATABASE [QunInfo] SET AUTO_SHRINK OFF 
GO

ALTER DATABASE [QunInfo] SET AUTO_UPDATE_STATISTICS ON 
GO

ALTER DATABASE [QunInfo] SET CURSOR_CLOSE_ON_COMMIT OFF 
GO

ALTER DATABASE [QunInfo] SET CURSOR_DEFAULT  GLOBAL 
GO

ALTER DATABASE [QunInfo] SET CONCAT_NULL_YIELDS_NULL OFF 
GO

ALTER DATABASE [QunInfo] SET NUMERIC_ROUNDABORT OFF 
GO

ALTER DATABASE [QunInfo] SET QUOTED_IDENTIFIER OFF 
GO

ALTER DATABASE [QunInfo] SET RECURSIVE_TRIGGERS OFF 
GO

ALTER DATABASE [QunInfo] SET  DISABLE_BROKER 
GO

ALTER DATABASE [QunInfo] SET AUTO_UPDATE_STATISTICS_ASYNC OFF 
GO

ALTER DATABASE [QunInfo] SET DATE_CORRELATION_OPTIMIZATION OFF 
GO

ALTER DATABASE [QunInfo] SET TRUSTWORTHY OFF 
GO

ALTER DATABASE [QunInfo] SET ALLOW_SNAPSHOT_ISOLATION OFF 
GO

ALTER DATABASE [QunInfo] SET PARAMETERIZATION SIMPLE 
GO

ALTER DATABASE [QunInfo] SET READ_COMMITTED_SNAPSHOT OFF 
GO

ALTER DATABASE [QunInfo] SET HONOR_BROKER_PRIORITY OFF 
GO

ALTER DATABASE [QunInfo] SET  READ_WRITE 
GO

ALTER DATABASE [QunInfo] SET RECOVERY SIMPLE 
GO

ALTER DATABASE [QunInfo] SET  MULTI_USER 
GO

ALTER DATABASE [QunInfo] SET PAGE_VERIFY CHECKSUM  
GO

ALTER DATABASE [QunInfo] SET DB_CHAINING OFF 
GO

  创建一个名为GroupData的数据库,配置同上:

USE [master]
GO
CREATE DATABASE [GroupData] ON  PRIMARY 
( NAME = N'GroupData', FILENAME = N'D:\DATA\GroupData.mdf' , SIZE = 5120KB , MAXSIZE = UNLIMITED, FILEGROWTH = 1024KB )
 LOG ON 
( NAME = N'GroupData_log', FILENAME = N'D:\DATA\GroupData_log.ldf' , SIZE = 1024KB , MAXSIZE = 2048GB , FILEGROWTH = 10%)
GO

ALTER DATABASE [GroupData] SET COMPATIBILITY_LEVEL = 100
GO

IF (1 = FULLTEXTSERVICEPROPERTY('IsFullTextInstalled'))
begin
EXEC [GroupData].[dbo].[sp_fulltext_database] @action = 'enable'
end
GO

ALTER DATABASE [GroupData] SET ANSI_NULL_DEFAULT OFF 
GO

ALTER DATABASE [GroupData] SET ANSI_NULLS OFF 
GO

ALTER DATABASE [GroupData] SET ANSI_PADDING OFF 
GO

ALTER DATABASE [GroupData] SET ANSI_WARNINGS OFF 
GO

ALTER DATABASE [GroupData] SET ARITHABORT OFF 
GO

ALTER DATABASE [GroupData] SET AUTO_CLOSE OFF 
GO

ALTER DATABASE [GroupData] SET AUTO_CREATE_STATISTICS ON 
GO

ALTER DATABASE [GroupData] SET AUTO_SHRINK OFF 
GO

ALTER DATABASE [GroupData] SET AUTO_UPDATE_STATISTICS ON 
GO

ALTER DATABASE [GroupData] SET CURSOR_CLOSE_ON_COMMIT OFF 
GO

ALTER DATABASE [GroupData] SET CURSOR_DEFAULT  GLOBAL 
GO

ALTER DATABASE [GroupData] SET CONCAT_NULL_YIELDS_NULL OFF 
GO

ALTER DATABASE [GroupData] SET NUMERIC_ROUNDABORT OFF 
GO

ALTER DATABASE [GroupData] SET QUOTED_IDENTIFIER OFF 
GO

ALTER DATABASE [GroupData] SET RECURSIVE_TRIGGERS OFF 
GO

ALTER DATABASE [GroupData] SET  DISABLE_BROKER 
GO

ALTER DATABASE [GroupData] SET AUTO_UPDATE_STATISTICS_ASYNC OFF 
GO

ALTER DATABASE [GroupData] SET DATE_CORRELATION_OPTIMIZATION OFF 
GO

ALTER DATABASE [GroupData] SET TRUSTWORTHY OFF 
GO

ALTER DATABASE [GroupData] SET ALLOW_SNAPSHOT_ISOLATION OFF 
GO

ALTER DATABASE [GroupData] SET PARAMETERIZATION SIMPLE 
GO

ALTER DATABASE [GroupData] SET READ_COMMITTED_SNAPSHOT OFF 
GO

ALTER DATABASE [GroupData] SET HONOR_BROKER_PRIORITY OFF 
GO

ALTER DATABASE [GroupData] SET  READ_WRITE 
GO

ALTER DATABASE [GroupData] SET RECOVERY SIMPLE 
GO

ALTER DATABASE [GroupData] SET  MULTI_USER 
GO

ALTER DATABASE [GroupData] SET PAGE_VERIFY CHECKSUM  
GO

ALTER DATABASE [GroupData] SET DB_CHAINING OFF 
GO

2、统一表名

  修改各个数据库中表的名字:把QunList1统一修改为QunList01这样格式的,这样做的好处就是在合并数据的时候读取到的数据库的数据是按照顺序插入到表中的,不会造成数据页的拆分。

--格式化表名
USE QunInfo01
GO
exec sp_rename 'QunList1','QunList01'
exec sp_rename 'QunList2','QunList02'
exec sp_rename 'QunList3','QunList03'
exec sp_rename 'QunList4','QunList04'
exec sp_rename 'QunList5','QunList05'
exec sp_rename 'QunList6','QunList06'
exec sp_rename 'QunList7','QunList07'
exec sp_rename 'QunList8','QunList08'
exec sp_rename 'QunList9','QunList09'

USE GroupData01
GO
exec sp_rename 'Group1','Group01'
exec sp_rename 'Group2','Group02'
exec sp_rename 'Group3','Group03'
exec sp_rename 'Group4','Group04'
exec sp_rename 'Group5','Group05'
exec sp_rename 'Group6','Group06'
exec sp_rename 'Group7','Group07'
exec sp_rename 'Group8','Group08'
exec sp_rename 'Group9','Group09'

3、创建临时表

  在QunInfo、GroupData数据库中分别创建一个临时表:tables,用来保存所有的数据库与表的信息,提供数据库合并用。

--创建临时表
use [QunInfo]
CREATE TABLE [QunInfo].[dbo].[tables](
    [db_name] [sysname] NULL,
    [table_name] [sysname] NULL,
    [status] [bit] default 0
) ON [PRIMARY]

--生成数据库名称与表名称的对应列表
EXEC sp_MSForEachDB 'USE [?];
    --插入表信息
    INSERT INTO [QunInfo].[dbo].[tables]([table_name])
        SELECT name from [?].sys.tables where name like ''QunList%'' order by name
    --更新数据库名称
    UPDATE [QunInfo].[dbo].[tables] SET [db_name] = ''?'' WHERE [db_name] is NULL'

use [GroupData]
--创建临时表
CREATE TABLE [GroupData].[dbo].[tables](
    [db_name] [sysname] NULL,
    [table_name] [sysname] NULL,
    [status] [bit] default 0
) ON [PRIMARY]

--生成数据库名称与表名称的对应列表
EXEC sp_MSForEachDB 'USE [?];
    --插入表信息
    INSERT INTO [GroupData].[dbo].[tables]([table_name])
        SELECT name from [?].sys.tables where name like ''Group%'' order by name
    --更新数据库名称
    UPDATE [GroupData].[dbo].[tables] SET [db_name] = ''?'' WHERE [db_name] IS NULL'

4、表分区

  对大数据表分区可以加快查询速度。经过估算,QunInfo表格数据加起来近9千万行。查询的时候大多用群号字段,所以用这个群号的字段[QunNum]作为分区,每一千万做一个分区,最大的群号为100219998,这样就有11个分区。以下是分区脚本:

USE [QunInfo]
GO

--1.创建文件组
ALTER DATABASE [QunInfo]
ADD FILEGROUP [FG_QunList_QunNum_01]

ALTER DATABASE [QunInfo]
ADD FILEGROUP [FG_QunList_QunNum_02]

ALTER DATABASE [QunInfo]
ADD FILEGROUP [FG_QunList_QunNum_03]

ALTER DATABASE [QunInfo]
ADD FILEGROUP [FG_QunList_QunNum_04]

ALTER DATABASE [QunInfo]
ADD FILEGROUP [FG_QunList_QunNum_05]

ALTER DATABASE [QunInfo]
ADD FILEGROUP [FG_QunList_QunNum_06]

ALTER DATABASE [QunInfo]
ADD FILEGROUP [FG_QunList_QunNum_07]

ALTER DATABASE [QunInfo]
ADD FILEGROUP [FG_QunList_QunNum_08]

ALTER DATABASE [QunInfo]
ADD FILEGROUP [FG_QunList_QunNum_09]

ALTER DATABASE [QunInfo]
ADD FILEGROUP [FG_QunList_QunNum_10]

ALTER DATABASE [QunInfo]
ADD FILEGROUP [FG_QunList_QunNum_11]


--2.创建文件
ALTER DATABASE [QunInfo]
ADD FILE
(NAME = N'FG_QunList_QunNum_01_data',FILENAME = N'D:\数据库\FG_QunList_QunNum_01_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_QunList_QunNum_01];

ALTER DATABASE [QunInfo]
ADD FILE
(NAME = N'FG_QunList_QunNum_02_data',FILENAME = N'D:\数据库\FG_QunList_QunNum_02_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_QunList_QunNum_02];

ALTER DATABASE [QunInfo]
ADD FILE
(NAME = N'FG_QunList_QunNum_03_data',FILENAME = N'D:\数据库\FG_QunList_QunNum_03_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_QunList_QunNum_03];

ALTER DATABASE [QunInfo]
ADD FILE
(NAME = N'FG_QunList_QunNum_04_data',FILENAME = N'D:\数据库\FG_QunList_QunNum_04_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_QunList_QunNum_04];

ALTER DATABASE [QunInfo]
ADD FILE
(NAME = N'FG_QunList_QunNum_05_data',FILENAME = N'D:\数据库\FG_QunList_QunNum_05_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_QunList_QunNum_05];

ALTER DATABASE [QunInfo]
ADD FILE
(NAME = N'FG_QunList_QunNum_06_data',FILENAME = N'D:\数据库\FG_QunList_QunNum_06_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_QunList_QunNum_06];

ALTER DATABASE [QunInfo]
ADD FILE
(NAME = N'FG_QunList_QunNum_07_data',FILENAME = N'D:\数据库\FG_QunList_QunNum_07_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_QunList_QunNum_07];

ALTER DATABASE [QunInfo]
ADD FILE
(NAME = N'FG_QunList_QunNum_08_data',FILENAME = N'D:\数据库\FG_QunList_QunNum_08_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_QunList_QunNum_08];

ALTER DATABASE [QunInfo]
ADD FILE
(NAME = N'FG_QunList_QunNum_09_data',FILENAME = N'D:\数据库\FG_QunList_QunNum_09_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_QunList_QunNum_09];

ALTER DATABASE [QunInfo]
ADD FILE
(NAME = N'FG_QunList_QunNum_10_data',FILENAME = N'D:\数据库\FG_QunList_QunNum_10_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_QunList_QunNum_10];

ALTER DATABASE [QunInfo]
ADD FILE
(NAME = N'FG_QunList_QunNum_11_data',FILENAME = N'D:\数据库\FG_QunList_QunNum_11_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_QunList_QunNum_11];


--3.创建分区函数
CREATE PARTITION FUNCTION
[Fun_QunList_QunNum](INT) AS
RANGE RIGHT
FOR VALUES(10000000,20000000,30000000,40000000,50000000,60000000,70000000,80000000,90000000,100000000)


--4.创建分区方案
CREATE PARTITION SCHEME
[Sch_QunList_QunNum] AS
PARTITION [Fun_QunList_QunNum]
TO([FG_QunList_QunNum_01],[FG_QunList_QunNum_02],[FG_QunList_QunNum_03],[FG_QunList_QunNum_04],[FG_QunList_QunNum_05],[FG_QunList_QunNum_06],[FG_QunList_QunNum_07],[FG_QunList_QunNum_08],[FG_QunList_QunNum_09],[FG_QunList_QunNum_10],[FG_QunList_QunNum_11])


--5.分区函数的记录数, 执行该查询前请先执行完下一步————5、新建数据表”
SELECT $PARTITION.[Fun_QunList_QunNum](QunNum) AS Partition_num,
  MIN(QunNum) AS Min_value,MAX(QunNum) AS Max_value,COUNT(1) AS Record_num
FROM dbo.[QunList]
GROUP BY $PARTITION.[Fun_QunList_QunNum](QunNum)
ORDER BY $PARTITION.[Fun_QunList_QunNum](QunNum);

  GroupData里面的数据大概有15亿,以群号作为分区依据,每五百万为一组,可分为21个文件组:

USE [GroupData]
GO

--1.创建文件组
ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_01]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_02]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_03]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_04]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_05]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_06]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_07]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_08]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_09]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_10]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_11]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_12]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_13]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_14]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_15]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_16]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_17]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_18]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_19]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_20]

ALTER DATABASE [GroupData]
ADD FILEGROUP [FG_Group_QunNum_21]


--2.创建文件
ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_01_data',FILENAME = N'D:\数据库\FG_Group_QunNum_01_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_01];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_02_data',FILENAME = N'D:\数据库\FG_Group_QunNum_02_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_02];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_03_data',FILENAME = N'D:\数据库\FG_Group_QunNum_03_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_03];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_04_data',FILENAME = N'D:\数据库\FG_Group_QunNum_04_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_04];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_05_data',FILENAME = N'D:\数据库\FG_Group_QunNum_05_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_05];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_06_data',FILENAME = N'D:\数据库\FG_Group_QunNum_06_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_06];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_07_data',FILENAME = N'D:\数据库\FG_Group_QunNum_07_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_07];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_08_data',FILENAME = N'D:\数据库\FG_Group_QunNum_08_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_08];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_09_data',FILENAME = N'D:\数据库\FG_Group_QunNum_09_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_09];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_10_data',FILENAME = N'D:\数据库\FG_Group_QunNum_10_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_10];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_11_data',FILENAME = N'D:\数据库\FG_Group_QunNum_11_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_11];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_12_data',FILENAME = N'D:\数据库\FG_Group_QunNum_12_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_12];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_13_data',FILENAME = N'D:\数据库\FG_Group_QunNum_13_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_13];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_14_data',FILENAME = N'D:\数据库\FG_Group_QunNum_14_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_14];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_15_data',FILENAME = N'D:\数据库\FG_Group_QunNum_15_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_15];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_16_data',FILENAME = N'D:\数据库\FG_Group_QunNum_16_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_16];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_17_data',FILENAME = N'D:\数据库\FG_Group_QunNum_17_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_17];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_18_data',FILENAME = N'D:\数据库\FG_Group_QunNum_18_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_18];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_19_data',FILENAME = N'D:\数据库\FG_Group_QunNum_19_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_19];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_20_data',FILENAME = N'D:\数据库\FG_Group_QunNum_20_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_20];

ALTER DATABASE [GroupData]
ADD FILE
(NAME = N'FG_Group_QunNum_21_data',FILENAME = N'D:\数据库\FG_Group_QunNum_21_data.ndf',SIZE = 100MB, FILEGROWTH = 10MB )
TO FILEGROUP [FG_Group_QunNum_21];


--3.创建分区函数
CREATE PARTITION FUNCTION
[Fun_Group_QunNum](INT) AS
RANGE RIGHT
FOR VALUES(5000000,10000000,15000000,20000000,25000000,30000000,35000000,40000000,45000000,50000000,55000000,60000000,65000000,70000000,75000000,80000000,85000000,90000000,95000000,100000000)


--4.创建分区方案
CREATE PARTITION SCHEME
[Sch_Group_QunNum] AS
PARTITION [Fun_Group_QunNum]
TO([FG_Group_QunNum_01],[FG_Group_QunNum_02],[FG_Group_QunNum_03],[FG_Group_QunNum_04],[FG_Group_QunNum_05],[FG_Group_QunNum_06],[FG_Group_QunNum_07],[FG_Group_QunNum_08],[FG_Group_QunNum_09],[FG_Group_QunNum_10],[FG_Group_QunNum_11],[FG_Group_QunNum_12],[FG_Group_QunNum_13],[FG_Group_QunNum_14],[FG_Group_QunNum_15],[FG_Group_QunNum_16],[FG_Group_QunNum_17],[FG_Group_QunNum_18],[FG_Group_QunNum_19],[FG_Group_QunNum_20],[FG_Group_QunNum_21])


--5.分区函数的记录数, 执行该查询前请先执行完下一步————5、新建数据表”
SELECT $PARTITION.[Fun_Group_QunNum](QunNum) AS Partition_num,
  MIN(QunNum) AS Min_value,MAX(QunNum) AS Max_value,COUNT(1) AS Record_num
FROM dbo.[Group]
GROUP BY $PARTITION.[Fun_Group_QunNum](QunNum)
ORDER BY $PARTITION.[Fun_Group_QunNum](QunNum);

5、新建数据表

  在数据库[QunInfo]新建一个QunList表用于合并QunInfo01~11的所有表格,涉及内容如下:

--创建优化后的QunList表
use [QunInfo]
CREATE TABLE [dbo].[QunList](
    [QunNum] [int] NOT NULL,
    [MastQQ] [smallint] NULL,
    [CreateDate] [date] NULL,
    [Title] [varchar](22) NULL,
    [Class] [varchar](38) NULL,
    [QunText] [varchar](80) NULL,
 CONSTRAINT [PK_QunList2] PRIMARY KEY CLUSTERED 
(
    [QunNum] ASC
)WITH (PAD_INDEX  = OFF, STATISTICS_NORECOMPUTE  = OFF, IGNORE_DUP_KEY = ON, ALLOW_ROW_LOCKS  = ON, ALLOW_PAGE_LOCKS  = ON, DATA_COMPRESSION = ROW) ON [Sch_QunList_QunNum]([QunNum])
) ON [Sch_QunList_QunNum]([QunNum])
GO

  同理对GroupData进行同样的操作,新建一个Group表:

use GroupData
CREATE TABLE [dbo].[Group](
    [QunNum] [int] NOT NULL,
    [QQNum] [int] NOT NULL,
    [Nick] [varchar](20) NULL,
    [Age] [tinyint] NULL,
    [Gender] [tinyint] NULL,
    [Auth] [tinyint] NULL,
 CONSTRAINT [PK_Group] PRIMARY KEY CLUSTERED 
(
    [QunNum] ASC,
    [QQNum] ASC
)WITH (PAD_INDEX  = OFF, STATISTICS_NORECOMPUTE  = OFF, IGNORE_DUP_KEY = ON, ALLOW_ROW_LOCKS  = ON, ALLOW_PAGE_LOCKS  = ON, DATA_COMPRESSION = ROW) ON [Sch_Group_QunNum]([QunNum])
) ON [Sch_Group_QunNum]([QunNum])
GO

6、数据表合并

  把11个数据库都合并到新创建的QunInfo的QunList表中(根据电脑性能,大概要跑一两个小时。E5-2640 16核心15分钟):

--合并数据
DECLARE @tablename sysname
DECLARE @dbname sysname
DECLARE @sql NVARCHAR(max)

--游标
DECLARE @itemCur CURSOR
SET @itemCur = CURSOR FOR 
    SELECT db_name,table_name from [QunInfo].[dbo].[tables]

OPEN @itemCur
FETCH NEXT FROM @itemCur INTO @dbname,@tablename
WHILE @@FETCH_STATUS=0

BEGIN
    
    SET @sql = '
    INSERT INTO [QunInfo].[dbo].[QunList]
           ([QunNum]
           ,[MastQQ]
           ,[CreateDate]
           ,[Title]
           ,[Class]
           ,[QunText])
    SELECT [QunNum]
      ,[MastQQ]
      ,[CreateDate]
      ,[Title]
      ,[Class]
      ,[QunText]
    FROM ['+@dbname+'].[dbo].['+@tablename+']'
  
    EXEC(@sql)
    
    UPDATE [QunInfo].[dbo].[tables] SET status = 1 WHERE db_name = @dbname AND table_name = @tablename
    
    --返回SQL
    PRINT(@sql)PRINT('GO')+CHAR(13)

    FETCH NEXT FROM @itemCur INTO @dbname,@tablename
END 

CLOSE @itemCur
DEALLOCATE @itemCur


--运行插入脚本时,可以查看进度
SELECT * from [QunInfo].[dbo].[tables]

  把GroupData01~11里的数据合并到GroupData库里的Group表(大概跑几个小时。E5-2640 16核心6小时左右):

--合并数据
DECLARE @tablename sysname
DECLARE @dbname sysname
DECLARE @sql NVARCHAR(max)

--游标
DECLARE @itemCur CURSOR
SET @itemCur = CURSOR FOR 
    SELECT db_name,table_name from [GroupData].[dbo].[tables]

OPEN @itemCur
FETCH NEXT FROM @itemCur INTO @dbname,@tablename
WHILE @@FETCH_STATUS=0

BEGIN
    
    SET @sql = '
INSERT INTO [GroupData].[dbo].[Group]
           ([QunNum]
           ,[QQNum]
           ,[Nick]
           ,[Age]
           ,[Gender]
           ,[Auth])
    SELECT [QunNum]
           ,[QQNum]
           ,[Nick]
           ,[Age]
           ,[Gender]
           ,[Auth]
    FROM ['+@dbname+'].[dbo].['+@tablename+']'
  
    EXEC(@sql)
    
    UPDATE [GroupData].[dbo].[tables] SET status = 1 WHERE db_name = @dbname AND table_name = @tablename
    
    --返回SQL
    PRINT(@sql)PRINT('GO')+CHAR(13)

    FETCH NEXT FROM @itemCur INTO @dbname,@tablename
END 

CLOSE @itemCur
DEALLOCATE @itemCur

7、建立索引

  为GroupData的Group表里的QQnum新建一个索引并对索引进行压缩:

--索引行压缩
USE [GroupData]
GO
CREATE NONCLUSTERED INDEX [IX_Group_QQNum] ON [dbo].[Group] 
(
    [QQNum] ASC
)WITH (PAD_INDEX  = OFF, STATISTICS_NORECOMPUTE  = OFF, SORT_IN_TEMPDB = OFF, IGNORE_DUP_KEY = OFF, DROP_EXISTING = OFF, ONLINE = OFF, ALLOW_ROW_LOCKS  = ON, ALLOW_PAGE_LOCKS  = ON, DATA_COMPRESSION = ROW) ON [Sch_Group_QunNum]([QunNum])
GO

8、页压缩:

  对QunInfo进行页压缩:

--索引页压缩
USE [QunInfo]
GO
ALTER TABLE [QunList]  
REBUILD WITH (DATA_COMPRESSION = PAGE );

  对GroupData进行页压缩:

--索引页压缩
USE [GroupData]
GO
CREATE NONCLUSTERED INDEX [IX_Group_QQNum] ON [dbo].[Group] 
(
    [QQNum] ASC
)WITH (PAD_INDEX  = OFF, STATISTICS_NORECOMPUTE  = OFF, SORT_IN_TEMPDB = OFF, IGNORE_DUP_KEY = OFF, DROP_EXISTING = OFF, ONLINE = OFF, ALLOW_ROW_LOCKS  = ON, ALLOW_PAGE_LOCKS  = ON, DATA_COMPRESSION = PAGE) ON [Sch_Group_QunNum]([QunNum])
GO

9、查看压缩结果:

Use [QunInfo] 
EXEC sp_spaceused [QunList]  
Use [GroupData] 
EXEC sp_spaceused [Group]  

  看看每个分区的数据:

SELECT 
    partition = $PARTITION.Fun_QunList_QunNum([QunNum])
    ,rows      = COUNT(*)
    ,min    = MIN([QunNum])
    ,max    = MAX([QunNum])
FROM [dbo].[QunList]
GROUP BY $PARTITION.Fun_QunList_QunNum([QunNum])
ORDER BY PARTITION

10、存储过程

作者:知乎用户
链接:https://www.zhihu.com/question/50751728/answer/123633989
来源:知乎
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。

USE [master]
GO
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
CREATE PROCEDURE [dbo].[Qun]    
   (    
       @QunNum int
     )    
    AS    
SELECT  a.[QunNum]
      ,[QQNum]
      ,[Nick]
      ,[Age]
      ,(case when [Gender]=0 then '男' else '女' end) 性别
      ,(case when [Auth]=1 then '成员' when [Auth]=4 then '群主' when [Auth]=2 then '管理' end) 身份
      ,[MastQQ]
      ,[CreateDate]
      ,[Title]
      ,[Class]
      ,[QunText]
  FROM [GroupData].[dbo].[Group] a
  left join [QunInfo].[dbo].[QunList] b
  on a.[QunNum]=b.QunNum
  where  a.[QunNum]=@QunNum order by [Auth] desc
GO

use QunInfo
GO
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
CREATE PROCEDURE [dbo].[Qun]    
   (    
       @QunNum int
     )    
    AS    
SELECT  a.[QunNum]
      ,[QQNum]
      ,[Nick]
      ,[Age]
      ,(case when [Gender]=0 then '男' else '女' end) 性别
      ,(case when [Auth]=1 then '成员' when [Auth]=4 then '群主' when [Auth]=2 then '管理' end) 身份
      ,[MastQQ]
      ,[CreateDate]
      ,[Title]
      ,[Class]
      ,[QunText]
  FROM [GroupData].[dbo].[Group] a
  left join [QunInfo].[dbo].[QunList] b
  on a.[QunNum]=b.QunNum
  where  a.[QunNum]=@QunNum order by [Auth] desc
GO

use GroupData
GO
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
CREATE PROCEDURE [dbo].[Qun]    
   (    
       @QunNum int
     )    
    AS    
SELECT  a.[QunNum]
      ,[QQNum]
      ,[Nick]
      ,[Age]
      ,(case when [Gender]=0 then '男' else '女' end) 性别
      ,(case when [Auth]=1 then '成员' when [Auth]=4 then '群主' when [Auth]=2 then '管理' end) 身份
      ,[MastQQ]
      ,[CreateDate]
      ,[Title]
      ,[Class]
      ,[QunText]
  FROM [GroupData].[dbo].[Group] a
  left join [QunInfo].[dbo].[QunList] b
  on a.[QunNum]=b.QunNum
  where  a.[QunNum]=@QunNum order by [Auth] desc
GO
USE [master]
GO
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
CREATE PROCEDURE [dbo].[QQ]    
   (    
       @QQNum int
     )    
    AS    
SELECT  a.[QunNum] 群号码
	  ,[Title] 群名
      ,[QQNum] QQ号码
      ,[Nick] 昵称
      ,[Age]
      ,(case when [Gender]=0 then '男' else '女' end) 性别
      ,(case when [Auth]=1 then '成员' when [Auth]=4 then '群主' when [Auth]=2 then '管理' end) 身份
      ,[MastQQ]
      ,[CreateDate]
      ,[QunText]
  FROM [GroupData].[dbo].[Group] a
  left join [QunInfo].[dbo].[QunList] b
  on a.[QunNum]=b.QunNum
  where  [QQNum]=@QQNum order by CreateDate
GO
USE [QunInfo]
GO
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
CREATE PROCEDURE [dbo].[QQ]    
   (    
       @QQNum int
     )    
    AS    
SELECT  a.[QunNum] 群号码
	  ,[Title] 群名
      ,[QQNum] QQ号码
      ,[Nick] 昵称
      ,[Age]
      ,(case when [Gender]=0 then '男' else '女' end) 性别
      ,(case when [Auth]=1 then '成员' when [Auth]=4 then '群主' when [Auth]=2 then '管理' end) 身份
      ,[MastQQ]
      ,[CreateDate]
      ,[QunText]
  FROM [GroupData].[dbo].[Group] a
  left join [QunInfo].[dbo].[QunList] b
  on a.[QunNum]=b.QunNum
  where  [QQNum]=@QQNum order by CreateDate
GO
USE GroupData
GO
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
CREATE PROCEDURE [dbo].[QQ]    
   (    
       @QQNum int
     )    
    AS    
SELECT  a.[QunNum] 群号码
	  ,[Title] 群名
      ,[QQNum] QQ号码
      ,[Nick] 昵称
      ,[Age]
      ,(case when [Gender]=0 then '男' else '女' end) 性别
      ,(case when [Auth]=1 then '成员' when [Auth]=4 then '群主' when [Auth]=2 then '管理' end) 身份
      ,[MastQQ]
      ,[CreateDate]
      ,[QunText]
  FROM [GroupData].[dbo].[Group] a
  left join [QunInfo].[dbo].[QunList] b
  on a.[QunNum]=b.QunNum
  where  [QQNum]=@QQNum order by CreateDate
GO

  创建完存储过程之后,查询起来就很方便了:exec dbo.Qun [群号码] 或者exec dbo.QQ [QQ号码]。最后可以删除QunInfo01~11、GroupData01~11这22个库了,只留下QunInfo库和GroupData库。

  感谢原文作者提供这么详尽的使用方法。

本文结束。

Leave a comment