您的位置:首页 > 新闻 > 热点要闻 > go语言使用model Gorm MySQL查询数据 定时十分钟查询一次 查询十分钟前新建的数据

go语言使用model Gorm MySQL查询数据 定时十分钟查询一次 查询十分钟前新建的数据

2024/10/6 14:19:08 来源:https://blog.csdn.net/m0_67038390/article/details/139352958  浏览:    关键词: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中。这样做可以提供更好的可靠性和灵活性。

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com