hive 把mysql语句执行_R分别连接mysql hive执行操作

大半年忘记更新工作记录了，惭愧，慢慢补上。

mysql/hive 是两类常用的不同类型的数据库，在数据操作上存在一定的区别。

1-MYSQL的连接。

library(DBI)

library(RMySQL)

con

"127.0.0.1",

user =

"root", password = "***")

dbSendQuery(con,'SET NAMES utf8')

sql

dim_app where id2 in (105 ) and des is not

null"

data_105 = dbGetQuery(con, sql)

直接使用RMySQL的包

连接到数据库，可以直接利用现有的函数dbGetQuery执行查询、dbSendQuery执行dml语句等。

# 清除多余的数据库连接

killDbConnections

{

all_cons

dbListConnections(MySQL())

print(all_cons)

for(con in all_cons)

dbDisconnect(con)

print(paste(length(all_cons), "

connections killed."))

}

2-HIVE

hive属于非关系型数据库

不支持commit等回滚事务性操作。前面所述的dbGetQuery会显示不支持，导入数据到库中需要将数据写入到外部文件，再将外部文件load到数据库。且load

语句不属于dml语句，所以使用dbSendUpdate函数，如果使用dbSendQuery函数由于无返回值会报错。

library("DBI")

library("r

library("RJDBC")

library("methods")

setwd("/home/xx/work/")

for(l in list.files('/opt/hive/lib/')){ .jaddClassPath(paste("/opt/hive/lib/",l,sep=""))}

drv

for(l in list.files('/opt/hadoop/share/hadoop/common/')){ .jaddClassPath(paste("/opt/hadoop/share/hadoop/common/",l,sep=""))}

conn

show_databases

#show_databases

dbSendUpdate(conn, "create table app_center.dim_app(id bigint , name string) ROW FORMAT DELIMITED FIELDS TERMINATED BY '\t'")

dbSendUpdate(conn, "load data local inpath './work/app2.dat' overwrite into table app_center.dim_app")

dbDisconnect(conn)

通过JDBC 连接到数据并且进行查询，插入，建表等语句。RHive

包太旧，不建议使用。

hive 把mysql语句执行_R分别连接mysql hive执行操作相关推荐

vbS访问mysql语句_关于VBS连接MySQL与连接Excel
目标:连接MySQL查找数据放入新建Excel表实现过程: 1.连接数据库首先要去MySQL官网下载个ODBC数据源. 安装之后,即可在控制面板-管理工具-ODBC数据源-添加,中看到MySQL驱 ...
wdcp mysql密码_WDCP提示无法连接mysql及创建站点提示mysql密码不正确
一.wdcp系统访问提示无法连接mysql 1.可能是mysql服务没启动,首先ssh登陆服务器,然后执行service mysqld restart重启mysql再访问试下,如果无法启动,先用df ...
mysql 遗失对主机的连接,MySQL远程连接丢失问题解决方法（Lost connection to MySQL server）...
MySQL远程连接丢失问题解决方法(Lost connection to MySQL server) 最近服务器很不稳定,于是重装了mysql 和php 服务,但是接着却遇到了很头疼的麻烦. 远程连接 ...
java连接MySQL几种方法_Java连接MySQL数据库三种方法
好久没有更新博客了!今天利用周目时学习了一下数据库mysql.介绍一下数据库的三种连接方式! 开发工具:Myeclipse MySQL5.6 MySQL连接驱动:mysql-connector-jav ...
MYSQL闪退及DBeaver连接MYSQL出现拒绝连接的解决方法
问题描述: MYSQL闪退: DBeaver连接MYSQL失败可能原因是MYSQL服务没有启动解决方案: 1.使用管理者模式打开CMD 2.进入MYSQL安装目录下的bin目录,并执行mysql ...
mysql跳过安全_Navicat连接MySQL数据库
前言: 在使用Gin架构搭建博客的时候,需要设计数据库,以及连接数据库.命令端口操控效率实在是太低且不好管理,这个时候使用Navicat就能轻松高效的使用数据库了. 步骤: 下载安装Navicat,M ...
qt5.8连接mysql代码_qt5.8如何连接mysql
qt5.8连接mysql的方法:首先编译生成mysql的驱动:然后下载"libmysql.dll"库,并将其放在Qt的bin文件夹下:最后创建连接代码文件进行测试即可. 推荐:&l ...
在linux中连接mysql数据库服务器_Linux下连接Mysql服务器的方式
一:mysql连接简介 1.linux下mysql的连接方式有三种: 本地mysql命令连接客户端命令连接脚本语言封装方法连接 2.linux下mysql的连接方法有两种: TCP/IP协议连接 ...
hive mysql 远程_Hive配置远程连接MySQL
因为hive是Hadoop的一个组件,作为数据厂库,hive的数据是存储在Hadoop的文件系统中的,hive为Hadoop提供SQL语句,是Hadoop可以通过SQL语句操作文件系统中的数据.hiv ...

hive 把mysql语句执行_R分别连接mysql hive执行操作

hive 把mysql语句执行_R分别连接mysql hive执行操作相关推荐

最新文章

热门文章