@@ -80,35 +80,35 @@ CREATE OR ALTER PROCEDURE #create_data_sources
8080AS
8181BEGIN
8282 -- Create database master key (required for database scoped credentials used in the samples)
83- IF NOT EXISTS (SELECT * FROM sys .symmetric_keys WHERE name = ' ##MS_DatabaseMasterKey##' )
84- CREATE MASTER KEY ENCRYPTION BY PASSWORD = ' sql19bigdatacluster!' ;
83+ CREATE MASTER KEY ENCRYPTION BY PASSWORD = ' sql19bigdatacluster!' ;
8584
8685 -- Create default data sources for SQL Big Data Cluster
87- IF NOT EXISTS (SELECT * FROM sys .external_data_sources WHERE name = ' SqlDataPool' )
88- CREATE EXTERNAL DATA SOURCE SqlDataPool
89- WITH (LOCATION = ' sqldatapool://controller-svc/default' );
90-
91- IF NOT EXISTS (SELECT * FROM sys .external_data_sources WHERE name = ' SqlStoragePool' )
92- CREATE EXTERNAL DATA SOURCE SqlStoragePool
93- WITH (LOCATION = ' sqlhdfs://controller-svc/default' );
94-
95- IF NOT EXISTS (SELECT * FROM sys .external_data_sources WHERE name = ' HadoopData' )
96- CREATE EXTERNAL DATA SOURCE HadoopData
97- WITH (
98- TYPE = HADOOP ,
99- LOCATION = ' hdfs://nmnode-0-svc:9000/' ,
100- RESOURCE_MANAGER_LOCATION = ' sparkhead-svc:8032'
101- );
86+ IF SERVERPROPERTY (' ProductLevel' ) = ' RTM'
87+ CREATE EXTERNAL DATA SOURCE SqlComputePool
88+ WITH (LOCATION = ' sqlcomputepool://controller-svc/default' );
89+
90+ CREATE EXTERNAL DATA SOURCE SqlDataPool
91+ WITH (LOCATION = ' sqldatapool://controller-svc/default' );
92+
93+ CREATE EXTERNAL DATA SOURCE SqlStoragePool
94+ WITH (LOCATION = ' sqlhdfs://controller-svc/default' );
95+
96+ CREATE EXTERNAL DATA SOURCE HadoopData
97+ WITH (
98+ TYPE = HADOOP ,
99+ LOCATION = ' hdfs://nmnode-0-svc:9000/' ,
100+ RESOURCE_MANAGER_LOCATION = ' sparkhead-svc:8032'
101+ );
102102END ;
103103GO
104104
105105-- - Sample dbs:
106106DECLARE @sample_dbs CURSOR , @proc nvarchar (255 );
107107SET @sample_dbs = CURSOR FAST_FORWARD FOR
108- SELECT file_or_directory_name, d .db_name
109- FROM sys .dm_os_enumerate_filesystem (' /var/opt/mssql/data' , ' *.bak' ) as f
110- CROSS APPLY (VALUES (REPLACE (REPLACE (file_or_directory_name, ' tpcxbb_1gb' , ' sales' ), ' .bak' , ' ' ))) as d(db_name )
111- WHERE DB_ID (d .db_name ) IS NULL ;
108+ SELECT file_or_directory_name, d .db_name
109+ FROM sys .dm_os_enumerate_filesystem (' /var/opt/mssql/data' , ' *.bak' ) as f
110+ CROSS APPLY (VALUES (REPLACE (REPLACE (file_or_directory_name, ' tpcxbb_1gb' , ' sales' ), ' .bak' , ' ' ))) as d(db_name )
111+ WHERE DB_ID (d .db_name ) IS NULL ;
112112DECLARE @file nvarchar (260 ), @db_name nvarchar (128 );
113113OPEN @sample_dbs;
114114WHILE (1 = 1 )
0 commit comments