MySQL自定义函数(User Define Function)开发实例——发送TCP/UDP消息

mysql,user,define,function,tcp,udp · 浏览次数 : 0

小编点评

开发背景 当数据库中某个字段的值改为特定值时,实时发送消息通知到其他系统。实现思路监控数据库中特定字段值的变化可以用数据库触发器实现。还需要实现一个自定义的函数,接收一个字符串参数,然后将这个字符传通过udp消息发送到指定端口。在触发器中执行这个自定义函数并在其他系统中监听指定端口的消息。从而实现数据库内容变化通知到其他系统的功能。 开发前准备 MySQL自定义函数仅支持C/C++开发,所以需要一些C/C++的基础。这里以在Windows系统使用Visual Studio2022开发进行介绍。添加依赖项libmysql.lib、ws2_32.lib,引入头文件"mysql.h"、。自定义函数命名为SendG,使用方式为SendG('abcde')。 MySQL自定义函数设计说明 提前说明:本文只介绍满足前面提到的需要的情况下涉及到的自定义函数设计方法。这里要涉及两个方法bool SendG_init(UDF_INIT* init, UDF_ARGS* args, char* message) 和 void SendG(UDF_INIT* init, UDF_ARGS* args, char* result, unsigned long* length, char* is_null, char* error)。主体函数当我们每次调用SendG('abcde') 首先会调用 _init后缀的函数,然后才会调用主体函数中的业务逻辑。因此我们可以在SendG_init函数中检查参数是否正确,在SendG函数中执行具体的业务逻辑。至于UDF_INIT、UDF_ARGS等结构的使用方法则不用担心,MySQL的头文件中有详细介绍,基本一看就能大概知道怎么用。 具体实现代码 ```cpp #include "pch.h" #include #include "mysql.h" #include extern "C" { __declspec(dllexport) bool SendG_init(UDF_INIT* init, UDF_ARGS* args, char* message) { if (args->arg_count != 1) { return true; } else if (args->arg_type[0] != STRING_RESULT) { return true; } return false; } __declspec(dllexport) void SendG(UDF_INIT* init, UDF_ARGS* args, char* result, unsigned long* length, char* is_null, char* error) { SOCKET sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP); sockaddr_in RecvAddr{}; RecvAddr.sin_family = AF_INET; RecvAddr.sin_port = htons(54321); inet_pton(AF_INET, "127.0.0.1", &RecvAddr.sin_addr); *is_null = 1; sendto(sock, args->args[0], args->lengths[0], 0, (SOCKADDR*)&RecvAddr, sizeof(RecvAddr)); closesocket(sock); } } ``` 我们在SendG_init中检查参数的个数和类型是否正确,SendG_init的返回值true代表有错误,false才表示没问题。然后会执行SendG主体函数,这里创建一个SOCKET使用UDP协议将传入的字符串发送给本机的54321端口,最后关闭SOCKET。 这里需要注意两点: 1、函数必须使用extern "C"导出C语言格式的函数 2、在这个例子中SendG方法是不需要有执行结果的,所以它的返回值类型是void,其次因为没有返回值所以这里必须使用*is_null=1允许方法返回NULL。如果有返回值则正常返回具体的类型,可选的返回值类型在Item_result中定义。 自定义函数的部署与卸载 首先将生成的dll放在MySQL的plugin目录中,可使用select @@plugin_dir查询。然后使用CREATE FUNCTION SendG RETURNS string SONAME 'SUDP.dll'部署函数。现在执行select SendG('abcde')就会向54321端口发送abcde了。可以让SendG接受两个参数,把端口号作为第二个参数,这样SendG函数的功能就更加灵活了。 卸载使用DROP FUNCTION SendG; 总结 MySQL的UDF提供了开发自定义函数的功能,实际在这里我们可以执行我们自己写的任意代码,别说发UDP/TCP消息了就是发邮件都行。

正文

开发背景

当数据库中某个字段的值改为特定值时,实时发送消息通知到其他系统。

实现思路

监控数据库中特定字段值的变化可以用数据库触发器实现。还需要实现一个自定义的函数,接收一个字符串参数,然后将这个字符传通过udp消息发送到指定端口。

在触发器中执行这个自定义函数并在其他系统中监听指定端口的消息。从而实现数据库内容变化通知到其他系统的功能。

开发前准备

MySQL自定义函数仅支持C/C++开发,所以需要一些C/C++的基础。

这里以在Windows系统使用Visual Studio2022开发进行介绍。

添加依赖项libmysql.lib、ws2_32.lib,引入头文件"mysql.h" <winsock2.h>  <ws2tcpip.h>

自定义函数命名为SendG,使用方式为SendG('abcde') 

MySQL自定义函数设计说明

提前说明:本文只介绍满足前面提到的需要的情况下涉及到的自定义函数设计方法。

这里要涉及两个方法

bool SendG_init(UDF_INIT* init, UDF_ARGS* args, char* message)   这个后缀_init方法显然是一个前置函数

void SendG(UDF_INIT* init, UDF_ARGS* args, char* result, unsigned long* length, char* is_null, char* error) 主体函数

当我们每次调用SendG('abcde') 首先会调用 _init后缀的函数,然后才会调用主体函数中的业务逻辑。因此我们可以在SendG_init函数中检查参数是否正确,在SendG函数中执行具体的业务逻辑。

至于UDF_INIT   UDF_ARGS等结构的使用方法则不用担心,MySQL的头文件中有详细介绍,基本一看就能大概知道怎么用,例如以下是UDF_ARGS的定义:

具体实现代码

#include "pch.h"
#include <winsock2.h>
#include "mysql.h"
#include <ws2tcpip.h>
extern "C" {
    __declspec(dllexport)
        bool SendG_init(UDF_INIT* init, UDF_ARGS* args, char* message) {
        if (args->arg_count != 1) 
            return true;
        else if (args->arg_type[0] != STRING_RESULT)
            return true;
        return false;
    }
    __declspec(dllexport)
    void SendG(UDF_INIT* init, UDF_ARGS* args, char* result, unsigned long* length, char* is_null, char* error) {
        SOCKET sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
        sockaddr_in RecvAddr{};
        RecvAddr.sin_family = AF_INET;
        RecvAddr.sin_port = htons(54321);
        inet_pton(AF_INET, "127.0.0.1", &RecvAddr.sin_addr);
        *is_null = 1;
        sendto(sock, args->args[0], args->lengths[0], 0, (SOCKADDR*)&RecvAddr,sizeof(RecvAddr));
        closesocket(sock);
    }
}

我们在SendG_init中检查参数的个数和类型是否正确,SendG_init的返回值true代表有错误,false才表示没问题。

然后会执行SendG主体函数,这里创建一个SOCKET使用UDP协议将传入的字符串发送给本机的54321端口,最后关闭SOCKET。

这里需要注意两点:

1、函数必须使用extern "C"导出C语言格式的函数

2、在这个例子中SendG方法是不需要有执行结果的,所以它的返回值类型是void,其次因为没有返回值所以这里必须使用*is_null=1允许方法返回NULL。如果有返回值则正常返回具体的类型,可选的返回值类型在Item_result中定            义它与UDF_ARGS在同一个头文件中,这里就不具体展开了。

自定义函数的部署与卸载

首先将生成的dll放在MySQL的plugin目录中,可使用select @@plugin_dir查询。然后使用CREATE FUNCTION SendG RETURNS string SONAME 'SUDP.dll'  部署函数

现在执行select SendG('abcde')就会向54321端口发送abcde了。可以让 SendG接受两个参数,把端口号作为第二个参数,这样SendG函数的功能就更加灵活了。

卸载使用 DROP FUNCTION SendG;

总结

MySQL的UDF提供了开发自定义函数的功能,实际在这里我们可以执行我们自己写的任意代码,别说发UDP/TCP消息了就是发邮件都行。

与MySQL自定义函数(User Define Function)开发实例——发送TCP/UDP消息相似的内容:

MySQL自定义函数(User Define Function)开发实例——发送TCP/UDP消息

开发背景 当数据库中某个字段的值改为特定值时,实时发送消息通知到其他系统。 实现思路 监控数据库中特定字段值的变化可以用数据库触发器实现。还需要实现一个自定义的函数,接收一个字符串参数,然后将这个字符传通过udp消息发送到指定端口。 在触发器中执行这个自定义函数并在其他系统中监听指定端口的消息。从而

Linux 提权-MySQL UDF

本文通过 Google 翻译 MySQL User Defined Functions – Linux Privilege Escalation 这篇文章所产生,本人仅是对机器翻译中部分表达别扭的字词进行了校正及个别注释补充。 导航 0 前言 1 什么是用户定义函数 (UDF) ? 2 枚举 UDF

[转帖]mysql 自动设置my.ini、my.cnf中basedir和datadir的相对路径

在实际生产中,我们经常用到mysql的安装,但是每次都需要手动设置配置文件中basedir和datadir的路径,但路径又基本上是当前安装路径,那我们是不是可以设置成自动配置成相对路径呢,当然可以。 我们新建一个文本文档,然后粘贴一下代码: @echo off set "pth=%~dp0" set

字节面试:MySQL自增ID用完会怎样?

在一些中小型项目开发中,我们通常会使用自增 ID 来作为主键的生成策略,但随着时间的推移,数据库的信息也会越来越多,尤其是使用自增 ID 作为日志表的主键生成策略时,可能很快就会遇到 ID 被用完的情况,那么如果发生了这种情况,MySQL 又会怎样执行呢? PS:当然,在分库分表的场景中,我们通常会

[转帖]实测:云RDS MySQL性能是自建的1.6倍

https://www.cnblogs.com/zhoujinyi/p/16392223.html 1. 摘要 基于之前写的「云厂商 RDS MySQL 怎么选」的文章,为了进一步了解各云厂商在RDS MySQL数据库性能上的差异,本文将对自建MySQL、阿里云、腾讯云、华为云和AWS 的 RDS

[转帖]MySQL 8.0.19 instant add column,亿级数据秒速增加字段

一、MySQL DDL 的方法 MySQL 在大型表上的 DDL 会带来耗时较久、负载较高、额外空间占用、MDL、主从同步延时等情况。需要特别引起重视,而MySQL 的 DDL 有很多种方法。 MySQL 本身自带三种方法,分别是:copy、inplace、instant。 copy 算法为最古老的

Vitess全局唯一ID生成的实现方案

为了标识一段数据,通常我们会为其指定一个唯一id,比如利用MySQL数据库中的自增主键。 但是当数据量非常大时,仅靠数据库的自增主键是远远不够的,并且对于分布式数据库只依赖MySQL的自增id无法满足全局唯一的需求。因此,产生了多种解决方案,如UUID,SnowFlake等。下文将介绍Vitess是如何解决这个问题的。

解读MySQL 8.0数据字典的初始化与启动

本文分享自华为云社区《MySQL全文索引源码剖析之Insert语句执行过程》,作者:GaussDB 数据库。 本文主要介绍MySQL 8.0数据字典的基本概念和数据字典的初始化与启动加载的主要流程。 MySQL 8.0数据字典简介 数据字典(Data Dictionary, DD)用来存储数据库内部

[转帖]MySQL事务的开启与提交,autocommit自动提交功能

MySQL事务的开启与提交,autocommit自动提交功能 https://www.cnblogs.com/deverz/p/6547866.html 对于一个MySQL数据库(InnoDB),事务的开启与提交模式无非下面这两种情况:1、若参数autocommit=0,事务则在用户本次对数据进行操

解读GaussDB(for MySQL)灵活多维的二级分区表策略

本文分享自华为云社区《GaussDB(for MySQL)创新特性:灵活多维的二级分区表策略》,作者:GaussDB 数据库。 背景介绍 分区表及二级分区表的功能,可以让数据库更加有效地管理和查询大规模数据,传统商业数据库具备该能力。MySQL支持分区表,与传统商业数据库相比,MySQL对二级分区表