PolyBase verbinden met Salesforce.com

PolyBase benadert en combineert zowel niet-relationele als relationele gegevens, allemaal vanuit SQL Server. Vanaf SQL Server 2019 ondersteunt PolyBase gegevens van backends waarvoor een ODBC-stuurprogramma beschikbaar is.

We hebben PolyBase geprobeerd met onze Salesforce ODBC-driver, om Salesforce-gegevens uit SQL Server 2019 op te vragen.

Om te beginnen:

1. Installeer en licentieer het Salesforce.com ODBC-stuurprogramma op de computer waarop SQL Server is geïnstalleerd.

   U hebt build 2.0.3 van het ODBC-stuurprogramma van Salesforce.com nodig, dat momenteel beschikbaar is door contact op te nemen met het Easysoft-ondersteuningsteam ().

2. Maak in Microsoft SQL Server Management Studio verbinding met uw voor PolyBase geschikte SQL Server-instantie. Voer deze query uit om te controleren of PolyBase is geïnstalleerd:

   SELECT SERVERPROPERTY ('IsPolyBaseInstalled') AS IsPolyBaseInstalled;

   Als PolyBase is geïnstalleerd, geeft deze query het volgende resultaat:

   1

3. U moet er ook voor zorgen dat PolyBase is ingeschakeld:

   EXEC SP_CONFIGURE @CONFIGNAME = 'polybase enabled', @CONFIGVALUE = 1;
   RECONFIGURE WITH OVERRIDE;

4. Als u dit nog niet hebt gedaan, start u de PolyBase-services (SQL Server PolyBase Engine, SQL Server PolyBase Data Movement) in de Windows Services-toepassing.
5. Maak een externe PolyBase-gegevensbron:

   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
   );
   

6. Maak een lokale SQL Server-tabel die de externe Salesforce-gegevens zal bevatten. Deze lokale tabel is voor de Account Salesforce-tabel:

   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)

7. De externe gegevens opvragen:

   SELECT Id FROM dbo.Account WHERE Id = '001i000000AOq3DXYZ'