将SELECT语句的标量结果赋值给Spark SQL中的变量或小部件(Databricks)

文章/答案/技术大牛

发布

1回答

sql、apache-spark、databricks

我正在寻找与T-SQL select @variable = AVG(something) FROM ...构造等效的Spark SQL。我想将从select avg(year) from values ("John", 33), ("Karen", 20), ("Gladys", 25) as data(name, year)返回的标量赋值给一个变

浏览 152提问于2021-02-24得票数 2

4回答

Spark sql中的变量

apache-spark、apache-spark-sql、databricks

因为在SQL Server中，我们可以像declare @sparksql='<any query/value/string>'一样声明变量，但是在spark sql中可以使用什么替代方法。

浏览 541提问于2020-11-26得票数 3

5回答

在Databricks* / Spark中在SQL中为一个变量分配一个动态值*

apache-spark、apache-spark-sql、databricks

我觉得这里一定缺少了一些显而易见的东西，但是我似乎不能在Spark中动态地设置一个变量值。 FROM tableBuilder但是，我似乎不能将派生值赋值<e

浏览 2提问于2019-12-11得票数 6

回答已采纳

1回答

如何从数据库中SQL语句的输出中创建变量

python、pyspark、databricks

我想创建一个变量，稍后我可以在同一个笔记本中的多个sql查询中使用该变量。变量本身只是sql语句的整数输出，如：然后，在后续的sql命令单元格中，我只需在计算中调用变量，如：select (count(cars) &#x

浏览 2提问于2021-09-24得票数 0

2回答

Databricks SQL值不能在Spark getArgument IN子句中使用

apache-spark-sql、databricks

我从databricks notebook小部件中获取了一个逗号分隔的字符串列表，但我不能在Spark SQL的IN子句中使用该值我在notebook中的%sql单元格中，不希望跳到%py或%scala此外，我不能在IN子句中使用select语句，因为IN子句不在select筛选器中。如果您尝试这种语法，就会

浏览 1提问于2019-05-09得票数 0

1回答

Server如何向变量中添加计算列并在另一列中使用

sql-server

P.UAP = T.UAPON C.Referencia = P.Referencia我需要创建一些使用某些列值计算的变量，并且需要使用该变量来计算其他列。原因是我不想对select语句进行所有计算，这将造成很大的混乱，但我不知道是否可以使用select。T.UAP ON C.Referencia = P.Referencia

浏览 0提问于2019-05-15得票数 0

回答已采纳

2回答

将SELECT* 语句的结果赋值给变量SQL* SERVER*

sql-server、variables

我有一个有700行的表。我想要做的是，对它执行‘`select * from table_name’查询，无论我将得到什么结果，我都想将它存储在一个变量中，完成后，想要遍历每个记录以进行处理吗？在广告中谢谢你，-saurabh

浏览 1提问于2014-12-08得票数 0

1回答

创建XML，使用批量复制导出

sql-server、bcp、sqlxml

我想，在XML和CTE中使用bcp是“独特的”(可能不是吗？) ...( FROM entitet AS e

浏览 0提问于2018-02-20得票数 0

2回答

如何使用spark表在数据库中使用select查询将数据插入表

sql-server、apache-spark、create-table、azure-databricks、azure-synapse

我希望使用Azure数据块中的SQL将Spark表的结果插入到新的SQL Synapse表中。我尝试了以下解释，https://learn.microsoft.com/en-us/azure/databricks/spark/latest/spark-sql/

浏览 6提问于2020-10-31得票数 0

1回答

SQL fetch正在工作，但在触发器中不工作

sql-server、tsql、sql-insert、database-trigger

VARCHAR(10) DECLARE @MIKTAR INTSELECT* FROM ATMATERIALTRANS FOR SELECT TDATE, WORKCENTERS.CODE, ATMATERIALS.BARCODE

浏览 0提问于2018-06-06得票数 0

4回答

在TSQL中将JSON转换为XML？

xml、json、tsql、sql-server-2005、xml-parsing

我有一个开发来执行存储在列表中的dinamyc查询，所有的程序都被编程来操纵XML中的参数，但是还有一些其他的应用程序可以发送json中的参数，所以我想知道是否有人做了一些东西来将T-SQL中的Json

浏览 3提问于2013-06-20得票数 2

回答已采纳

1回答

无法将HTTPUtility方法的结果绑定到会话变量

asp.net、sql-server、webforms、session-variables、httputility

我使用的是ASP.NET网页表单。我正在尝试将前一页中的一些数据(包括URL和存储在URL中的一些特定图形)绑定到会话变量，以便在SQL insert语句中使用到SQL Server数据库。下面是其中一个赋值的示例： this.Session["URL"] = HttpUtility.ParseQueryString(Request.UrlReferrer.Qu

浏览 18提问于2019-10-30得票数 0

1回答

AttributeError：“NoneType”对象没有属性“写在火花中”

apache-spark、pyspark、pyspark-sql、pyspark-dataframes

火花: 2.4.4火花data.registerTempTable("data") output.write.format('.csv

浏览 1提问于2019-09-26得票数 2

回答已采纳

1回答

SQL将变量赋值给SELECT语句中的函数结果

sql、sql-server、tsql、select

我有一个SELECT语句，它多次使用函数的结果。与其重复点击这个函数，我是否可以给它赋值一个变量，以提高语句的效率，并且我不需要一直点击这个函数？过于简化的假设示例代码：--This function

浏览 0提问于2017-10-11得票数 2

回答已采纳

2回答

Databricks中的错误:您似乎试图从广播变量、操作或转换引用SparkContext

pyspark、azure-databricks、multiprocess

我试图在databricks std集群中运行以下代码。from multiprocess import Poolsql_scripts = ["select * from t1","select * from t2"] spark.sql(sql_script)p.map(tra

浏览 10提问于2022-06-05得票数 0

1回答

将包含COALESCE的动态sql语句的结果赋值给变量

exec、variable-assignment、dynamic-sql、coalesce、sp-executesql

我有一个使用COALESCE构建的动态SQL语句。我需要将执行此动态sql语句的结果赋给一个变量。我尝试了以下代码，但它没有将输出赋值给变量@result。执行完成后，exec将显示正确的结果，但"select @ result“的输出始终为空 DECLARE @<

浏览 5提问于2018-09-11得票数 0

1回答

面临执行Sql任务的问题

ssis、ssis-2012

当前任务正在执行存储过程，结果被赋值给变量。现在，我想在单个执行任务中同时执行存储过程和sql select语句，我试图通过使用动态sql语句来获得它，如下所示。ParmDefinition, @Usr_Id='domain\fn.lastname', Set @Query = 'SELECT</

浏览 4提问于2021-11-16得票数 2

2回答

Databricks作业中的加载表将所有列转换为小写

pyspark、apache-spark-sql、databricks、azure-databricks、pyspark-schema

我将一个SQL视图作为表存储在Databricks中，并且所有的列都是大写的。当我使用spark.table(<<table_name>>)在Databricks作业中加载表时，所有列都转换为小写，这会导致代码崩溃。然而，当我以同样的方式在一个简单的笔记本中加载表时，列名仍然是大写的，不会变成小写。以前有人遇到过这个问题吗？这很奇怪，因为它只发生在工作中。

浏览 7提问于2022-07-07得票数 0

2回答

DataBricks:在Python中将CSV数据摄取到Delta会触发“表名中的无效字符”错误--如何设置列映射模式？

pyspark、databricks、delta-live-tables

首先，我可以说在写这篇文章的时候我正在学习DataBricks，所以我想要更简单、更简单的解决方案以及更复杂的解决方案。“，;{}()\n\t=”中的无效字符。请通过将表属性“delta.columnMapping.mode”设置为“名称”来启用列映射。有关详细信息，请参阅或使用别名重命名它。解释了如何在使用ALTER TABLE创建表之后将列映射模式设置为“name”，但没有解释如何在创建时设置它，特别是在使用如上所述的</

浏览 20提问于2022-06-16得票数 2

回答已采纳

1回答

使用pyspark从dataframe中添加temp表中的多个列

dataframe、azure、pyspark、databricks

试图在Databricks中的Pyspark中创建一个表，该表将捕获每个表的数据库名称、表名和DDL语句。蜂窝亚稳态已经加载在AzureMySQL中，而Databricks集群正是在其上进行指向的。虽然在单独的dataframe对象中，我能够捕获所需的详细信息，但是无法将它们合并到一个表中。对于数据库名和表名，这里是dataframe df1 t

浏览 6提问于2022-10-11得票数 0

回答已采纳

点击加载更多