|
@@ -54,7 +54,7 @@ namespace DotNetCore.CAP.SqlServer |
|
|
$@" |
|
|
$@" |
|
|
IF NOT EXISTS (SELECT * FROM sys.schemas WHERE name = '{schema}') |
|
|
IF NOT EXISTS (SELECT * FROM sys.schemas WHERE name = '{schema}') |
|
|
BEGIN |
|
|
BEGIN |
|
|
EXEC('CREATE SCHEMA {schema}') |
|
|
|
|
|
|
|
|
EXEC('CREATE SCHEMA [{schema}]') |
|
|
END; |
|
|
END; |
|
|
|
|
|
|
|
|
IF OBJECT_ID(N'[{schema}].[Queue]',N'U') IS NULL |
|
|
IF OBJECT_ID(N'[{schema}].[Queue]',N'U') IS NULL |
|
|