C#中使用Google.Cloud.BigQuery.V2执行联邦查询遇引号报错求助

问题根源 #

报错是因为C#字符串中嵌套的单引号未被BigQuery正确解析，导致SQL语句格式异常。虽然查询在BigQuery控制台能正常运行，但C#代码的字符串处理逻辑需要适配BigQuery的语法规则。

解决方案 #

你可以通过以下三种方式修正：

方式1：转义内部单引号（BigQuery语法要求） #

在C#字符串里，把内部查询的单引号替换为两个连续单引号（这是BigQuery识别的单引号转义方式）：

BigQueryClient client = BigQueryClient.Create(projectId);       
string sql = "SELECT * FROM EXTERNAL_QUERY('connection-id', ''SELECT * FROM schema.tablename;'');";

BigQueryParameter[] parameters = null;
BigQueryResults results = client.ExecuteQuery(sql, parameters);

foreach (BigQueryRow row in results)
{
    Console.WriteLine($"{row["colname1"]}: {row["colname2"]}");
}

方式2：使用逐字字符串简化转义 #

用C#逐字字符串（@前缀）避免常规转义干扰，同样用两个单引号转义内部单引号：

BigQueryClient client = BigQueryClient.Create(projectId);       
string sql = @"SELECT * FROM EXTERNAL_QUERY('connection-id', ''SELECT * FROM schema.tablename;'');";

BigQueryParameter[] parameters = null;
BigQueryResults results = client.ExecuteQuery(sql, parameters);

foreach (BigQueryRow row in results)
{
    Console.WriteLine($"{row["colname1"]}: {row["colname2"]}");
}

方式3：参数化查询（更安全推荐） #

通过参数传递connection-id和内部查询，彻底避免字符串拼接的转义问题，同时防范SQL注入：

BigQueryClient client = BigQueryClient.Create(projectId);       
string sql = "SELECT * FROM EXTERNAL_QUERY(@connectionId, @innerQuery);";

BigQueryParameter[] parameters = new[]
{
    new BigQueryParameter("connectionId", BigQueryDbType.String, "connection-id"),
    new BigQueryParameter("innerQuery", BigQueryDbType.String, "SELECT * FROM schema.tablename;")
};

BigQueryResults results = client.ExecuteQuery(sql, parameters);

foreach (BigQueryRow row in results)
{
    Console.WriteLine($"{row["colname1"]}: {row["colname2"]}");
}

关键说明 #

BigQuery中SQL语句的单引号必须用两个连续单引号转义，而非C#常用的反斜杠转义；参数化查询是最优方案，既解决转义问题又提升代码安全性。

内容的提问来源于stack exchange，提问作者A. Acevedo