将函数中的SQL结果输出到R dataframe
可以通过以下步骤实现：
- 首先，确保已经安装了R语言和相关的数据库驱动程序（如RMySQL、RPostgreSQL等）。
- 在R中，使用适当的库加载所需的数据库驱动程序。例如，如果使用MySQL数据库，可以使用RMySQL库。
library(RMySQL)- 建立与数据库的连接。使用
dbConnect()函数提供数据库的相关信息，如主机名、用户名、密码、数据库名称等。
con <- dbConnect(MySQL(), host = "localhost", user = "username", password = "password", dbname = "database_name")- 编写SQL查询语句，并使用
dbGetQuery()函数执行查询。将结果存储在一个变量中。
query <- "SELECT * FROM table_name"
result <- dbGetQuery(con, query)- 关闭与数据库的连接。
dbDisconnect(con)- 将查询结果转换为R dataframe。可以使用
as.data.frame()函数将查询结果转换为dataframe格式。
df <- as.data.frame(result)现在，你可以使用R dataframe df 来处理和分析SQL查询结果了。
对于推荐的腾讯云相关产品和产品介绍链接地址，由于要求不能提及具体的云计算品牌商，我无法提供具体的链接。但你可以在腾讯云官方网站上查找相关产品和文档，以获取更多信息。
相关·内容
我使用以下命令导出使用python从雪花中的过程导出的结果：
# executecriptfromfile function call1
executecriptfromfile('Warehouse.sql')
print('Warehouse activated')
# executecriptfromfile function call2
executecriptfromfile('ProcedureCall.sql')
print('Procedure executed')
dataframe = pd.read_sql(
浏览 2提问于2022-07-29得票数 0
回答已采纳
1回答
我正在尝试将R dataframe (我之前使用SQL查询创建的)导出到SQL，以便与SQL服务器上的数据表执行合并(联接)。
具体地说，如果mydat是R中的一个dataframe，我希望能够按照以下方式做一些事情
library('RODBC')
edw = odbcConnect(<some sql server>)
new_mat = sqlQuery(edw,"SELECT
db.code1
db.code2
FROM mydat as a
JOIN SQLServer_Tables.
浏览 0提问于2018-05-04得票数 2
我有一个包含两个索引的数据框，我正尝试将其导出到SQL Server表中。这是我正在使用的代码。 grouped_and_summed.to_sql(x, engine, if_exists='append', index=True, index_label=None) 'x‘变量是表的名称，'engine’变量来自这里。 engine = "mssql+pyodbc://MyServerName/MyTableName?driver=SQL Server Native Client 11.0?trusted_connection=yes" 当
浏览 16提问于2021-01-15得票数 0
回答已采纳
1回答
将R数据作为新表推送到SQL
、、、、
我试图使我的分析工作流程更有效地将我的Server数据库连接到R。
我现在做什么？
I使用Management开发查询以提取相关信息以进行分析。将查询结果导出到.csv UTF-8文件中。在result中读取该文件并执行分析。将最终数据导出到.csv UTF-8文件。<code>H 111</code>我使用此文件在Studio中创建一个表。<code>H 212</code><code>G 213</code>
，我想做什么？
我希望在Server和computer之间创建一个连接，这样我就可以直接导入/导出我的data
浏览 0提问于2019-09-27得票数 0
回答已采纳
我正在导出一个SQL查询结果到Python中的excel。我使用pyodbc连接来建立数据库连接。
cursor = db_connect.cursor()
Expirydate = date.today() + timedelta(days=90)
print(Expirydate)
sql_query = cursor.execute("""Select StaffDetails.TypeOfEmployee,
StaffDetails.EmploymentType, StaffDetails.EmploymentCategory,
浏览 3提问于2022-03-17得票数 -1
我使用R库(RODBC)导入sql存储过程的结果，并将其保存在数据框架中，然后使用write.table将其导出到xml文件(来自sql的结果是xml输出)--无论如何，R正在截断字符串(从sql导入的xml结果)。我试图找到一个函数或选项来扩展write.table单元格的大小/长度，但没有找到任何函数或选项，我也试图使用write.table语句中的sqlquery忽略使用dataframe，但是它没有工作，从sql导入的数据总是被截断。任何人有任何建议或答案都可以帮助我。这是我的密码
#library & starting the sql connection
library(R
浏览 0提问于2018-05-03得票数 2
我使用的是pandas 0.16和sqlalchemy。是否可以只将数据帧的结构(即列名和数据类型)导出到SQL？
我所能做到的最接近的结果是只导出第一行：
df.ix[[0],:].to_sql( tablename, myconnection )
然后我必须做一个截断表。但是，to_csv和to_sql方法之间存在不一致之处: to_csv将布尔字段写为字符串'TRUE‘或'FALSE’，而to_sql将它们写成0或1。这意味着导入使用dataframe.to_csv创建的文件要比实际复杂得多。
如果我运行
df.ix[[],:].to_sql( tablename, my
浏览 4提问于2015-04-20得票数 3
由于在某些合作伙伴的计算机中没有python，我计划通过pyinstaller创建一个exe文件，然后他们可以使用exe文件。exe文件将连接SQL服务器，然后导出excel文件。代码如下。
import pyodbc
import pandas as pd
from openpyxl import Workbook
from openpyxl.utils.dataframe import dataframe_to_rows
filename = input('Please input excel filename: ')
start_date = input('Pl
浏览 2提问于2021-07-09得票数 0
我正在尝试将数据框导出到mysql数据库中。我正在通过订单和库存API调用来获取数据。
我已经成功地将订单和库存API调用保存到数据帧中，并将订单数据帧导出到MySQL表中。
然而，清单数据帧抛给了我一个错误：
TypeError: sequence item 0: expected str instance, dict found
我不确定我做错了什么，我确实怀疑清单的dataframe在许多列中包含许多嵌套的json，但不确定该怎么办。
到目前为止，我的清单代码如下：
import pandas as pd
#python libary to compare today date for
浏览 15提问于2018-02-02得票数 1
回答已采纳
我有点难以理解，为什么我要做这样的事情：
我需要在sql服务器上创建一个任务，它每天都会运行一个脚本，从表中检索数据并通过FTP将其导出到客户端机器上。
结果必须在TSV (制表符分开)中传输。
到目前为止，我已经在Sql上创建了一个作业，它选择了表中的所有数据，然后从那里导出到C驱动器，我不知道该去哪里
如有任何建议，请见谅。
预先感谢R
浏览 3提问于2014-08-21得票数 0
回答已采纳
目前，我可以使用下面的代码从excel获得一个查询，运行它并将结果导出到另一个excel。但是，我不能设置一个循环来获取" query“列中的所有值并全部运行，并且在不覆盖第一个查询的结果的情况下将结果保存在结果中。因此，我需要使用temp1从“查询”获取第一个值。
dsn_tns = cx_Oracle.makedsn('xxxxxxxxxx', service_name='xxxxxx') # if needed, place an 'r' before any parameter in order to address specia
浏览 5提问于2020-07-30得票数 0
回答已采纳
我正在学习如何在R和R Markdown中使用SQL。 许多来源说，SQL表可以使用SQL块创建，并且output.var需要在SQL块标记中才能将该表输出到R数据帧中。但是dataframe的结果是NULL，代码如下： ```{r setup, include=FALSE} install.packages("RSQLite"，repos = "http://cran.us.r-project.org") 库(RSQLite) 库(DBI) 库(Knitr) db <- dbConnect(RSQLite::SQLite()，":memory:
浏览 32提问于2019-10-02得票数 2
我已经创建了一个查找表(在Excel中)，其中包含各种表的表和列名，以及这些表下的列名以及要在这些字段上运行的所有SQL查询。下面是一个示例表。
所有SQL查询的结果都采用Total_Count和Fail_Count格式。我希望将这些结果与当前版本的查找表中的所有信息和执行日期一起输出到一个单独的表中。
示例结果表：
下面是我用来在相同的查找表中获得结果的代码，但是在一个单独的result_set表中存储相同的结果时遇到了麻烦，这个表有不同的列表示总数和失败计数。
df['Results'] = ''
from pandas import D
浏览 0提问于2019-04-23得票数 0
1回答
我对R中的编程很陌生，我正在R中运行一个循环，并试图将结果输出到一个dataframe中。但是我遇到了一些错误，我自己无法解决，如果有人能看一看，并给我一些如何解决问题的提示，那就太好了。该进程将一直运行，直到遇到来自某个循环的“错误”输出。
基本上，循环停止产生输出到dataframe，并且在循环遇到以下错误时停止：
开始错误:结束: NA/NaN参数
这是我的循环脚本：
for (i in seq(2,880)){
rscheck<-as.data.frame(cbind(as.matrix(chr1only[,i]), chr1only$SIF1))
rscheck$V2<-
浏览 4提问于2013-12-30得票数 0
回答已采纳
使用Google，我有以下设置：
------------------------------------------------
| Game | Player 1 | Player 2 | Player 3 |
------------------------------------------------
| Racing | L | W | X |
| Sonic 2 | W | L | X |
| Sonic 2 | W | X |
浏览 6提问于2012-02-12得票数 1
1回答
我正在尝试将DataFrame中的列汇总到一个新列中，该列将被添加到dataframe本身。
这是DataFrame
val input = sc.parallelize(Seq(
("r1", 1, 1),
("r2", 6, 4),
("r3", 4, 1),
("r4", 1, 2)
)).toDF("ID", "a", "b")
我只想在"a“和"b”中添加一列“one”，其中包含1的计数。
这是我想出来的Scala代码，不幸的是，它对任何一行
浏览 10提问于2018-01-10得票数 1
回答已采纳
我正在尝试使用下面的代码
显示纸牌游戏的结果，
在显示倒计时时等待3秒，然后，
重新加载屏幕。
//显示结果，至少这是这样的想法。对于(var player = 0；player < players.length；player++) { resultString = playersplayer如果( == null) { resultString += "，则为平数。“；}player{ resultString += (player == 0？"，you”："，cassino") + (player ==结果？(玩家== 0？“赢”：“赢”)
浏览 3提问于2013-07-25得票数 0
回答已采纳
1回答
我正在尝试创建趋势条纹，从熊猫数据库中显示1，-1,0 (赢/输/无移动)。我希望条纹在正值时增加，并在0上重置，或者在-1上重置并创建负值条纹。所需的结果如下所示：
win streak
0 0
1 1
1 2
1 3
1 4
0 0
0 0
-1 -1
-1 -2
1 1
目前，我有一个创建win列的代码。
dataframe.loc[dataframe['close'] > dataframe['close_1h'].shift(1), 'win'] = 1
dataframe
浏览 11提问于2021-03-14得票数 0
回答已采纳
2回答
我成功地将数据从收集到R中，现在我想将其导出到SQL中。
library('rvest')
url_Manitoba <- 'https://www.gov.mb.ca/sd/fire/Fire-Situation/daily-
firesituation.html'
webpage_Manitoba <- read_html(url_Manitoba)
population <- webpage_Manitoba %>%
html_nodes("table") %>%
html_table(fill=TRUE)
浏览 1提问于2019-07-06得票数 2
我在SQL Server2008SQL Management Studio上，我试图将一个表导出到R2文件中作为INSERT to ...但在该表中，我还有一个小的日期时间字段，它将导出为CAST(0x9E7501E0作为SmallDateTime)，例如...有没有办法把smalldatetime导出到.sql，其中smalldatetime表示为'2014-02-05 11:10:34‘？
提前感谢大家！！干杯，路易吉
浏览 1提问于2014-05-02得票数 0
6回答
我使用的是Spark 1.3.1 (PySpark)，并且我已经使用SQL查询生成了一个表。我现在有一个对象，它是一个DataFrame。我想把这个表对象(我把它叫做“DataFrame”)导出到一个csv文件中，这样我就可以操作它并绘制列。如何将DataFrame“表”导出为csv文件？
谢谢!
浏览 813提问于2015-07-13得票数 92
回答已采纳
1回答
我对潘达斯很陌生。如何将以下查询转换为熊猫语法。我不再查询MS访问表，我现在正在查询一个名为df的熊猫DataFrame。
查询是：
SELECT
Short_ID,
SUM(IIF(Status = 'Completed', 1, 0))) / COUNT (Status) AS completion_metric
FROM
PROMIS_LT_Long_ID
GROUP BY
Short_ID;
查询结果如下所示：
Short_ID | completion_metric
---------+------------------
10
浏览 3提问于2021-09-17得票数 0
回答已采纳
2回答
我正在使用SQL Server进行数据库分析，并使用R进行预测。我需要将R的结果返回到SQL Server数据库中。一种方法是使用write.table将预测数据输出到文本文件，并使用BULK INSERT进行导入。有没有更好的方法？
浏览 1提问于2015-01-05得票数 1
想尝试做这样的事情：
我有一个名为ID_LIST的ID列。使用id的那个列，我想将它传递到Spark调用中，通过ID_LIST循环，使用foreach将结果返回到另一个dataframe。
val sqlContext = new org.apache.spark.sql.SQLContext(sc)
val id_list = sqlContext.sql("select distinct id from item_orc")
id_list.registerTempTable("ID_LIST")
id_list.foreach(i => printl
浏览 6提问于2017-05-16得票数 0
我正面临着一个可能与这个question和其他类似的问题相关的问题，我决定创建一个专家问题，因为我觉得我的问题可能有一些额外的东西需要考虑。这就是我现在面临的问题。 我在pandas中有一个dataframe，它从sql读取数据，并显示如下内容： ? 在图片中，它向我展示了值具有前导'0‘，该列的数据类型是'object’。 当我在我的windows机器(python 3.7，pandas 1.0.3)上运行这个SQL并导出到CSV时，它完全按照要求工作并显示正确的输出，当我尝试在我的Linux机器(python 3.5.2，pandas 0.24.2)上运行时出现问题，
浏览 128提问于2021-03-24得票数 0
我有一个从我对Pandas做的一些分析中创建的值列表。然后，我想运行一个for循环，使用该列表中的每个值执行SQL查询。
我希望这些结果要么被附加到一个新的DataFrame中--我可以预先初始化，要么将每个结果添加到一个新的DataFrame中，然后我可以将其附加到自己。
示例代码如下，其中df'a‘将是我之前分析的结果列。
df = pd.DataFrame(np.array([[1, 2, 3], [4, 5, 6], [7, 8, 9]]),
columns=['a', 'b', 'c'])
x = df['a']
浏览 0提问于2019-08-08得票数 0
1回答
我正试图通过DataFrame将熊猫pyodbc导出到MS访问表中。
conn = pyodbc.connect(r'Driver={Microsoft Access Driver (*.mdb, *.accdb)};DBQ=my_db.accdb;')
df.to_sql('test', conn, index=False)
DatabaseError: Execution failed on sql 'SELECT name FROM sqlite_master WHERE type='table' AND name=?;'
浏览 31提问于2021-05-28得票数 1
回答已采纳
3回答
我正在尝试提取有特殊字符的密码，并将这些密码导出到一个新的dataframe中。Dataframe如下所示：
Password
*jafad,gwu
klfcv[(+%
12qwe&rghj
bcnyfd254
abcdefghij
我曾尝试以下列方式提取密码：
data = pd.read_excel("password.xlsx", names = ['Password'])
def SpecialChar():
special = pd.Series(data['Password']).str.find
浏览 5提问于2017-10-05得票数 2
回答已采纳
1回答
这里我要做的是从excel中获取所有的sql，使用python执行它们，并将数据导出到另一个名为output.xlsx的excel中。然而，结果覆盖了前面的结果。如何更改下面的代码，以便每当sql运行时，结果将保存在一个新的选项卡中？谢谢！
sql = excel_data_df['Query'].tolist()
i = 0
while i < len(sql):
cursor = connection.cursor()
stmn = (sql[i])
print(stmn)
cursor.execute(stmn)
while
浏览 0提问于2020-08-03得票数 1
回答已采纳
我使用R中的DBI包以这种方式连接到teradata：
library(teradatasql)
query <- "
SELECT sku, description
FROM sku_table
WHERE sku = '12345'
"
dbconn <- DBI::dbConnect(
teradatasql::TeradataDriver(),
host = teradataHostName, database = teradataDBName,
user =
浏览 3提问于2022-01-04得票数 0
我有一个相当复杂的过程来创建pyspark dataframe，将其转换为pandas dataframe，并将结果输出到平面文件。我不确定错误是在哪一点引入的，所以我将描述整个过程。
开始时，我有一个pyspark dataframe，其中包含ids集的成对相似性。它看起来是这样的：
+------+-------+-------------------+
| ID_A| ID_B| EuclideanDistance|
+------+-------+-------------------+
| 1| 1| 0.0|
浏览 1提问于2018-05-02得票数 0
3回答
我正在使用Databricks笔记本，并试图在查询数据帧后将其作为CSV导出到我的本地计算机。但是，它不会将我的CSV保存到我的本地计算机。为什么？
连接到数据库
#SQL Connector
import pandas as pd
import psycopg2
import numpy as np
from pyspark.sql import *
#Connection
cnx = psycopg2.connect(dbname= 'test', host='test', port= '1234', user= 'test'
浏览 4提问于2018-08-20得票数 1
回答已采纳
我想要做的是读取xlsm excel文件，获取输入的代码(符号)列表，使用这些代码在web上抓取相应的值，然后导出到同一个xlsm文件中，但是有一个新的工作表。
money = openpyxl.load_workbook(r'file_path', read_only=False, keep_vba=True)
allocation=money['Allocation']
df1 = pd.DataFrame (allocation.values)
df1.columns = df1.iloc[6] #set header
df1 = df1[7:]
df
浏览 3提问于2022-10-02得票数 0
1回答
如何创建自己的数据帧？
、、、
我有3个dataframes (df1, df2 and df3)，每次运行代码都会导入到3个MySQL表中。现在，我正在尝试创建一个新的数据框架，它正在“监视”这3个数据帧(或表)。
我的预期结果：
df - time_run - count_rows - count_columns
0 df1 - 12:00:23 - 100 - 9
1 df2 - 12:00:24 - 1500 - 8
2 df3 - 12:00:26 - 190 - 6
df显示数据
浏览 0提问于2020-09-08得票数 0
1回答
在utf8中将查询导出到csv
、、、、
我想将我的查询结果导出到utf-8中的csv文件。
现在我用sqlcmd导出到csv。
我的SQL文件：
SELECT *
FROM Test.dbo.T_LIF;
我的Windows批处理文件
@echo off
sqlcmd -S MyServer\SQLServer2008 -E -s; -W -i t_lif_export.sql | findstr /V /C:"-" /B > t_lif_export.csv
不正确的输出:Sanit“r- und Heizungs格罗áhandel
正确输出:Sanit r- und Heizungs格罗
如何在utf-8
浏览 2提问于2017-07-21得票数 1
2回答
在其他统计程序中，可以创建一个日志文件来显示作为命令结果发出的输出。在SQL中有可能做类似的事情吗？
特别是，我希望有一个包含多个查询的.sql文件，然后将每个结果输出到一个文本文件中。
我用的是PostgreSQL和Navicat。
浏览 1提问于2012-07-05得票数 1
回答已采纳
1回答
我有几个.sql文件，它们在SQL数据库中聚合了许多表/视图。我希望能够将R定向到特定的sql文件并执行它，然后在dataframe中返回结果。
谷歌一下，我似乎只能抓取数据库中的实际表/视图，或者我必须重写sql查询并通过RODBC包运行它。
在python中，这可以用pd.read_sql_query来完成
浏览 4提问于2018-12-06得票数 3
4回答
我尝试使用openpyxl将现有的DataFrame导出到Excel文件。
import pandas as pd
from openpyxl.utils.dataframe import dataframe_to_rows
from openpyxl import Workbook
d = {'col1': [1, 2], 'col2': [3, 4]}
df = pd.DataFrame(data=d)
wb = Workbook()
ws = wb.active
for rows in dataframe_to_rows(df, index=True
浏览 2提问于2018-07-02得票数 3
我有这段将MySQL数据导出到CSV文件的代码，但是当我回显结果时，它只显示数据库中的1行，即使我在PHP My Admin中运行SQL，它也显示了大约29行。
并且它只是生成一个空白的CSV文件
$sql="select description, jobreceived, timebookedfor, bookedfor,
site_contact, site_address, invoice_contact, invoice_address,
quotedprice, cleardowndetails, notes, mo_number from jobs
浏览 0提问于2013-04-23得票数 1
2回答
我正在写一个python程序，要求你预测一个骰子。你从5欧元开始，如果你赢了，你就会赚5欧元，如果你赢了1欧元，你就会输1欧元，如果你赢了超过1欧元，你会输3欧元。
def main():
while True:
saldo = 5
y = input("[R]oll or [S]top")
if y == "r" :
p = input("What is your prediction?")
from random import randi
浏览 2提问于2017-10-18得票数 0
你好，我正试图将一个非常大的SQL表(大约170万行)导出到excel或csv文件中，我的问题是当我没有指定内存限制错误时，我猜数据太大，无法存储在内存中。现在我已经通过了一个庞大的，我得到了一个不同的错误。
Error - VisibleDeprecationWarning:不推荐使用衣衫褴褛的嵌套序列(即列表或元组或具有不同长度或形状的ndarray )创建ndarray。如果您打算这样做，则在创建ndarray时必须指定'dtype=object‘。values =np.array(转换(V)表示v的值)
代码：
import pyodbc
import pandas as pd
浏览 6提问于2022-06-17得票数 0
2回答
所以我有一个包含足球比赛结果的数据库。我有一个主客队不同的专栏，我想创建一个专栏，告诉主队是赢了，输了还是平了。
所以我写了一个if-else语句
if (difference>0) {
result2 = 'win'
} else if (difference<0) {
result2 = 'loss'
} else if (difference==0) {
result2 = 'draw'
} else {
result2 = 'error'
}
然而，这个if-else语句是不可能的，因为if没有
浏览 0提问于2020-08-26得票数 0
1回答
我正在将一个大型数据集(38M记录)从Teradata提取到Python DataFrame中。以下是我的查询：
sql = 'SELECT *
from retail.consumer
where unit = Texas'
df = pd.read_sql(sql, conn, chunksize = 100000)
ef = []
while True:
try:
a = next(df)
ef.append(a)
data = pd.DataFrame(ef)
except StopIteration
浏览 1提问于2022-03-17得票数 0
我在Pandas DataFrame中使用以下代码包装文本：
for column in dataframe:
if column != '':
dataframe[column] = dataframe[column].str.wrap(len(column) + 20)
并将DataFrame导出到带有.to_excel(“文件名”)的excel文档中。结果是(Linux上的LibreOffice)，如下图所示：
如何更改行高以获得以下结果：
？
我还想提到，当我删除上面的代码并在LibreOffi
浏览 14提问于2022-11-08得票数 0
回答已采纳
22回答
岩石剪刀
、
实现经典的岩石剪刀。
条件：
用户将输入'r'，'p‘或's’
程序将输出“r”、“p”或“S”并得到结果
程序选择('r'，'p‘或's')必须是伪随机的(我在看你霍华德)
结果可以用任何可打印的字符表示，对于用户输入的内容，应该始终有三种可能的结果(用户赢、输或平分)。
如果用户不输入任何内容，或者不输入“r”、“p”或“S”的不同内容，会发生什么情况？
你需要：
提供金币密码。
未使用的密码
如何调用程序？
样本运行
I将选择字符较少的答案，如果领带显示最多的投票结果将被选择。
打好高尔夫球，祝好运永远对你有利。
我
浏览 0提问于2013-04-10得票数 26
回答已采纳
我会尽可能的直接和具体。
我正在尝试创建Greasemonkey插件，它将创建赢/输的图表:死链接
正如您所看到的，site有一个首页，它可以很好地显示赢/输的结果，以及哪个用户赢/输了多少。我想要做的是捕捉每一个新条目，这样我就可以为用户/用户绘制一些笔墨和或统计数据。
当我访问应该有数据的div/span时，结果是空的。我知道这背后的原因是，所有与我相关的数据的div在加载时都是空的，并且它们稍后会被填充。
我不知道的是如何访问这些数据。我可以看到(使用firebug控制台)一直在执行GET请求，在这些get请求中是我需要的数据。有人能告诉我，或至少指出正确的方向，如何访问每次数据刷新/插
浏览 2提问于2013-12-01得票数 0
回答已采纳
2回答
我想在R studio中从包ElemStatLearn加载数据集。
但是，当我加载数据集时，我的“全球环境”面板显示
library("ElemStatLearn")
data("nci")
但是，当我执行
View("nci")
我可以看到整个数据，但不能将其导出到dataframe。
如何将此数据集转换或导出为数据格式？
浏览 0提问于2018-03-27得票数 1
回答已采纳
使用SQL Developer运行查询效果很好，但如果我不先运行查询，然后右键单击结果集并执行导出到csv例程，则可以节省大量时间。
我想知道在SQL Developer中是否有这样一种方式: 1)编写查询，然后选择将查询结果导出到磁盘。2)编写一个由多个查询组成的队列，每个查询将其结果写入磁盘。
浏览 52提问于2013-10-18得票数 25
回答已采纳
我有一个查询，希望将其内容导出到一个表中：
DECLARE @bdname VARCHAR(50)
SET @bdname = ?
SELECT
@bdname,
CONVERT(CHAR(30), dp2.name),
CONVERT(CHAR(20), dp.name)
FROM
sys.database_principals AS dp
INNER JOIN
sys.database_role_members AS drm ON dp.principal_id = drm.role_principal_id
INNER JOIN
浏览 3提问于2017-05-13得票数 2
回答已采纳
我想转换一个创建如下的数组：
case class Student(name: String, age: Int)
val dataFrame: DataFrame = sql.createDataFrame(sql.sparkContext.parallelize(List(Student("Torcuato", 27), Student("Rosalinda", 34))))
当我从DataFrame收集结果时，得到的数组是一个Array[org.apache.spark.sql.Row] = Array([Torcuato,27], [Rosalinda,
浏览 21提问于2016-04-14得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
