R语言实现每3秒重复执行数据库查询代码的方法咨询

1. 有没有类似ReactiveFileReader的数据库专用函数？ #

当然有！如果你是在Shiny应用里做交互式展示，Shiny自带的reactivePoll()就是完美替代——它和ReactiveFileReader逻辑类似，但专门针对数据库这类需要主动查询更新的场景设计。

它的工作逻辑很清晰：

• 先运行一个checkFunc检查函数，判断数据库数据是否有变化（比如查询表的行数、最后修改时间）
• 一旦检测到变化，就触发valueFunc取值函数重新拉取数据

2. 两种定时刷新的代码示例 #

场景一：Shiny应用中使用（推荐用于交互式展示）

这里给你一个完整的Shiny小应用，每3秒自动检查并刷新数据：

library(shiny)
library(RMySQL)

ui <- fluidPage(
  # 用表格展示实时刷新的数据
  tableOutput("refreshed_table")
)

server <- function(input, output, session) {
  # 封装数据库连接逻辑，避免重复创建连接
  get_db_conn <- function() {
    dbConnect(MySQL(), 
              user='root', 
              password='password', 
              dbname='test_data', 
              host='localhost')
  }
  
  # 使用reactivePoll实现定时刷新
  updated_data <- reactivePoll(
    intervalMillis = 3000, # 设置3秒一次的刷新间隔
    session = session,
    # 检查函数：用表的行数判断是否有新数据（你也可以用更精准的时间戳）
    checkFunc = function() {
      conn <- get_db_conn()
      on.exit(dbDisconnect(conn)) # 确保每次检查后关闭连接
      rs <- dbSendQuery(conn, "SELECT COUNT(*) FROM rawdata")
      row_count <- fetch(rs, n = 1)[[1]]
      row_count
    },
    # 取值函数：重新获取完整数据表
    valueFunc = function() {
      conn <- get_db_conn()
      on.exit(dbDisconnect(conn))
      rs <- dbSendQuery(conn, "SELECT * FROM rawdata")
      fetch(rs)
    }
  )
  
  # 渲染刷新后的表格
  output$refreshed_table <- renderTable({
    updated_data()
  })
}

shinyApp(ui, server)

场景二：普通R脚本中定时刷新（适合后台运行）

如果不需要界面，只是在脚本里循环刷新数据，可以用Sys.sleep()配合循环实现：

library(RMySQL)

# 封装获取数据的函数
fetch_mysql_data <- function() {
  mydb <- dbConnect(MySQL(), 
                    user='root', 
                    password='password', 
                    dbname='test_data', 
                    host='localhost')
  on.exit(dbDisconnect(mydb)) # 每次查询后关闭连接，防止连接溢出
  rs <- dbSendQuery(mydb, "SELECT * FROM rawdata")
  fetch(rs)
}

# 循环执行，每3秒刷新一次
while(TRUE) {
  data <- fetch_mysql_data()
  # 这里可以替换成你需要的操作，比如打印前几行或者保存到文件
  cat("数据已刷新，当前时间：", Sys.time(), "\n")
  print(head(data))
  Sys.sleep(3) # 暂停3秒后再次刷新
}

一些实用小提示 #

• 一定要记得用dbDisconnect()关闭连接，不然数据库的连接数会被快速占满
• 如果你的表数据量很大，用COUNT(*)做检查可能效率不高，可以改成查询表的最后更新时间（比如给表加个update_time字段，或者用SHOW TABLE STATUS LIKE 'rawdata'获取系统维护的更新时间）
• 普通脚本的循环要停止的话，按Ctrl + C就可以中断运行

内容的提问来源于stack exchange，提问作者Mr.KT