forked from pjvds/ncqrs
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Updated table creation script for SQL Server to allow tables to be cr…
…eated in a schema other than 'dbo'.
- Loading branch information
1 parent
3e91a96
commit 4b7cbed
Showing
1 changed file
with
112 additions
and
58 deletions.
There are no files selected for viewing
170 changes: 112 additions & 58 deletions
170
Framework/src/Ncqrs/Eventing/Storage/SQL/TableCreationScript.sql
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,58 +1,112 @@ | ||
| IF EXISTS(SELECT * FROM sysobjects WHERE name='Events' AND xtype = 'U') RETURN; | ||
|
|
||
| CREATE TABLE [dbo].[Events]( | ||
| [SequentialId] [int] IDENTITY(1,1) NOT NULL, | ||
| [Id] [uniqueidentifier] NOT NULL, | ||
| [TimeStamp] [datetime] NOT NULL, | ||
| [Name] [varchar](max) NOT NULL, | ||
| [Version] [varchar](max) NOT NULL, | ||
| [EventSourceId] [uniqueidentifier] NOT NULL, | ||
| [Sequence] [bigint] NULL, | ||
| [Data] [nvarchar](max) NOT NULL, | ||
| CONSTRAINT [PK_Events] PRIMARY KEY CLUSTERED | ||
| ( | ||
| [SequentialId] ASC | ||
| ) | ||
| WITH | ||
| ( | ||
| PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, | ||
| IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, | ||
| ALLOW_PAGE_LOCKS = ON | ||
| ) | ||
| ) ON [PRIMARY] | ||
|
|
||
| CREATE NONCLUSTERED INDEX IX_EventSourceId ON [dbo].[Events] (EventSourceId) | ||
|
|
||
| CREATE TABLE [dbo].[EventSources] | ||
| ( | ||
| [Id] [uniqueidentifier] NOT NULL, [Type] [nvarchar](255) NOT NULL, [Version] [int] NOT NULL | ||
| ) ON [PRIMARY] | ||
|
|
||
|
|
||
| CREATE UNIQUE NONCLUSTERED INDEX [IX_Id] ON [dbo].[EventSources] | ||
| ( | ||
| [Id] 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) ON [PRIMARY] | ||
|
|
||
| CREATE TABLE [dbo].[Snapshots] | ||
| ( | ||
| [EventSourceId] [uniqueidentifier] NOT NULL, [Version] [bigint], [TimeStamp] [datetime] NOT NULL, | ||
| [Type] varchar(255) NOT NULL, [Data] [varbinary](max) NOT NULL | ||
| ) ON [PRIMARY] | ||
|
|
||
|
|
||
| CREATE TABLE [dbo].[PipelineState]( | ||
| [BatchId] [int] IDENTITY(1,1) NOT NULL, | ||
| [PipelineName] [varchar](255) NOT NULL, | ||
| [LastProcessedEventId] [uniqueidentifier] NOT NULL, | ||
| CONSTRAINT [PK_MainPipelineState] PRIMARY KEY CLUSTERED | ||
| ( | ||
| [BatchId] ASC | ||
| ) | ||
| WITH | ||
| ( | ||
| PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, | ||
| IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, | ||
| ALLOW_PAGE_LOCKS = ON | ||
| ) | ||
| ) ON [PRIMARY] | ||
| IF EXISTS(SELECT * FROM sysobjects WHERE xtype = 'U' AND name = 'Events') | ||
| BEGIN | ||
| PRINT 'The Events table already exists.' | ||
| END | ||
| ELSE | ||
| BEGIN | ||
| CREATE TABLE [Events] | ||
| ( | ||
| [SequentialId] [int] IDENTITY(1,1) NOT NULL, | ||
| [Id] [uniqueidentifier] NOT NULL, | ||
| [TimeStamp] [datetime] NOT NULL, | ||
| [Name] [varchar](max) NOT NULL, | ||
| [Version] [varchar](max) NOT NULL, | ||
| [EventSourceId] [uniqueidentifier] NOT NULL, | ||
| [Sequence] [bigint] NULL, | ||
| [Data] [nvarchar](max) NOT NULL, | ||
| CONSTRAINT [PK_Events] PRIMARY KEY CLUSTERED | ||
| ( | ||
| [SequentialId] ASC | ||
| ) | ||
| WITH | ||
| ( | ||
| PAD_INDEX = OFF, | ||
| STATISTICS_NORECOMPUTE = OFF, | ||
| IGNORE_DUP_KEY = OFF, | ||
| ALLOW_ROW_LOCKS = ON, | ||
| ALLOW_PAGE_LOCKS = ON | ||
| ) | ||
| ) ON [PRIMARY] | ||
|
|
||
| CREATE NONCLUSTERED INDEX IX_EventSourceId ON [Events] (EventSourceId) | ||
|
|
||
| PRINT 'The Events table was created.' | ||
| END; | ||
|
|
||
| IF EXISTS(SELECT * FROM sysobjects WHERE xtype = 'U' AND name = 'EventSources') | ||
| BEGIN | ||
| PRINT 'The EventSources table already exists.' | ||
| END | ||
| ELSE | ||
| BEGIN | ||
| CREATE TABLE [EventSources] | ||
| ( | ||
| [Id] [uniqueidentifier] NOT NULL, | ||
| [Type] [nvarchar](255) NOT NULL, | ||
| [Version] [int] NOT NULL | ||
| ) ON [PRIMARY] | ||
|
|
||
| CREATE UNIQUE NONCLUSTERED INDEX [IX_Id] ON [EventSources] | ||
| ( | ||
| [Id] 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 | ||
| ) ON [PRIMARY] | ||
|
|
||
| PRINT 'The EventSuorces table was created.' | ||
| END | ||
|
|
||
| IF EXISTS(SELECT * FROM sysobjects WHERE xtype = 'U' AND name = 'Snapshots') | ||
| BEGIN | ||
| PRINT 'The Snapshots table already exists.' | ||
| END | ||
| ELSE | ||
| BEGIN | ||
| CREATE TABLE [Snapshots] | ||
| ( | ||
| [EventSourceId] [uniqueidentifier] NOT NULL, | ||
| [Version] [bigint] NULL, | ||
| [TimeStamp] [datetime] NOT NULL, | ||
| [Type] varchar(255) NOT NULL, | ||
| [Data] [varbinary](max) NOT NULL | ||
| ) ON [PRIMARY] | ||
|
|
||
| PRINT 'The Snapshots table was created.' | ||
| END | ||
|
|
||
| IF EXISTS(SELECT * FROM sysobjects WHERE xtype = 'U' AND name = 'PipelineState') | ||
| BEGIN | ||
| PRINT 'The PipelineState table already exists.' | ||
| END | ||
| ELSE | ||
| BEGIN | ||
| CREATE TABLE [PipelineState] | ||
| ( | ||
| [BatchId] [int] IDENTITY(1,1) NOT NULL, | ||
| [PipelineName] [varchar](255) NOT NULL, | ||
| [LastProcessedEventId] [uniqueidentifier] NOT NULL, | ||
| CONSTRAINT [PK_MainPipelineState] PRIMARY KEY CLUSTERED | ||
| ( | ||
| [BatchId] ASC | ||
| ) | ||
| WITH | ||
| ( | ||
| PAD_INDEX = OFF, | ||
| STATISTICS_NORECOMPUTE = OFF, | ||
| IGNORE_DUP_KEY = OFF, | ||
| ALLOW_ROW_LOCKS = ON, | ||
| ALLOW_PAGE_LOCKS = ON | ||
| ) | ||
| ) ON [PRIMARY] | ||
|
|
||
| PRINT 'The PipelineState table was created.' | ||
| END |