go语言使用model Gorm MySQL查询数据 定时十分钟查询一次 查询十分钟前新建的数据
在Go语言中，使用GORM库与MySQL数据库交互并定时查询数据是常见的需求。以下是一个基本的示例，展示了如何设置定时任务，并使用GORM查询十分钟前新建的数据：
首先，你需要安装GORM和MySQL驱动：
```bash
go get -u gorm.io/gorm
go get -u gorm.io/driver/mysql
```
然后，假设你有一个模型`MyModel`，如下所示：
```go
package main
import (
"gorm.io/gorm"
"time"
)
type MyModel struct {
gorm.Model
// 其他字段...
}
```
接下来，你需要配置GORM连接到MySQL数据库，并设置定时任务：
```go
package main
import (
"fmt"
"gorm.io/driver/mysql"
"gorm.io/gorm"
"time"
)
func main() {
// 连接到MySQL数据库
dsn := "username:password@tcp(127.0.0.1:3306)/dbname?charset=utf8mb4&parseTime=True&loc=Local"
db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})
if err != nil {
panic("failed to connect database")
}
// 自动迁移schema
db.AutoMigrate(&MyModel{})
// 定时任务函数
ticker := time.NewTicker(10 * time.Minute)
done := make(chan bool)
go func() {
for {
select {
case <-done:
return
case <-ticker.C:
// 查询十分钟前新建的数据
tenMinutesAgo := time.Now().Add(-10 * time.Minute)
var models []MyModel
db.Where("created_at >= ?", tenMinutesAgo).Find(&models)
// 处理查询结果
for _, model := range models {
fmt.Printf("Found model with ID: %d, Created At: %s\n", model.ID, model.CreatedAt)
// ... 执行其他操作 ...
}
}
}
}()
// 让主goroutine等待，防止程序退出
<-make(chan struct{})
}
```
在上面的代码中，我们首先使用`gorm.Open`连接到MySQL数据库，并使用`AutoMigrate`自动迁移模型。然后，我们创建了一个`ticker`，它会每隔10分钟触发一次。在`go`函数中，我们监听`ticker`的通道以及一个用于停止定时任务的`done`通道。
当`ticker`触发时，我们计算十分钟前的时间点，并使用`Where`和`Find`方法来查询所有在这个时间点之后创建的数据。查询结果会存储在`models`切片中，你可以按照需求处理这些数据。
最后，主goroutine通过等待一个永远不会接收的通道来防止程序退出。在实际应用中，你可能需要添加适当的信号处理来优雅地停止定时任务和整个程序。
注意：在实际部署环境中，通常不会使用Go的`main`函数来运行定时任务，而是会使用像`cron`这样的系统任务调度器，或者使用专门的任务调度库如`robfig/cron`，或者将定时任务部署到Kubernetes的CronJob中。这样做可以提供更好的可靠性和灵活性。