R语言批量将Oracle数据库数据插入到MySQL数据库中

港控/mmm° 2023-02-16 00:41 4阅读 0赞

## 加载包 ##

library(DBI)  
library(RMySQL)  
library(rJava)  
library(RJDBC)

## 设置Oracle读取驱动 ##

setwd(“C:\\Users\\Administrator\\Desktop\\oracle”)

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RhbmRlbGlu_size_16_color_FFFFFF_t_70]

## 配置连接Oracle，并读取表 ##

drv<-JDBC(“oracle.jdbc.driver.OracleDriver”,“ojdbc6.jar”, identifier.quote=""") \#\#java中JDBC的套路  
conn<-dbConnect(drv,“jdbc:oracle:thin:@10.113.113.177:1521:XE”,“SZTN”,“sztn”) \#\#建立一个连接  
table1<-dbGetQuery(conn,“SELECT \* FROM T\_SYN\_YJXX\_ZK01”) \#\#根据sql记录获取Oracle中表的数据  
table2<-dbGetQuery(conn,“SELECT \* FROM T\_SYN\_SSZB\_ZK01”) \#\#根据sql记录获取Oracle中表的数据

str(table1)

## 创建MySQL数据库连接,并插入数据到MySQL ##

con <- dbConnect(MySQL(), host=“10.113.125.17”, dbname=“tan\_test”, user=“root”, password=“root”)  
colnames(table1) <- iconv(colnames(table1),from=“UTF-8”,to=“GBK”)  
colnames(table2) <- iconv(colnames(table2),from=“UTF-8”,to=“GBK”)  
dbWriteTable(con,“auto\_coal\_waring”,table1,overwrite=T,row.names=FALSE)  
dbWriteTable(con,“auto\_coal\_analysis”,table2,overwrite=T,row.names=FALSE)  
dbWriteTable(con,“auto\_coal\_waring\_history”,table1,append=T,row.names=FALSE)  
dbWriteTable(con,“auto\_coal\_analysis\_history”,table2,append=T,row.names=FALSE)

## 注意事项 ##

数据库字符编码不同，在不同的系统运行环境中，编码会出现差异，存在乱码的情况，需要根据系统进行设置。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RhbmRlbGlu_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200606163227863.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RhbmRlbGlu,size_16,color_FFFFFF,t_70