【R语言连接数据库】RMySQL数据库编程指南

本文主要是介绍【R语言连接数据库】RMySQL数据库编程指南，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

这里写图片描述

主要内容

1、RMySQL介绍
2、RMySQL安装方法
3、R连接本地mysql
4、R连接远程mysql
5、R查询mysql数据
6、R插入数据到mysql
7、R调用mysql中的存储过程

1. RMySQL介绍

MySQL是一款最常用到开源数据库软件，安装简单，运行稳定，非常适用于中小型的数据存储。R作为数据分析的工具，当然要支持数据库驱动接口。让R和MySQL配合在一起，所能爆发出的能量是巨大的。

RMySQL一个R语言程序包，提供了访问MySQL数据库的R语言接口程序，RMySQL需求依赖于DBI项目。RMySQL不仅提供了基本的数据库访问，SQL查询，还封装了一些方法。比较读整表，分页，data.frame快速插入等等的功能。掌握好RMySQL，数据库编辑将得心应手！！

2、RMySQL安装

install.packages('RMySQL')

3、通过R程序，读MySQL数据库数据。

对于大数据，我们自然不能用Excel之流存放，通常我们将它们存在数据库中，一个比较优秀的数据库软件就是MySQL，可以让我们读取查询数据库中的相关内容。R中的RMySQL包提供了这么一个读取MySQL数据的办法，并可以使用SQL语句对数据进行查询。
一些有用的函数：

dbConnect：连接数据库dbDisconnect：取消数据库连接dbGetQuery：执行一条SQL语句，将查询结果写为一个数据框dbListTables：列出数据库中的表的名称dbListFields：获取列表的每一列的名称dbReadTable：读取数据库中的一张表dbSendQuery：执行一条SQL语句，返回一个数据库对象

3.1、连接本地mysql,读取数据

mysql建表语句

CREATE TABLE t_blog(
id INT PRIMARY KEY AUTO_INCREMENT,
title varchar(12) NOT NULL UNIQUE,
author varchar(12) NOT NULL, 
length int NOT NULL,
create_date timestamp NOT NULL DEFAULT now()
)ENGINE=INNODB DEFAULT CHARSET=UTF8;

mysql插入语句

INSERT INTO t_blog(title,author,length) values('你好，第一篇','Conan',20),('RMySQL数据库编程','Conan',99),('R的极客理想系列文章','Conan',15);

这里写图片描述

R语言连接本地 mysql ，插入数据，查询数据


rm(list=ls())
gc()
library(RMySQL)########建立本地连接mysql
conn <- dbConnect(MySQL(), dbname = "cgjr", username="root", password="12345",client.flag=CLIENT_MULTI_STATEMENTS)# ###########设置gbk显示中文
# dbGetQuery(conn,'SET NAMES gbk')
# 
# query<-dbGetQuery(conn, "SELECT * FROM persons")# 建表并插入数据dbSendQuery(conn,'SET NAMES gbk')
dbSendQuery(conn,"INSERT INTO t_blog(title,author,length) values('R插入的新文章','Conan',50)");query<-dbSendQuery(conn, "SELECT * FROM t_blog")data <- fetch(query, n = -1)print(data)##########关闭连接
dbDisconnect(conn)

> print(data)id               title author length         create_date
1  1        你好，第一篇  Conan     20 2017-12-12 16:03:29
2  2    RMySQL数据库编程  Conan     99 2017-12-12 16:03:29
3  3 R的极客理想系列文章  Conan     15 2017-12-12 16:03:29
4  4       R插入的新文章  Conan     50 2017-12-12 16:05:20
>

3.2、远程连接线上mysql 数据库

rm(list=ls())
gc()
library(RMySQL)conn <- dbConnect(MySQL(), dbname = "cgjr", username="ldf", password="XXXXXX",host="XXXXXX",port=XXXXX)dbSendQuery(conn,'SET NAMES gbk')query<-dbSendQuery(conn, "SELECT user_id,province,city,district from t_mobile_position WHERE CONCAT(province,city,district) REGEXP '赣州市南康区'  LIMIT 20")data <- fetch(query, n = -1)print(data)dbDisconnect(conn)

> print(data)user_id province   city district
1  191805022214   江西省 赣州市   南康区
2  191805022214   江西省 赣州市   南康区
3  191805022214   江西省 赣州市   南康区
4  191805022214   江西省 赣州市   南康区
5  191805022214   江西省 赣州市   南康区
6  191805835201   江西省 赣州市   南康区
7  191805835201   江西省 赣州市   南康区
8  191805835201   江西省 赣州市   南康区
9  191805835201   江西省 赣州市   南康区
10 191806098337   江西省 赣州市   南康区
11 191806098337   江西省 赣州市   南康区
12 191806098337   江西省 赣州市   南康区
13 191806098337   江西省 赣州市   南康区
14 191806098337   江西省 赣州市   南康区
15 191806098337   江西省 赣州市   南康区
16 191806191478   江西省 赣州市   南康区
17 191806191478   江西省 赣州市   南康区
18 191806191478   江西省 赣州市   南康区
19 191806191478   江西省 赣州市   南康区
20 191806385456   江西省 赣州市   南康区

3.3、 R语言调用mysql 存储过程

rm(list=ls())
gc()
library(RMySQL)
########建立本地连接mysql
conn <- dbConnect(MySQL(), dbname = "cgjr", username="root", password="12345",client.flag=CLIENT_MULTI_STATEMENTS)
dbSendQuery(conn,'SET NAMES gbk')
query<-dbSendQuery(conn, "call add_student(3)")##########关闭连接
dbDisconnect(conn)