PolyBase accede e combina i dati non relazionali e relazionali, il tutto dall'interno di SQL Server. A partire da SQL Server 2019, PolyBase supporta i dati dai back-end per i quali è disponibile un driver ODBC.
Abbiamo provato PolyBase con il nostro driver ODBC Salesforce, per interrogare i dati Salesforce da SQL Server 2019.
Per iniziare:
- Installare e concedere in licenza il driver ODBC Salesforce.com sulla macchina in cui è installato SQL Server.
È necessaria la build 2.0.3 del driver ODBC di Salesforce.com, attualmente disponibile contattando il team di supporto Easysoft ().
- In Microsoft SQL Server Management Studio, connettiti all'istanza di SQL Server abilitata per PolyBase. Per verificare se PolyBase è installato, esegui questa query:
SELECT SERVERPROPERTY ('IsPolyBaseInstalled') AS IsPolyBaseInstalled;
Se PolyBase è installato, questa query restituirà:
1
- Devi anche assicurarti che PolyBase sia abilitato:
EXEC SP_CONFIGURE @CONFIGNAME = 'polybase enabled', @CONFIGVALUE = 1; RECONFIGURE WITH OVERRIDE;
- Se non l'hai già fatto, avvia i servizi PolyBase (SQL Server PolyBase Engine, SQL Server PolyBase Data Movement) nell'applicazione Servizi Windows.
- Crea un'origine dati esterna PolyBase:
CREATE DATABASE PolyBaseDB USE PolyBaseDB CREATE MASTER KEY ENCRYPTION BY PASSWORD = 'p455w0rd'; CREATE DATABASE SCOPED CREDENTIAL PolyBaseSalesforce WITH IDENTITY = 'myuser, Secret = 'p455w0rd'; CREATE EXTERNAL DATA SOURCE salesforce_data_source WITH ( LOCATION = 'odbc://Salesforce', CONNECTION_OPTIONS = 'DRIVER={Easysoft Salesforce ODBC Driver}; UID=mysalesforceuser@mydomain; PWD=mypassword;TOKEN=1234ABCDEF;', CREDENTIAL = PolyBaseSalesforce );
- Crea una tabella SQL Server locale che conterrà i dati Salesforce remoti. Questa tabella locale è per la tabella Account Salesforce:
CREATE EXTERNAL TABLE Account([Id] NCHAR(18) COLLATE Latin1_General_CI_AS NOT NULL, [IsDeleted] TINYINT NOT NULL, [MasterRecordId] NCHAR(18) COLLATE Latin1_General_CI_AS, [Name] NVARCHAR(255) COLLATE Latin1_General_CI_AS NOT NULL, [Type] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [ParentId] NCHAR(18) COLLATE Latin1_General_CI_AS, [BillingStreet] NVARCHAR(4000) COLLATE Latin1_General_CI_AS, [BillingCity] NVARCHAR(40) COLLATE Latin1_General_CI_AS, [BillingState] NVARCHAR(80) COLLATE Latin1_General_CI_AS, [BillingPostalCode] NVARCHAR(20) COLLATE Latin1_General_CI_AS, [BillingCountry] NVARCHAR(80) COLLATE Latin1_General_CI_AS, [BillingStateCode] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [BillingCountryCode] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [BillingLatitude] FLOAT(53), [BillingLongitude] FLOAT(53), [BillingAddress] NVARCHAR(4000) COLLATE Latin1_General_CI_AS, [ShippingStreet] NVARCHAR(4000) COLLATE Latin1_General_CI_AS, [ShippingCity] NVARCHAR(40) COLLATE Latin1_General_CI_AS, [ShippingState] NVARCHAR(80) COLLATE Latin1_General_CI_AS, [ShippingPostalCode] NVARCHAR(20) COLLATE Latin1_General_CI_AS, [ShippingCountry] NVARCHAR(80) COLLATE Latin1_General_CI_AS, [ShippingStateCode] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [ShippingCountryCode] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [ShippingLatitude] FLOAT(53), [ShippingLongitude] FLOAT(53), [ShippingAddress] NVARCHAR(4000) COLLATE Latin1_General_CI_AS, [Phone] NVARCHAR(40) COLLATE Latin1_General_CI_AS, [Fax] NVARCHAR(40) COLLATE Latin1_General_CI_AS, [AccountNumber] NVARCHAR(40) COLLATE Latin1_General_CI_AS, [Website] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [PhotoUrl] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [Sic] NVARCHAR(20) COLLATE Latin1_General_CI_AS, [Industry] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [AnnualRevenue] FLOAT(53), [NumberOfEmployees] INT, [Ownership] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [TickerSymbol] NVARCHAR(20) COLLATE Latin1_General_CI_AS, [Description] NVARCHAR(4000) COLLATE Latin1_General_CI_AS, [Rating] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [Site] NVARCHAR(80) COLLATE Latin1_General_CI_AS, [OwnerId] NCHAR(18) COLLATE Latin1_General_CI_AS NOT NULL, [CreatedDate] DATETIME2(0) NOT NULL, [CreatedById] NCHAR(18) COLLATE Latin1_General_CI_AS NOT NULL, [LastModifiedDate] DATETIME2(0) NOT NULL, [LastModifiedById] NCHAR(18) COLLATE Latin1_General_CI_AS NOT NULL, [SystemModstamp] DATETIME2(0) NOT NULL, [LastActivityDate] DATE, [LastViewedDate] DATETIME2(0), [LastReferencedDate] DATETIME2(0), [Jigsaw] NVARCHAR(20) COLLATE Latin1_General_CI_AS, [JigsawCompanyId] NVARCHAR(20) COLLATE Latin1_General_CI_AS, [AccountSource] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [SicDesc] NVARCHAR(80) COLLATE Latin1_General_CI_AS, [CustomerPriority__c] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [SLA__c] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [Active__c] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [NumberofLocations__c] FLOAT(53), [UpsellOpportunity__c] NVARCHAR(255) COLLATE Latin1_General_CI_AS, [SLASerialNumber__c] NVARCHAR(10) COLLATE Latin1_General_CI_AS, [SLAExpirationDate__c] DATE) WITH (LOCATION='Account', DATA_SOURCE= salesforce_data_source)
- Interroga i dati remoti:
SELECT Id FROM dbo.Account WHERE Id = '001i000000AOq3DXYZ'