使用SQL的SP_OAMethod实现Salesforce Bulk API 2.0 CSV批量同步问题

问题背景 #

我有符合Salesforce格式要求的CSV文件，需要用SQL的sp_OAMethod存储过程调用Salesforce Bulk API 2.0实现批量同步。之前试过把CSV导入数据库表，用游标拼接数据后调用存储过程发送，但因为字符串长度限制失败了。想知道有没有直接上传CSV文件的方法（类似Postman里选Binary选项加载本地CSV的方式）。

之前试过这段代码，Salesforce显示任务完成但没处理任何记录，用任务ID也查不到成功或失败的记录：

EXEC @ret = sp_OAMethod @token, 'open', NULL, 'PUT', @url, 'true';   
EXEC @ret = sp_OAMethod @token, 'setRequestHeader', NULL, 'Authorization', @authHeader;
EXEC @ret = sp_OAMethod @token, 'setRequestHeader', NULL, 'Content-type', @contentType;
EXEC @ret = sp_OAMethod @token, 'setRequestHeader', NULL, 'content-disposition', "attachment; filename=<path of the csv file with filename.csv>";

解决方案 #

核心问题 #

你之前的代码只设置了请求头，但没实际读取并发送CSV文件的内容，这就是Salesforce任务无记录的原因。sp_OAMethod调用的XMLHTTP对象必须通过send方法把文件内容传过去才行。

步骤1：读取本地CSV的二进制内容 #

用OPENROWSET读取文件，注意SQL Server服务账户要有该文件的读取权限：

DECLARE @csvContent VARBINARY(MAX)
SELECT @csvContent = BulkColumn
FROM OPENROWSET(BULK 'C:\your\file\path\data.csv', SINGLE_BLOB) AS FileData

步骤2：正确配置请求并发送内容 #

要先创建Salesforce的Ingest Job，拿到Job ID再构造上传URL，然后发送文件内容：

DECLARE @token INT, @ret INT, @url NVARCHAR(2000), @authHeader NVARCHAR(500), @contentType NVARCHAR(100)

-- 初始化XMLHTTP对象
EXEC @ret = sp_OACreate 'MSXML2.XMLHTTP', @token OUT;
IF @ret <> 0 GOTO Cleanup

-- 替换为你的实际参数
SET @url = 'https://your-salesforce-domain/services/data/v58.0/jobs/ingest/your-job-id/batches'
SET @authHeader = 'Bearer your-access-token'
SET @contentType = 'text/csv'

-- 打开同步请求（第三个参数设为false，避免异步问题）
EXEC @ret = sp_OAMethod @token, 'open', NULL, 'PUT', @url, 'false';
IF @ret <> 0 GOTO Cleanup

-- 设置请求头
EXEC @ret = sp_OAMethod @token, 'setRequestHeader', NULL, 'Authorization', @authHeader;
EXEC @ret = sp_OAMethod @token, 'setRequestHeader', NULL, 'Content-Type', @contentType;
-- 可选设置文件名，核心还是发送内容
EXEC @ret = sp_OAMethod @token, 'setRequestHeader', NULL, 'Content-Disposition', 'attachment; filename="data.csv"';

-- 发送CSV二进制内容
EXEC @ret = sp_OAMethod @token, 'send', NULL, @csvContent;
IF @ret <> 0 GOTO Cleanup

-- 打印响应，用于调试
DECLARE @status INT, @responseText NVARCHAR(MAX)
EXEC @ret = sp_OAGetProperty @token, 'status', @status OUT;
EXEC @ret = sp_OAGetProperty @token, 'responseText', @responseText OUT;

PRINT '响应状态: ' + CAST(@status AS NVARCHAR(10))
PRINT '响应内容: ' + @responseText

Cleanup:
-- 销毁对象
EXEC @ret = sp_OADestroy @token;

关键注意事项 #

• 权限：SQL Server服务账户必须能访问CSV文件所在的路径，否则读取会失败。
• Bulk API流程：必须先创建Ingest Job，不能直接上传文件。创建Job的接口是/services/data/vXX.X/jobs/ingest，提交Job配置后拿到ID再用上面的代码上传。
• 同步请求：open方法第三个参数用false，确保请求完成后再获取响应，避免异步导致的状态混乱。
• 内容类型：Content-Type必须设为text/csv，Salesforce才会正确解析CSV内容。

调试方法 #

• 调用Salesforce的Job查询接口（/services/data/vXX.X/jobs/ingest/your-job-id），查看Job的详细状态和错误信息。
• 打印SQL中的响应内容，根据Salesforce返回的提示定位问题。

内容的提问来源于stack exchange，提问作者user21020259