如何将具有特殊字符的列名别名为具有下划线而不是特殊字符的新列名？

Posted 2023-04-17

【中文标题】如何将具有特殊字符的列名别名为具有下划线而不是特殊字符的新列名？

【英文标题】：How to alias a column name with special character to new column name with underscore instead of speacial character?

【发布时间】：2020-06-13 17:01:07

【问题描述】：

我有一个列名为“产品/价格”的表，我想在 sparksql 中创建现有表的副本时将其重命名为 product_price。

create table newtable as select product/price as product_price from 现有表

这给了我错误“分析异常错误：无法解析‘产品’

我也尝试过如下操作：

create table newtable as select 'product/price' as product_price 从现有表中

这确实会更改列名，但其中的所有值也会更改为 product_price。

【参考方案1】：

  // select `product/price` as product_price .... to your column ?
  //

  val d1 = Seq("test", "Test1", "test2").toDF("product/price")
  d1.show(false)
  //      +-------------+
  //      |product/price|
  //      +-------------+
  //      |test         |
  //      |Test1        |
  //      |test2        |
  //      +-------------+

  val d2 = d1.withColumnRenamed("product/price", "product_price")
  d2.show(false)
  //      +-------------+
  //      |product_price|
  //      +-------------+
  //      |test         |
  //      |Test1        |
  //      |test2        |
  //      +-------------+