/* Object: StoredProcedure [dbo].[CreateTable] Script Date: 2017/6/20 9:58:15 */
SET ANSI_NULLS ON
GO
SET QUOTED_IDENTIFIER ON
GO
– =============================================
– Author:
– Create date: <2017-6-20>
– Description: Nginx表自動建立並轉移已完成的資料
– =============================================
ALTER PROCEDURE [dbo].[CreateTable]
– Add the parameters for the stored procedure here

--定義日期引數，即“N”天之前的日期
@Day int

AS

IF(SELECT COUNT(0) FROM NginxLog
–WHERE IsGrab=1 AND IsRead=’2’ AND IsRanking=’1’
)>0
BEGIN

–第一部分：以NginxLog_加“N天”之前的日期，自動建立帶日期命名的表，如：NginxLog_20170614

--定義出“N天”之前的表拼接名
DECLARE @NDay VARCHAR(10)
SELECT  @NDay = CONVERT(CHAR(8),GETDATE()[email protected],112)
Declare @TableDay VARCHAR(20) = 'NginxLog_'
 
[email protected]
SELECT @TableDay

--建立日期命名的表,將要做的SQL操作全部儲存到變數
DECLARE @sql_str1 NVARCHAR(MAX)
SET @sql_str1 = N'
CREATE TABLE [dbo].['[email protected]+'](
[Id] [nvarchar](36) NOT NULL,
[Ip] [nvarchar](15) NOT NULL,
[AccessTime] [datetime] NOT NULL,
[RemoteType] [nvarchar](20) NOT NULL,
[Uri] [nvarchar](4000) NOT NULL,
[RemoteProtocol] [nvarchar](10) NOT NULL,
[ResponseState] [int] NOT NULL,
[BandWidth] [bigint] NOT NULL,
[Os] [nvarchar](2000) NOT NULL,
[HttpReferer] [nvarchar](255) NOT NULL,
[HttpType] [nvarchar](5) NOT NULL,
[ResponseTime] [float] NULL CONSTRAINT [DF_NginxLog_ResponseTime'
 
[email protected]+']  DEFAULT ((0)),
[AccessMachine] [nvarchar](15) NOT NULL CONSTRAINT [DF_NginxLog_AccessMachine'[email protected]+']  DEFAULT (NULL),
[IpProvince] [nvarchar](50) NULL,
[IpCity] [nvarchar](50) NULL,
[IsRead] [tinyint] NOT NULL CONSTRAINT [DF__NginxLog__isRead__2B3F6F97'[email protected]+']  DEFAULT ((0)),
[IsGrab] [tinyint] NOT NULL CONSTRAINT [DF_NginxLog_IsGrab'[email protected]+']  DEFAULT ((0)),
[UpstreamTime] [float] NULL CONSTRAINT [DF_NginxLog_UpstreamTime'[email protected]+']  DEFAULT ((0)),
[IsRanking] [tinyint] NOT NULL CONSTRAINT [DF__NginxLog__IsRank__5B78929E'[email protected]+']  DEFAULT ((0)),
CONSTRAINT [PK__tmp_ms_x__3214EC0724D4C13B'[email protected]+'] PRIMARY KEY CLUSTERED 
(
[Id] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
) ON [PRIMARY]'

--執行變數
EXEC (@sql_str1)

–第二部分：當資料庫的日期=N天前定義的日期，則將資料匯入到“NginxLog_日期”的表中

--定義判斷條件的日期
DECLARE @jDay CHAR(10)='0000-00-'+CAST(@Day AS CHAR(10))
SELECT @jDay

DECLARE @sql_str2 NVARCHAR(MAX)
SET @sql_str2 = N'
INSERT INTO [dbo].['[email protected]+'](
   [Id]
  ,[Ip]
  ,[AccessTime]
  ,[RemoteType]
  ,[Uri]
  ,[RemoteProtocol]
  ,[ResponseState]
  ,[BandWidth]
  ,[Os]
  ,[HttpReferer]
  ,[HttpType]
  ,[ResponseTime]
  ,[AccessMachine]
  ,[IpProvince]
  ,[IpCity]
  ,[IsRead]
  ,[IsGrab]
  ,[UpstreamTime]
  ,[IsRanking]
  )
 SELECT 
  [Id]
  ,[Ip]
  ,[AccessTime]
  ,[RemoteType]
  ,[Uri]
  ,[RemoteProtocol]
  ,[ResponseState]
  ,[BandWidth]
  ,[Os]
  ,[HttpReferer]
  ,[HttpType]
  ,[ResponseTime]
  ,[AccessMachine]
  ,[IpProvince]
  ,[IpCity]
  ,[IsRead]
  ,[IsGrab]
  ,[UpstreamTime]
  ,[IsRanking]
  FROM dbo.NginxLog WHERE CONVERT(char(10),AccessTime,120)=CONVERT(char(10),getdate()-'[email protected]+',120)'

  --執行SQL
  EXEC (@sql_str2)  

–第三部分：刪除NginxLog表中，這一天的資料
SELECT * FROM dbo.NginxLog WHERE CONVERT(char(10),AccessTime,120)=CONVERT(char(10),getdate()[email protected],120)
–DELETE FROM dbo.NginxLog WHERE CONVERT(char(10),AccessTime,120)=CONVERT(char(10),getdate()[email protected],120)
END

ELSE
PRINT ‘沒有滿足條件的表建立!’