Canal adapter同步MySQL到ES,部分时间字段始终同步不过来

news2024/12/24 0:53:15

在这里插入图片描述
在这里插入图片描述
解决思路:把查出来的字符串格式化一下

MySQL查出来的20180116120000这个如何转换成2018-01-16
这是一个常见的需求,我们通常在MySQL中使用DATE或DATETIME函数将字符串格式转换为日期或日期时间格式。但是,你的数字并不符合MySQL直接转换的标准格式。你需要先将它转换为标准的日期格式字符串。

假设这个数字存在名为my_column的列中,所在表为my_table,你可以使用以下SQL查询来实现:

SELECT DATE_FORMAT(STR_TO_DATE(my_column, '%Y%m%d%H%i%s'), '%Y-%m-%d') as formatted_date
FROM my_table;

这个查询的工作方式是:

  1. 使用STR_TO_DATE函数将你的数字转换为一个日期时间值。‘%Y%m%d%H%i%s’ 是一个格式字符串,它告诉MySQL如何解析数字。在这个例子中,‘%Y’是四位数年份,’%m’是月份,‘%d’是日期,’%H’是小时,‘%i’是分钟,’%s’是秒。
  2. 然后,使用DATE_FORMAT函数将日期时间值转换为你需要的格式,‘%Y-%m-%d’,其中’%Y’表示四位数年份,‘%m’表示月份,’%d’表示日期。

请注意,这个查询假设你的数字始终代表有效的日期和时间。如果这不是情况,你可能需要更复杂的处理。

然而最好保留时分秒

如果你需要保留时间部分,你可以简单地调整DATE_FORMAT函数的格式字符串以包含时、分、秒。例如,如果你需要格式为 ‘2018-01-16 12:00:00’,你可以使用以下查询:

SELECT DATE_FORMAT(STR_TO_DATE(CRT_TIME, '%Y%m%d%H%i%s'), '%Y-%m-%d %H:%i:%s') as formatted_date
FROM tbl_ps_device_info;

在这个查询中,'%Y-%m-%d %H:%i:%s' 是一个格式字符串,其中 %Y 代表四位数年份,%m 代表月份,%d 代表日期,%H 代表小时,%i 代表分钟,%s 代表秒。因此,DATE_FORMAT函数将日期时间值转换为这种格式。

举个例子:
从tbl_ps_device_info表中查CRT_TIME这个字段

如果你想从tbl_ps_device_info表中查询CRT_TIME字段,并将其转换为日期格式(如 ‘2018-01-16’),你可以使用类似的查询:

SELECT DATE_FORMAT(STR_TO_DATE(CRT_TIME, '%Y%m%d%H%i%s'), '%Y-%m-%d') as formatted_date
FROM tbl_ps_device_info;

这个查询会从tbl_ps_device_info表中获取所有的CRT_TIME记录,然后使用STR_TO_DATE函数将它们转换为日期时间,然后使用DATE_FORMAT函数将日期时间转换为你需要的日期格式。

同样,这个查询假设CRT_TIME始终代表有效的日期和时间。如果可能有无效的日期时间,你可能需要更复杂的处理,例如使用IF函数检查STR_TO_DATE的结果是否为NULL

在这里插入图片描述

最终写成完整SQL:

SELECT 
    info.DEVICE_NO as _id, 
    info.DEVICE_NO, 
    info.DEVICE_NAME, 
    info.DEVICE_TYPE, 
    info.PARK_NO, 
    info.CHNO_NO, 
    info.IF_CONTROL, 
    info.CONTROLTIMES,
    info.STATUS, 
    info.STATUS_CHANGE_TIME, 
    DATE_FORMAT(STR_TO_DATE(info.CRT_TIME, '%Y%m%d%H%i%s'), '%Y-%m-%d %H:%i:%s') as CRT_TIME, 
    info.UPD_TIME, 
    info.OPR_FLAG, 
    info.ITEMID, 
    info.DELETED,
    info.INOUTTYPE, 
    info.IF_DOWN, 
    info.SUB_DEVICE_TYPE, 
    info.ORG_ID 
FROM 
    tbl_ps_device_info info
    --------
    #注意最后的分号也不能写,不然会拼接where条件错误

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

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

相关文章

论文解读:PeSTo:用于精确预测蛋白质结合界面的无参数几何深度学习

Title:PeSTo: parameter-free geometric deep learning for accurate prediction of protein binding interfaces 期刊:nature communication 分区:一区 影响因子:16.6 webserver:t Pesto Github:GitHub - LBM-EPFL/PeSTo 摘要 蛋白质是…

Self-supervised Graph Learning for Recommendation(SGL)

Code:GitHub - wujcan/SGL-Torch: SGL PyTorch version(作者给出了Pytorch和Tensorflow两个版本) 本文提出了一种应用于用户-物品二分图推荐系统的图自监督学习框架。核心的思想是,对用户-物品二部图做数据增强(本文提…

ActiveMQ一文解读

消息队列中间件是分布式系统中重要的组件,主要解决应用耦合、异步消息、流量削锋等问题,实现高性能、高可用、可伸缩和最终一致性架构,是大型分布式系统不可缺少的中间件。 目前在生产环境中使用较多的消息队列有 ActiveMQ、RabbitMQ、ZeroM…

42. 会话划分问题

文章目录 题目需求思路一实现一题目来源 题目需求 现有页面浏览记录表(page_view_events)如下,每行数据代表:每个用户的每次页面访问记录。 规定若同一用户的相邻两次访问记录时间间隔小于60s,则认为两次浏览记录属于…

紧急提醒,你的计算机或许已中招,赶快进行排查

大家早上好,我是YUAN。 这几天,安全圈又曝出了一个重大漏洞。如果你的电脑使用的是技嘉-GIGABYTE主板,那么你可能已经中招了,但还不知情。 在介绍这个漏洞之前,让我们思考一个问题:如果产品经理让你实现一…

基于Selenium+Python实现自动解数独,秒变最强大脑

前言 在本文中,我将向大家介绍如何使用Python编写一个数独脚本,并实现模拟完成数独游戏的脚本。数独是一种经典的逻辑游戏,它可以帮助我们锻炼逻辑思维能力。通过编写数独脚本,我们可以使用Python语言解决数独问题,从而…

一、枚举类型——新特性(模式匹配-覆盖范围)

模式匹配会引导你逐渐使用 sealed 关键字,这有助于确保你已覆盖了所有可能传入选择器表达式的类型。不过接下来再看一个示例: SealedPatternMatch.java JDK 17 import java.util.List;sealed interface Transport { };record Bicycle(String id) impleme…

第八章:YOLO v3(渐进式改进)网络详解

(目标检测篇)系列文章目录 第一章:R-CNN网络详解 第二章:Fast R-CNN网络详解 第三章:Faster R-CNN网络详解 第四章:SSD网络详解 第五章:Mask R-CNN网络详解 第六章:YOLO v1网络详解 第七章:YOLO v2网络详解 第八章:YOLO v3网络详解 文章目录 系列文章目录技…

ruiyo-cloud-plus集成shardingsphere-proxy进行分库分表

一、什么shardingsphere-proxy Sharding-Proxy是ShardingSphere的第二个产品。 它定位为透明化的数据库代理端,提供封装了数据库二进制协议的服务端版本,用于完成对异构语言的支持。 目前先提供MySQL版本,它可以使用任何兼容MySQL协议的访问…

阿里云轻量应用服务器和云服务器ECS有什么区别?

阿里云服务器ECS和轻量应用服务器有什么区别?云服务器ECS是明星级云服务器,轻量应用服务器可以理解为简化版的云服务器ECS,轻量适用于单机应用,云服务器ECS适用于集群类高可用高容灾应用,阿里云百科来详细说下阿里云轻…

用栈实现队列——力扣232

题目描述 思路 class MyQueue {stack<int> inStack, outStack;void in2out(){while(!inStack.empty()){outStack.push(inStack.top());inStack.pop();}} public:MyQueue() {}void push(int x) {inStack.push(x);}int pop() {if(outStack.empty()){in2out();}int x out…

etiger.vip 答案 1907最高的山

1907.最高的山 题目描述 有n座山&#xff0c;编号从1到n&#xff0c;第i座山的高度为hi&#xff0c;请问其中最高的山是哪一座&#xff1f; 输入输出格式 输入格式 第一行一个正整数n&#xff0c;表示山的数量&#xff0c;n<1000。 第二行n个正整数&#xff0c;中间由空…

四元数转换为一个旋转矩阵

#include <iostream> #include <vector> #include <Eigen/Core> #include <Eigen/Geometry> #

回调函数的应用(sqort函数)——指针进阶(三)

目录 前言 什么是回调函数&#xff1f; 回调函数的应用 qsort函数 qsort函数的使用 qsort模拟实现 模拟函数的使用 总结 前言 回调函数是一种非常常见的编程技术&#xff0c;在许多不同的编程语言和框架中都有广泛的应用。但它到底是什么&#xff0c;以及如何使用呢&#xff1…

-XX:MaxDirectMemorySize

-XX:MaxDirectMemorySize最大堆外内存大小&#xff0c;此参数的含义是当Direct ByteBuffer分配的堆外内存到达指定大小后就触发Full GC。首先可以在jdk文档中找到&#xff1a;关于MaxDirectMemorySize内存的描述&#xff1a;Sets the maximum total size (in bytes) of the New…

02_06内核cpu信息及内存布局及堆管理及内存使用情况

linux_cpu_大致信息查看 因为需要知道当前linux cpu是多少位的,才能知道内核空间的分布 64位Linux-般使用48位来表示虚拟地址空间&#xff0c;45位表示物理地址。通过命令: cat/proc/cpuinfo。 查看Linux内核位数和proc文件系统输出系统软硬件信息如下: 通过cat /proc/cpuinfo…

RabbitMQ笔记--消息中间件,rabbitmq安装及简单使用

1.消息中间件 消息&#xff1a;指在应用间传送的数据。 消息队列中间件&#xff1a;指利用高效可靠的消息传递机制进行与平台无关的数据交流&#xff0c;并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型&#xff0c;可以在分布式环境下扩展进程间的通…

unittest自动化测试之unittest封装方法

目录 封装方法 完整代码 总结&#xff1a; 封装方法 在编写自动化脚本的时候&#xff0c;都要求代码简介&#xff0c;上一篇unittest---unittest断言中代码重复性比较多&#xff0c;我们进行一次简单的优化&#xff08;优化方法不同&#xff0c;请勿喷&#xff09; 我们可以…

Video4linux: cannot set V4L control... 解决方案

问题描述 最近在用USB_CAM读取摄像头的时候&#xff0c;总是出现如下问题&#xff1a; 思来想去真是难受。 问题分析 在usb_cam/ config /usb_cam.yaml文件中&#xff0c;把他报错的东西加在ignore里面即可。 首先打开camera_driver.cpp文件&#xff0c;把908行的printf语句…

ARM64学习笔记---建立异常向量表(二)

源码: #include "mm.h" #include "sysregs.h".section .rodata .align 3 .globl el_string1 el_string1:.string "Booting at EL".section ".text.boot" .globl _start _start://读取mpidr_el1寄存器的值&#xff0c;该寄存器决定了…