Oracle 的 PL/SQL 对我来说相当新，所以我需要一些帮助来了解我尝试在 Merge 的 Using 子句中使用参数的方式是否可行。
我正在使用 ODP.NET 使用 Oracle 11g 与现有的 C# .NET 4.0 代码库进行通信，该代码库使用 SQL 连接来检索/修改数据。现有的 SQL 语句如下所示：
MERGE INTO Worker Target
USING
(
SELECT
:Id0 Id
,:Options0 Options
FROM dual
UNION ALL
SELECT
:Id1 Id
,:Options1 Options
FROM dual
) Source
ON (Target.Id = Source.Id)
WHEN MATCHED THEN
UPDATE SET
Target.StateId = :StateId
,Target.Options = Source.Options
Using 子句在 C# StringBuilder 中生成，以适应不同数量的工作人员 Id/Option 对，同时创建匹配的参数。
StringBuilder usingClause = new StringBuilder();
List<OracleParameter> parameters = new List<OracleParameter>();
for (int i = 0; i < workers.Count; ++i)
{
if (i > 0)
usingClause.Append("UNION ALL\n");
usingClause.AppendFormat("SELECT\n :Id{0} Id\n ,:Options{0} Options\n FROM dual\n", i);
parameters.Add(new OracleParameter("Id" + i, workers[i].Id));
parameters.Add(new OracleParameter("Options" + i, workers[i].Options))
}
parameters.Add(new OracleParameter("StateId", pendingStateId));
usingClause StringBuilder 与 Merge 命令的其余部分组合成一个名为“sql”的字符串，然后在 OracleCommand 对象中使用该字符串。执行 SQL Merge 语句的 C# 如下所示：
OracleConnection cn = new OracleConnection(
ConfigurationManager.ConnectionStrings["OracleSystemConnection"].ConnectionString
);
using (OracleCommand cmd = new OracleCommand(sql, cn))
{
cmd.BindByName = true;
cn.Open();
foreach (OracleParameter prm in parameters)
cmd.Parameters.Add(prm);
cmd.ExecuteNonQuery();
cn.Close();
}
我已经尝试过按名称绑定参数和不按名称绑定参数，并确保在没有按名称绑定参数的情况下顺序正确。我不断得到的是“ORA-01008：并非所有变量都绑定”错误。
我还尝试在 SQL Developer 中运行 Merge 命令，并得到“未声明绑定变量 'Id0'”的响应。通常，当我在 SQL Developer 中使用未声明的绑定变量运行命令时，它会打开一个对话框来输入值，但不是使用此 SQL 命令，因此在 SQL Developer 中未声明它是可以理解的，但我不明白为什么会这样ODP.NET/C# 实现的情况，因为我将参数添加到 OracleCommand 对象。
如果有人能指出我做错了什么，或者告诉我如何达到同样的效果，将不胜感激。此外，如果有人知道将值列表传递到 Merge 的 Using 子句中的更好方法，而不是在它们之间执行一堆 SELECTs FROM dual 和 UNION ALL，那么也将不胜感激。
使用 Long Raw 作为选项列的答案
经过一番努力，这是最终的解决方案。感谢 tomi44g 为我指明了正确的方向。
DECLARE
TYPE id_array IS TABLE OF NUMBER INDEX BY PLS_INTEGER;
TYPE option_array IS TABLE OF LONG RAW INDEX BY PLS_INTEGER;
t_ids id_array := :ids;
t_options option_array := :options;
BEGIN
FORALL i IN 1..t.ids.count
EXECUTE IMMEDIATE '
MERGE INTO Worker Target
USING (SELECT :1 Id, :2 Options FROM dual) Source
ON (Source.Id = Target.Id)
WHEN MATCHED THEN
UPDATE SET
Target.StateId = :3
,Target.Options = Source.Options' USING t_ids(i), t_options(i), :state_id;
END;
这就是 C# 更改的内容，以适应解决方案。
// Gather the values into arrays for binding.
int[] workerIds = new int[workers.Count];
byte[][] workerOptions = new byte[workers.Count][];
BinaryFormatter binaryFormatter = new BinaryFormatter();
for (int i = 0; i < workers.Count; ++i)
{
workerIds[i] = workers[i].Id;
// There's an assumed limit of 4096 bytes here; this is just for testing
MemoryStream memoryStream = new MemoryStream(4096);
binaryFormatter.Serialize(memoryStream, workers[i].Options);
workerOptions[i] = memoryStream.ToArray();
}
// Excute the command.
OracleConnection cn = new OracleConnection(
ConfigurationManager.ConnectionStrings["OracleSystemConnection"].ConnectionString
);
using (OracleCommand cmd = new OracleCommand(sql, cn))
{
cmd.BindByName = true;
cn.Open();
OracleParameter ids = new OracleParameter();
ids.OracleDbType = OracleDbType.Int32;
ids.CollectionType = OracleCollectionType.PLSQLAssociativeArray;
ids.Value = workerIds;
ids.ParameterName = "ids";
OracleParameter options = new OracleParameter();
options.OracleDbType = OracleDbType.LongRaw;
options.CollectionType = OracleCollectionType.PLSQLAssociativeArray;
options.Value = workerOptions;
options.ParameterName = "options";
cmd.Parameters.Add(ids);
cmd.Parameters.Add(options);
cmd.Parameters.Add(new OracleParameter("state_id", pendingStateId));
try
{
cmd.ExecuteNonQuery();
}
catch (OracleException e)
{
foreach (OracleError err in e.Errors)
{
Console.WriteLine("Message:\n{0}\nSource:\n{1}\n", err.Message, err.Source);
System.Diagnostics.Debug.WriteLine("Message:\n{0}\nSource:\n{1}\n", err.Message, err.Source);
}
}
cn.Close();
}