Skip to content

Commit db76c16

Browse files
committed
escape ticks
1 parent 36809d3 commit db76c16

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

csharp/src/Drivers/Databricks/DatabricksConnection.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -370,7 +370,6 @@ protected override TOpenSessionReq CreateSessionRequest()
370370
return req;
371371
}
372372

373-
374373
protected override async Task HandleOpenSessionResponse(TOpenSessionResp? session)
375374
{
376375
await base.HandleOpenSessionResponse(session);
@@ -392,9 +391,10 @@ protected override async Task HandleOpenSessionResponse(TOpenSessionResp? sessio
392391

393392
// Since Databricks Namespace was introduced in newer versions, we fallback to USE SCHEMA to set default schema
394393
// in case the server version is too low.
395-
private async Task SetSchema(string schemaName) {
394+
private async Task SetSchema(string schemaName)
395+
{
396396
using var statement = new DatabricksStatement(this);
397-
statement.SqlQuery = $"USE {schemaName}";
397+
statement.SqlQuery = $"USE `{schemaName}`";
398398
await statement.ExecuteUpdateAsync();
399399
}
400400

csharp/src/Drivers/Databricks/DatabricksStatement.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,8 @@ public DatabricksStatement(DatabricksConnection connection)
4444
// set the catalog name for legacy compatibility
4545
// TODO: use catalog and schema fields in hiveserver2 connection instad of DefaultNamespace so we don't need to cast
4646
var defaultNamespace = ((DatabricksConnection)Connection).DefaultNamespace;
47-
if (defaultNamespace != null) {
47+
if (defaultNamespace != null)
48+
{
4849
if (CatalogName == null)
4950
{
5051
CatalogName = defaultNamespace.CatalogName;

0 commit comments

Comments
 (0)