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中。这样做可以提供更好的可靠性和灵活性。