r-dbi

    0热度

    1回答

    就R我运行下面的查询,以检索数据日期: test <- dbGetQuery(conn = GetConnection("default"), statement = "SELECT PK_FK_RW_BOND_HOLDING_VAL_BOND, PK_CASHFLOW_DAT FROM RW_CASH_FLOWS_ON_BONDS WHERE PK_FK_RW_BOND_HOLDING_VAL_

    2热度

    2回答

    我的R工作流现在涉及处理大量查询(RPostgreSQL库)。我确实希望将代码轻松地在将来进行维护和管理。 我开始从单独的.SQL文件(this帮助)加载大型查询,它工作得很好。 然后我开始使用内插的值(that帮助),这意味着我可以写 SELECT * FROM table WHERE value = ?my_value; 和(装载它成R之后)使用sqlInterpolate(ANSI(),

    1热度

    1回答

    我写自R分贝sqlite的使用以下命令: dbWriteTable(con, 'topics',as.data.frame(topics), row.names = NA, overwrite = FALSE, append = TRUE, field.types = NULL) 我得到源码如下表: 哪有我重命名row_names属性? 东风[as.data.frame(主题)]片段是:

    0热度

    1回答

    我有一个火花数据帧TABLE1与100000行一列各包含相同长度的串 AA105LONDEN 03162017045262017 16953563ABCDEF 和我会喜欢根据下面分隔的行将每行分隔成多个列,并将空白作为单独的列。 AA|105|LONDEN| |0316|2017|04526|2017| |1695|3563|ABCDEF 目前,我尝试使用DBI包与代码如下所示: libr

    1热度

    1回答

    我想为SparklyR编写SQL函数的包装。我创建了以下功能: sqlfunction <- function(sc, block) { spark_context(sc) %>% invoke("sqlContext.sql", block) } 然后我把它用在以下几点: newsqlData <- sqlfunction(sc, "select subst

    3热度

    1回答

    当使用RSQLite 1.0.0包从SQLite 3数据库中提取数据时,我遇到了一个奇怪的现象。除datetime值之外的所有内容都会被截断! 看到一个例子: 继我提取DATETIME列: library(RSQLite) src_path <- "../DataLocked/Study.db" con <- dbConnect(SQLite(), src_path) dbGetQuery(

    1热度

    1回答

    我已经通过使用这一说法RMySQL包连接到MySQL数据库: con<-dbConnect(drv=RMySQL::MySQL(max.con=1,fetch.default.rec=500),host="host",dbname="dbname",password="psswd",user="user")) 到目前为止,没有任何问题。当我检查: >class(con) [1] "MySQL

    1热度

    2回答

    我有一个R笔记本,我正在从数据库读取数据使用SQL块,然后将其分配给数据框。然后我想在R笔记本中的R块中使用它,所以我使用sql块中的output.vars选项。当我运行所有,然后预览它完美的作品,但是当我编织它时,我得到的错误:“eval(expr,envir,enclos)中的错误:找不到对象'x'”。 下面是一些简单的代码,将重现此错误: --- title: "R Notebook"

    2热度

    1回答

    我想从mysql中将几百个单独的数据库转换为r。我可以单独获取它们,但我不知道如何创建一个循环/函数/申请一次全部获取它们。 以下是我如何分别获取它们的方法。 library(RMySQL) mydb = dbConnect(MySQL(), user='root', password='nelson', host='localhost', dbname="bookstore")

    1热度

    2回答

    我无法获得R语言DBI :: sqlAppendTable函数与数字以外的任何其他工作。以下是一些说明问题的代码。我怀疑问题是sqlAppendTable不引用数据。任何修复或解决方法将不胜感激。 num = data.frame(matrix(1:26, ncol=2)) let = data.frame(matrix(letters, ncol=2)) test.sqlAppendTab