锟斤拷锟斤拷位锟矫ｏ拷锟斤拷页 > 锟斤拷锟斤拷锟教筹拷 > 锟教筹拷 > MySQL锟皆讹拷锟藉函锟斤拷实锟斤拷锟斤拷锟捷匡拷锟斤拷锟捷变化通知锟斤拷锟斤拷锟斤拷系统

MySQL锟皆讹拷锟藉函锟斤拷实锟斤拷锟斤拷锟捷匡拷锟斤拷锟捷变化通知锟斤拷锟斤拷锟斤拷系统

锟斤拷源锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷|锟斤拷时锟戒：2024-06-26 08:49:16 |锟斤拷锟侥讹拷锟斤拷177锟斤拷|锟斤拷锟斤拷签锟斤拷 NCT 系 T DeFi 知锟斤拷 S C in 锟斤拷锟斤拷 udp 锟斤拷锟斤拷锟斤拷锟捷匡拷锟斤拷 |锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷

锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟捷匡拷锟斤拷某锟斤拷锟街段碉拷值锟斤拷为锟截讹拷值时锟斤拷实时锟斤拷锟斤拷锟斤拷息通知锟斤拷锟斤拷锟斤拷系统锟斤拷实锟斤拷思路锟斤拷锟斤拷锟斤拷菘锟斤拷锟斤拷囟锟斤拷侄锟街碉拷谋浠拷锟斤拷锟斤拷锟斤拷锟斤拷菘獯ワ拷锟斤拷锟绞碉拷帧锟斤拷锟斤拷锟揭碉拷锟揭伙拷锟斤拷远锟斤拷锟侥猴拷锟斤拷锟斤拷锟斤拷锟斤拷一锟斤拷锟街凤拷锟斤拷锟斤拷锟斤拷锟斤拷然锟斤拷锟斤拷锟斤拷址锟斤拷锟酵拷锟絬dp锟斤拷息锟斤拷锟酵碉拷指锟斤拷锟剿口★拷锟节达拷锟斤拷锟斤拷锟斤拷执锟斤拷锟斤拷锟斤拷远锟斤拷搴拷锟斤拷锟斤拷锟斤拷锟斤拷锟较低筹拷屑锟斤拷锟街革拷锟斤拷丝诘锟斤拷锟较拷锟斤拷佣锟�

锟斤拷锟斤拷锟捷匡拷锟斤拷某锟斤拷锟街段碉拷值锟斤拷为锟截讹拷值时锟斤拷锟斤拷要实时锟斤拷锟斤拷锟斤拷息通知锟斤拷锟斤拷锟斤拷系统锟斤拷为锟斤拷实锟斤拷锟斤拷一锟斤拷锟杰ｏ拷锟斤拷锟斤拷通锟斤拷锟斤拷锟斤拷锟斤拷菘锟斤拷锟斤拷囟锟斤拷侄锟街碉拷谋浠拷锟绞碉拷帧锟斤拷锟斤拷锟斤拷通锟斤拷使锟斤拷锟斤拷锟捷库触锟斤拷锟斤拷锟斤拷锟斤拷伞锟酵憋拷锟斤拷锟斤拷锟揭碉拷锟揭伙拷锟斤拷远锟斤拷锟侥猴拷锟斤拷锟斤拷锟矫猴拷锟斤拷锟杰癸拷锟斤拷锟斤拷一锟斤拷锟街凤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟街凤拷锟斤拷通锟斤拷UDP锟斤拷息锟斤拷锟酵碉拷指锟斤拷锟剿口★拷

锟节达拷锟斤拷锟斤拷锟斤拷执锟斤拷锟斤拷锟斤拷远锟斤拷搴拷锟斤拷锟斤拷锟斤拷锟斤拷锟较低筹拷屑锟斤拷锟街革拷锟斤拷丝诘锟斤拷锟较拷锟斤拷佣锟绞碉拷锟斤拷锟斤拷菘锟斤拷锟斤拷荼浠ㄖ拷锟斤拷锟斤拷锟较低筹拷墓锟斤拷堋锟�

锟斤拷锟斤拷前准锟斤拷

MySQL锟皆讹拷锟藉函锟斤拷锟斤拷支锟斤拷C/C++锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟揭拷弑锟揭伙拷锟斤拷锟紺/C++锟斤拷锟斤拷锟斤拷锟节憋拷锟斤拷锟叫ｏ拷锟斤拷锟斤拷锟斤拷锟斤拷Windows系统使锟斤拷Visual Studio2022锟斤拷锟叫匡拷锟斤拷锟侥凤拷锟斤拷锟斤拷锟斤拷锟斤拷前锟斤拷要锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷libmysql.lib锟斤拷ws2_32.lib锟斤拷锟斤拷锟斤拷锟斤拷头锟侥硷拷"mysql.h"锟斤拷锟斤拷锟斤拷

锟皆讹拷锟藉函锟斤拷锟斤拷锟斤拷为SendG锟斤拷使锟矫凤拷式为SendG('abcde')锟斤拷

MySQL锟皆讹拷锟藉函锟斤拷锟斤拷锟剿碉拷锟�

锟斤拷锟斤拷锟斤拷锟截讹拷锟斤拷锟斤拷时锟斤拷锟皆讹拷锟藉函锟斤拷锟斤拷锟斤拷婕帮拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷直锟斤拷锟絊endG_init锟斤拷SendG锟斤拷

SendG_init锟斤拷一锟斤拷前锟矫猴拷锟斤拷锟斤拷锟斤拷锟节硷拷锟斤拷锟斤拷锟角凤拷锟斤拷确锟斤拷SendG锟斤拷锟斤拷锟藉函锟斤拷锟斤拷锟斤拷锟斤拷执锟叫撅拷锟斤拷锟揭碉拷锟斤拷呒锟斤拷锟矫匡拷蔚锟斤拷锟絊endG('abcde') 锟斤拷锟斤拷锟饺碉拷锟斤拷SendG_init锟斤拷锟斤拷锟斤拷然锟斤拷呕锟斤拷锟斤拷锟斤拷锟藉函锟斤拷锟叫碉拷业锟斤拷锟竭硷拷锟斤拷UDF_INIT锟斤拷UDF_ARGS锟饺结构锟斤拷使锟矫凤拷锟斤拷锟斤拷锟斤拷锟斤拷MySQL锟斤拷头锟侥硷拷锟斤拷锟揭碉拷锟斤拷细锟斤拷锟杰★拷

MySQL自定义函数实现数据库内容变化通知到其他系统

锟斤拷锟斤拷实锟街达拷锟斤拷

锟斤拷锟斤拷锟斤拷锟皆讹拷锟藉函锟斤拷SendG锟侥撅拷锟斤拷实锟街达拷锟诫：

#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锟结供锟剿匡拷锟斤拷锟皆讹拷锟藉函锟斤拷锟侥癸拷锟杰★拷实锟斤拷锟较ｏ拷锟斤拷锟角匡拷锟斤拷执锟斤拷锟斤拷锟斤拷锟皆硷拷写锟斤拷锟斤拷锟斤拷锟斤拷耄拷锟斤拷锟斤拷锟斤拷欠锟斤拷锟経DP/TCP锟斤拷息锟斤拷锟斤拷锟斤拷锟斤拷锟皆凤拷锟斤拷锟绞硷拷锟斤拷锟皆讹拷锟藉函锟斤拷锟斤拷锟斤拷坪筒锟斤拷锟斤拷锟皆硷拷锟斤拷锟斤拷锟秸筂ySQL锟侥癸拷锟杰★拷

小锟斤拷锟狡硷拷锟侥讹拷