Automatizza la query aperta in MS SQL Server
Questa tabella e l'insieme degli stored procedure (SP) consentono di automatizzare il trasferimento di dati dai database Oracle ai SQL Server.
Creazione dei moduli di query Get Open
Supponiamo che tu abbia la conoscenza e l'autorizzazione per creare tabelle, stored procedure (SP), Linked Server objects and jobs, senza questi potrebbero esserci problemi con cui non possiamo aiutarti.
Durante l'esecuzione, tendiamo a inserirlo in un database di Utilities in cui manteniamo le funzioni condivise e gli oggetti di manutenzione.
Il primo compito che abbiamo è creare una tabella principale per gestire tutto il flusso di dati, alcune delle colonne da tenere d'occhio includono:
- GetOpenQueryStream - Questo è un campo di integer che consente di elaborare insiemi di tabelle e verrà eseguito nell'ordine impostato nella colonna GetOpenQueryOrder
- GetOpenQueryName - Dovrebbe essere GetOpenQuery_Progress o GetOpenQuery_Oracle a meno che tu non abbia adattato il codice.
- GetOpenQueryLinkServ: è il nome del server collegato, che deve essere impostato in Oggetti server
- GetOpenQuerySourceSchema - È lo schema del database di origine
- GetOpenQueryDatabase, GetOpenQuerySchema, GetOpenQueryTable formano l'identificatore in tre parti per cui i dati sono impostati per essere copiati.
- È possibile aggiungere le istruzioni WHERE, INNER e TOP
- GetOpenQuerySkipCols: rimuoverà le colonne dalla tabella durante l'importazione.
Creazione di una tabella
CREATE TABLE dbo.GetOpenQuery(
GetOpenQueryID int IDENTITY(1,1) NOT NULL,GetOpenQueryStream int NULL,GetOpenQueryName nvarchar(100) NULL,GetOpenQueryLinkServ nvarchar(100) NULL,GetOpenQueryDatabase nvarchar(100) NULL,GetOpenQuerySchema nvarchar(max) NULL,GetOpenQueryTable nvarchar(100) NULL,GetOpenQueryWHERE nvarchar(1000) NULL,GetOpenQueryTOP nvarchar(100) NULL,GetOpenQuerySourceSchema nvarchar(100) NULL,GetOpenQuerySkipCols nvarchar(max) NULL,GetOpenQueryINNER nvarchar(max) NULL,GetOpenQuerySkipTruncate bit NULL DEFAULT ((0)),GetOpenQueryOrder bit NULL DEFAULT ((0)))Un hub
Gli SQL Server Jobs possono quindi essere agganciati inserendo un ID e iterare le tabelle pertinenti tramite questa stored procedure (SP). Questo itera la tabella sopra citata e attiva il codice pertinente per il server collegato Oracle o Progress.
Questo diventerà quindi l'hub da cui tutti gli altri SQL Server Jobs possono essere chiamati.
Creazione di Stored Procedure
CREATE PROC [dbo].[GetOpenQuery_Data](@Stream INT) AS BEGINDECLARE @GetOpenQueryName NVARCHAR(100),@GetOpenQueryLinkServ NVARCHAR(100),@GetOpenQueryDatabase NVARCHAR(100),@GetOpenQuerySchema NVARCHAR(MAX),@GetOpenQueryTable NVARCHAR(100),@GetOpenQueryWHERE NVARCHAR(1000),@GetOpenQueryTOP NVARCHAR(100),@SrcScheme NVARCHAR(100),@SkipCols NVARCHAR(MAX),@GetOpenQueryINNER NVARCHAR(MAX),@GetOpenQuerySkipTruncate BIT DECLARE @SQL NVARCHAR(MAX),@SQLRows BIGINT,@SQLRowCount BIGINT,@SQLOutPut NVARCHAR(100)='@SQLRows BIGINT' DECLARE C CURSOR FAST_FORWARD FORSELECTGetOpenQueryName, GetOpenQueryLinkServ, GetOpenQueryDatabase, GetOpenQuerySchema, GetOpenQueryTable,GetOpenQueryWHERE, GetOpenQueryTOP, GetOpenQuerySourceSchema, GetOpenQuerySkipCols, GetOpenQueryINNER, GetOpenQuerySkipTruncateFROM GetOpenQueryWHERE GetOpenQueryStream=@StreamORDER BY GetOpenQueryOrderOPEN CFETCH NEXT FROM CINTO @GetOpenQueryName,@GetOpenQueryLinkServ,@GetOpenQueryDatabase,@GetOpenQuerySchema,@GetOpenQueryTable,@GetOpenQueryWHERE,@GetOpenQueryTOP,@SrcScheme,@SkipCols,@GetOpenQueryINNER,@GetOpenQuerySkipTruncateWHILE @@FETCH_STATUS = 0 BEGIN BEGIN TRY SET @SQL='EXEC '+@GetOpenQueryName+' '''+ @GetOpenQueryLinkServ+''','''+ @GetOpenQueryDatabase+''','''+ @GetOpenQuerySchema+''','''+ @GetOpenQueryTable+''','+ ISNULL(NULLIF(''''+@GetOpenQueryWHERE+'''',''),'NULL')+','+ ISNULL(NULLIF(@GetOpenQueryTOP,''),'NULL')+','+ ISNULL(NULLIF(@SrcScheme,''),'NULL')+','+ ISNULL(NULLIF(''''+@SkipCols+'''',''),'NULL')+','+ ISNULL(NULLIF(''''+@GetOpenQueryINNER+'''',''),'NULL')+','+(CASE WHEN @GetOpenQuerySkipTruncate=1 THEN '1' ELSE '0' END) EXEC sp_executesql @SQL SET @SQLRows=@@ROWCOUNT SELECT @SQLRows END TRY BEGIN CATCH PRINT @GetOpenQueryLinkServ+'; Table '+@GetOpenQueryTable+' Failed' END CATCH PRINT @SQL FETCH NEXT FROM C INTO @GetOpenQueryName,@GetOpenQueryLinkServ,@GetOpenQueryDatabase,@GetOpenQuerySchema,@GetOpenQueryTable, @GetOpenQueryWHERE,@GetOpenQueryTOP,@SrcScheme,@SkipCols,@GetOpenQueryINNER,@GetOpenQuerySkipTruncateEND CLOSE C;DEALLOCATE C;ENDGO