如何通过PostgreSQL会话命令将双引号设为字符串分隔符？

PostgreSQL没有类似SQL Server/Oracle中可将双引号视为字符串而非标识符的会话级设置——这是因为PostgreSQL严格遵循SQL标准，默认双引号用于包裹列名、表名这类标识符，单引号才是字符串的定界符，这个规则无法通过会话命令修改。

不过你完全可以绕过字符串转义/替换的方案，用更高效且安全的方式解决问题，推荐以下核心思路：

1. 使用Spark JDBC参数化查询（最优方案） #

Spark通过JDBC写入PostgreSQL时，默认采用参数化查询传递数据，无需手动处理字符串中的引号。数据库会自动将参数中的双引号识别为字符串内容，而非标识符。

示例Scala代码：

import org.apache.spark.sql.{SparkSession, DataFrame}

val spark = SparkSession.builder()
  .appName("KafkaStreamToPostgres")
  .getOrCreate()

// 从Kafka接收并处理后的数据流
val streamDF = spark.readStream
  .format("kafka")
  .option("kafka.bootstrap.servers", "kafka-host:9092")
  .option("subscribe", "your-topic")
  .load()
  // 此处添加你的数据处理逻辑
  .selectExpr("CAST(value AS STRING) as content")

// 流式写入PostgreSQL
val query = streamDF.writeStream
  .foreachBatch { (batchDF: DataFrame, _: Long) =>
    batchDF.write
      .format("jdbc")
      .option("url", "jdbc:postgresql://pg-host:5432/your-db")
      .option("dbtable", "target_table")
      .option("user", "pg-user")
      .option("password", "pg-pass")
      .option("driver", "org.postgresql.Driver")
      .mode("append")
      .save()
  }
  .start()

query.awaitTermination()

这种方式完全不需要在流处理阶段做字符串清理，所有引号都会被PostgreSQL正确解析为字符串内容，同时还能避免SQL注入风险，性能远高于手动字符串处理。

2. 绝对避免手动拼接SQL语句 #

如果因特殊场景必须构造SQL（强烈不推荐在流处理中这么做），绝不要直接拼接字符串值，而是使用PreparedStatement的?占位符，将字符串值通过参数传递，数据库会自动处理引号问题。

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