Structure Overhaul

Code/MetadataDB/dbo/Stored Procedures/GetBucketContents.sql

@@ -0,0 +1,16 @@
+CREATE PROCEDURE [dbo].[GetBucketContents]
+	(
+	@BucketId INT
+	)
+AS
+
+BEGIN
+	SELECT 
+		p.*
+	FROM 
+		[dbo].[BucketToProcessMap] m
+		INNER JOIN [dbo].[BucketProcesses] p
+			ON m.[ProcessId] = p.[ProcessId]
+	WHERE
+		m.[BucketId] = @BucketId
+END

Code/MetadataDB/dbo/Stored Procedures/GetBuckets.sql

@@ -0,0 +1,6 @@
+CREATE PROCEDURE [dbo].[GetBuckets]
+AS
+
+BEGIN
+	SELECT [BucketId] FROM [dbo].[Buckets] WHERE [Enabled] = 1
+END

Code/MetadataDB/dbo/Stored Procedures/LogUploadFinish.sql

@@ -0,0 +1,15 @@
+CREATE PROCEDURE [LogUploadFinish]
+	(
+	@LogId INT
+	)
+AS
+BEGIN
+
+	UPDATE
+		[dbo].[UploadLog]
+	SET
+		[UploadEndDateTime] = GETDATE()
+	WHERE
+		[LogId] = @LogId;
+
+END;

Code/MetadataDB/dbo/Stored Procedures/LogUploadStart.sql

@@ -0,0 +1,27 @@
+CREATE PROCEDURE [LogUploadStart]
+	(
+	@FileCount INT,
+	@TriggerId VARCHAR(36)
+	)
+AS
+BEGIN
+
+	SET NOCOUNT ON;
+
+	INSERT INTO [dbo].[UploadLog]
+		(
+		[UploadStartDateTime],
+		[FileUploadCount],
+		[TriggerId]
+		)
+	VALUES
+		(
+		GETDATE(),
+		@FileCount,
+		@TriggerId
+		)
+
+	SELECT
+		SCOPE_IDENTITY() AS LogId
+
+END;

Code/MetadataDB/dbo/Stored Procedures/SetBucketLogEntry.sql

@@ -0,0 +1,29 @@
+CREATE   PROCEDURE [dbo].[SetBucketLogEntry]
+	(
+	@LogId INT = NULL
+	)
+AS
+
+BEGIN
+
+	IF @LogId IS NULL
+	BEGIN
+
+		TRUNCATE TABLE [dbo].[DataDump]
+		TRUNCATE TABLE [dbo].[BucketLog]
+
+		INSERT INTO [dbo].[BucketLog] ([LogStartDate], [LogDetail]) VALUES (GETDATE(), 'Running Scale Demo')
+
+		SELECT SCOPE_IDENTITY() AS 'LogId'
+
+	END
+	ELSE
+	BEGIN
+		UPDATE
+			[dbo].[BucketLog]
+		SET
+			[LogEndDate] = GETDATE()
+		WHERE
+			[LogId] = @LogId
+	END
+END

Code/MetadataDB/dbo/Stored Procedures/SetBucketProcesses.sql

@@ -0,0 +1,44 @@
+
+CREATE   PROCEDURE [dbo].[SetBucketProcesses]
+	(
+	@DebugMode BIT = 0
+	)
+AS
+
+BEGIN
+	
+	DELETE FROM [dbo].[BucketToProcessMap] 
+
+	;WITH maxBuckets AS
+		(
+		SELECT MAX([BucketId]) AS 'MaxBucket' FROM [dbo].[Buckets]
+		)
+
+	INSERT INTO [dbo].[BucketToProcessMap] 
+	SELECT
+		CASE
+			WHEN (ROW_NUMBER() OVER (ORDER BY p.[Duration] DESC) * 1) % maxBuckets.[MaxBucket] = 0 THEN maxBuckets.[MaxBucket]
+			ELSE (ROW_NUMBER() OVER (ORDER BY p.[Duration] DESC) * 1) % maxBuckets.[MaxBucket]
+		END AS 'NewBucketId',
+		p.[ProcessId]
+	FROM 
+		[dbo].[BucketProcesses] p
+		CROSS JOIN maxBuckets
+
+	IF @DebugMode = 1
+	BEGIN
+		;WITH maxBuckets AS
+			(
+			SELECT MAX([BucketId]) AS 'MaxBucket' FROM [dbo].[Buckets]
+			)
+		SELECT
+			CASE
+				WHEN (ROW_NUMBER() OVER (ORDER BY p.[Duration] DESC) * 1) % maxBuckets.[MaxBucket] = 0 THEN maxBuckets.[MaxBucket]
+				ELSE (ROW_NUMBER() OVER (ORDER BY p.[Duration] DESC) * 1) % maxBuckets.[MaxBucket]
+			END AS 'NewBucketId',
+			p.*
+		FROM 
+			[dbo].[BucketProcesses] p
+			CROSS JOIN maxBuckets
+	END
+END

Code/MetadataDB/dbo/Tables/BucketLog.sql

@@ -0,0 +1,8 @@
+CREATE TABLE [dbo].[BucketLog] (
+    [LogId]        INT          IDENTITY (1, 1) NOT NULL,
+    [LogStartDate] DATETIME     NOT NULL,
+    [LogEndDate]   DATETIME     NULL,
+    [LogDetail]    VARCHAR (50) NULL,
+    CONSTRAINT [PK_BucketLog] PRIMARY KEY CLUSTERED ([LogId] ASC)
+);
+

Code/MetadataDB/dbo/Tables/BucketProcesses.sql

@@ -0,0 +1,12 @@
+CREATE TABLE [dbo].[BucketProcesses] (
+    [ProcessId]        INT            IDENTITY (1, 1) NOT NULL,
+    [ProcessName]      VARCHAR (50)   NOT NULL,
+    [ProcessDetails]   VARCHAR (500)  NULL,
+    [ObjectName]       NVARCHAR (128) NOT NULL,
+    [ObjectParameters] NVARCHAR (500) NULL,
+    [Duration]         INT            CONSTRAINT [DF_BProcesses_Duration] DEFAULT ((0)) NOT NULL,
+    [LastUpdated]      DATETIME       CONSTRAINT [DF_BProcesses_LastUpdated] DEFAULT (getdate()) NOT NULL,
+    [Enabled]          BIT            CONSTRAINT [DF_BProcesses_Enabled] DEFAULT ((1)) NOT NULL,
+    CONSTRAINT [PK_BProcesses] PRIMARY KEY CLUSTERED ([ProcessId] ASC)
+);
+

Code/MetadataDB/dbo/Tables/BucketToProcessMap.sql

@@ -0,0 +1,8 @@
+CREATE TABLE [dbo].[BucketToProcessMap] (
+    [BucketId]  INT NOT NULL,
+    [ProcessId] INT NOT NULL,
+    CONSTRAINT [PK_BucketToProcessMap] PRIMARY KEY CLUSTERED ([BucketId] ASC, [ProcessId] ASC),
+    CONSTRAINT [FK_BucketToProcessMap_BucketProcesses] FOREIGN KEY ([ProcessId]) REFERENCES [dbo].[BucketProcesses] ([ProcessId]),
+    CONSTRAINT [FK_BucketToProcessMap_Buckets] FOREIGN KEY ([BucketId]) REFERENCES [dbo].[Buckets] ([BucketId])
+);
+

Code/MetadataDB/dbo/Tables/Buckets.sql

@@ -0,0 +1,8 @@
+CREATE TABLE [dbo].[Buckets] (
+    [BucketId]   INT           IDENTITY (1, 1) NOT NULL,
+    [BucketCode] VARCHAR (50)  NOT NULL,
+    [Details]    VARCHAR (500) NULL,
+    [Enabled]    BIT           CONSTRAINT [DF_Buckets_Enabled] DEFAULT ((1)) NOT NULL,
+    CONSTRAINT [PK_Buckets] PRIMARY KEY CLUSTERED ([BucketId] ASC)
+);
+

Code/MetadataDB/dbo/Tables/DataDump.sql

@@ -0,0 +1,4 @@
+CREATE TABLE [dbo].[DataDump] (
+    [SomeValue] NVARCHAR (50) NOT NULL
+);
+

Code/MetadataDB/dbo/Tables/FileToUpload.sql

@@ -0,0 +1,7 @@
+CREATE TABLE [dbo].[FilesToUpload]
+	(
+	[SourceDirectory] [NVARCHAR](MAX) NOT NULL,
+	[TargetDirectory] [NVARCHAR](MAX) NULL,
+	[FileName] [NVARCHAR](255) NOT NULL,
+	[Enabled] BIT NOT NULL
+	)

Code/MetadataDB/dbo/Tables/UploadLog.sql

@@ -0,0 +1,9 @@
+CREATE TABLE [dbo].[UploadLog]
+	(
+	[LogId] [INT] IDENTITY(1,1) NOT NULL,
+	[UploadStartDateTime] [DATETIME] NOT NULL,
+	[UploadEndDateTime] [DATETIME] NULL,
+	[FileUploadCount] [INT] NULL,
+	[TriggerId] [VARCHAR](36) NULL,
+	CONSTRAINT [PK_UploadLog] PRIMARY KEY CLUSTERED ([LogId] ASC)
+	)