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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/diannao/20271.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Practicing Version Control

Part A 新建一个文件夹Git&#xff0c;然后进入文件夹: Windows: 在这个文件夹中右键 > Open Git Bash hereMac: 运行终端&#xff0c;打cd 空格&#xff0c;然后将文件夹拖入终端&#xff0c;按 return 从 Github 上复制 HTTPS&#xff0c;然后 git clone https://githu…

16-云原生监控体系-rabbitmq_exporter监控 RabbitMQ-[部署Dashborad告警规则实战]

文章目录 1. 二进制方式部署1.1. 二进制包下载和部署1.2. 配置1.2.1. 可用的环境变量1.2.2. 使用变量2. docker-compose 方式部署3. 配置到 Prometheus3. Metrics3.1. 全局3.2. 基础信息3.3. Queues3.3.1 Queues - Gauge3.3.2. Queues - Counter

Fish语言编程:探索一种全新的编程范式

Fish语言编程&#xff1a;探索一种全新的编程范式 在浩瀚的编程海洋中&#xff0c;Fish语言以其独特的魅力吸引着无数编程爱好者的目光。作为一种全新的编程范式&#xff0c;Fish语言以其简洁、直观和强大的特性&#xff0c;为编程世界带来了新的活力。本文将从四个方面、五个…

数据库(12)——DQL聚合查询

常见的聚合函数 将一列数据作为一个整体&#xff0c;进行纵向计算。 函数功能count统计数量max最大值min最小值avg平均值sum求和 语法 SELECT 聚合函数 &#xff08;字段列表&#xff09;FROM 表名; 示例 这是我们的原始表&#xff1a; 求人物总数 select count(id) from in…

2024-06-01 问AI: 在大语言模型中,什么是single agent?

文心一言 在大语言模型&#xff08;LLM&#xff09;的语境中&#xff0c;特别是在涉及多智能体&#xff08;Multi-Agent&#xff09;系统的讨论中&#xff0c;Single-Agent&#xff08;单智能体&#xff09;指的是整个系统中仅设计了一个智能体来负责处理工作流中的各个环节。…

“开源与闭源:AI大模型发展的未来之路“

文章目录 每日一句正能量前言数据隐私开源大模型与数据隐私闭源大模型与数据隐私数据隐私保护的共同考虑结论 商业应用开源大模型的商业应用优势&#xff1a;开源大模型的商业应用劣势&#xff1a;闭源大模型的商业应用优势&#xff1a;闭源大模型的商业应用劣势&#xff1a;商…

Navicat使用ssh隧道连接mysql数据库

转载请标明出处&#xff1a;http://blog.csdn.net/donkor_/article/details/139352748 文章目录 前言新建连接MySql,填写ssh隧道信息方式1&#xff1a;使用密码方式连接方式二&#xff1a;使用密钥方式连接 填写常规信息总结 前言 使用ssh隧道连接数据库&#xff0c;方便本机…

docker和虚拟机的异同

Docker 和虚拟机&#xff08;Virtual Machine, VM&#xff09;都是用于隔离和运行应用程序的技术&#xff0c;但它们在实现方式、性能和使用场景上有显著的差异。以下是它们的主要异同点&#xff1a; 相同点 隔离性&#xff1a;两者都提供隔离环境&#xff0c;确保应用程序运…

2024抖音流量认知课:掌握流量底层逻辑,明白应该选择什么赛道 (43节课)

课程下载&#xff1a;https://download.csdn.net/download/m0_66047725/89360865 更多资源下载&#xff1a;关注我。 课程目录 01序言&#xff1a;拍前请看.mp4 02抖音建模逻辑1.mp4 03抖音标签逻辑2.mp4 04抖音推流逻辑3.mp4 05抖音起号逻辑4.mp4 06养号的意义.mp4 0…

Linux 多台机器之间的免密登录设置

生成公钥私钥 ssh-keygen -t rsa 一路回车即可 将公钥发送给需要免密的机群 # 格式&#xff1a;ssh-copy-id -i ~/.ssh/id_rsa.pub 用户名机群地址 ssh-copy-id -i ~/.ssh/id_rsa.pub hadoop192.168.0.1

【经典排序算法】堆排序(精简版)

什么是堆排序&#xff1a; 堆排序(Heapsort)是指利用堆&#xff08;完全二叉树&#xff09;这种数据结构所设计的一种排序算法&#xff0c;它是选择排序的一种。需要注意的是排升序要建大堆&#xff0c;排降序建小堆。 堆排序排序的特性总结&#xff1a; 1. 堆排序使用堆来选数…

flink left join消费kafka数据

left join会产生回车流数据 在控制台数据 import com.sjfood.sjfood.gmallrealtime.app.BaseSQLAPP; import com.sjfood.sjfood.gmallrealtime.util.SQLUtil; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.table.…

电脑设置密码怎么设置?让你的电脑更安全!

在如今信息化的社会中&#xff0c;保护个人电脑的安全至关重要。设置密码是最基本的电脑安全措施之一&#xff0c;它可以有效防止未经授权的访问和保护个人隐私&#xff0c;可是电脑设置密码怎么设置&#xff1f;本文将介绍三种设置电脑密码的方法&#xff0c;帮助您加强电脑的…

法线方程实现最小二乘拟合(Matlab)

一、问题描述 利用法线方程实现最小二乘拟合。 二、实验目的 掌握法线方程方法的原理&#xff0c;能够利用法线方程完成去一组离散数据点的拟合。 三、实验内容及要求 对于下面的不一致系统&#xff0c;构造法线方程&#xff0c;计算最小二乘以及2-范数误差。 [ 3 − 1 2 …

Nginx实战:LUA脚本_环境配置安装

目录 一、什么是LUA脚本 二、Nginx中的LUA脚本 1、主要特点 2、用途 三、如何在nginx中使用LUA脚本 1、原生nginx 2、OpenResty 3、nginx lua配置验证 一、什么是LUA脚本 Nginx Lua 脚本是 Nginx 与 Lua 语言集成的结果&#xff0c;它允许你使用 Lua 语言编写Nginx 模块…

(深度学习记录)第TR3周:Transformer 算法详解

&#x1f368; 本文为&#x1f517;365天深度学习训练营 中的学习记录博客&#x1f356; 原作者&#xff1a;K同学啊 | 接辅导、项目定制 文本的输入处理中&#xff0c;transformer会将输入文本序列的每个词转化为一个词向量&#xff0c;我们通常会选择一个合适的长度作为输入…

mysql中的模糊匹配

在MySQL中,模糊查询通常使用 LIKE 运算符和通配符来实现。模糊查询用于匹配满足特定模式的字符串,可以在字符串中使用通配符进行搜索。以下是关于MySQL模糊查询的详细介绍: LIKE 运算符 LIKE 运算符用于在WHERE子句中搜索列中的指定模式。可以使用两种通配符: %:表示零个…

若依分页问题排查

无限分页数据返回 一、问题排查1.1 代码排查1.2 sql排查1.3 原因分析 二、问题修复 项目使用了 若依的框架&#xff0c;前端反馈了一个问题&#xff0c;总记录条数只有 48条的情况下&#xff0c;传入的 页数时从6~~无穷大&#xff0c;每页大小为10, 此时还能返回数据&#xff0…

JSON源码类学习

json源码学习 parse把json转换成Object parseObject转换为jsonObject parseArray从字符串数组解析成真正的数组 tojsonString把真正的json解析json 数组的方法 作用&#xff1a;类型转换 为什么要做类型转换 开发一个方法验证 这个方法先封装方法&#xff0c;是否为json …

seaborn和matplotlib显示两条曲线图例

总结&#xff0c;添加label和plt.legend&#xff0c;以下由chatgpt生成 在使用 Seaborn 的 kdeplot&#xff08;核密度估计图&#xff09;时&#xff0c;显示图例也是一个常见需求&#xff0c;尤其是当你想比较多个不同分布的数据时。下面我将提供一个示例&#xff0c;说明如何…