R SQL package

sqldf()는 SQL문에 따라 스키마를 생성하고 데이터를 테이블에 로딩,수행한 후 데이터셋을 R로 객체로 로딩한다. 내부적으로 sqlite를 저장소로 사용한다.

> library(sqldf)
> sqldf('select * from iris where Speicies="setosa"')
Error in result_create(conn@ptr, statement) : no such column: Speicies
> head(sqldf('select * from iris where Species="setosa"'))
  Sepal.Length Sepal.Width Petal.Length Petal.Width Species
1          5.1         3.5          1.4         0.2  setosa
2          4.9         3.0          1.4         0.2  setosa
3          4.7         3.2          1.3         0.2  setosa
4          4.6         3.1          1.5         0.2  setosa
5          5.0         3.6          1.4         0.2  setosa
6          5.4         3.9          1.7         0.4  setosa

 

RMySQL 사용 예로, 자세한 부분은 매뉴얼을 참고하자.

> library('RMySQL')
> conn<-dbConnect(MySQL(),host="192.168.100.185",user="root",password="yourpass",dbname="mysql")
> summary(conn)
<MySQLConnection:0,0>
  User:   root 
  Host:   192.168.100.185 
  Dbname: mysql 
  Connection type: 192.168.100.185 via TCP/IP 

Results:

> rs<-dbSendQuery(conn,"show tables")
> while(!dbHasCompleted(rs)) {
+   row<-dbFetch(rs)
+   print(row)
+ }
             Tables_in_mysql
1               column_stats
2               columns_priv
3                         db
4                      event
5                       func
6                general_log
7             gtid_slave_pos
8              help_category
9               help_keyword
10             help_relation
11                help_topic
12                      host
13               index_stats
14        innodb_index_stats
15        innodb_table_stats
16                    plugin
17                      proc
18                procs_priv
19              proxies_priv
20             roles_mapping
21                   servers
22                  slow_log
23               table_stats
24               tables_priv
25                 time_zone
26     time_zone_leap_second
27            time_zone_name
28      time_zone_transition
29 time_zone_transition_type
30                      user
> dbClearResult(rs)
[1] TRUE
> dbDisconnect(conn)
[1] TRUE