SQL TypeC/C++ Type
[root@localhost zhxilin]#
我们定义一个最简单的UDF主函数：
{
int a = *((args[);
args[);
messagE)
{
由于mysql提供的接口是C实现的，我们在C++中使用时需要添加：
接下来编译成动态库.so：
[zhxilin@localhost mysql-
redis-test]$ g++
-shared -fPIC -I /usr/include/mysql -o simple_add.so simple.
-shared 表示编译和链接时使用的是全局共享的类库;
-fPIC编译器输出位置无关的目标代码，适用于动态库；
-I /usr/include/mysql 指明包含的头文件mysql.h所在的位置。
编译出simple_add.so后用root拷贝到/usr/lib64/mysql/plugin下：
[root@localhost mysql-
redis-test]#
紧接着可以在MySQL中创建函数执行了。登录MySQL，创建关联函数：
测试UDF函数：
@H_965_15@mysql 262_10288@ct simple_add();
C)
可以看到，UDF正确执行了加法。
创建UDF函数的语法是@R_262_2236@ION xxx RETURNS [IntegeR/StriNG/REAL] SONAME '[so name]';
删除UDF函数的语法是 DROP FUNCTION simple_add;
跟上述做法一样，只需在UDF里调用redis提供的接口函数。redis官方给出了https://github.com/mrpi/redis-cplusplus-client" target="_blank">redis C++ Client （https://github.com/mrpi/redis-cplusplus-client），封装了redis的基本操作。
源码是依赖boost，需要先安装boost：
[root@localhost dev]#
然后下载redis cpp client源码：
[root@localhost dev]# git clone
https:
redis-cplusplus-client
使用时需要把redisclient.h、anet.h、fmacros.h、anet.c 这4个文件考到目录下，开始编写关于redis的UDF。我们定义了redis_hset作为主函数，连接redis并调用hset插入哈希表，redis_hset_init作为初始化，检查参数个数和类型。
redisclient.hredis::client *m_client =redis_hset(UDF_INIT *initid,{
{
redis
{
redis_HOST);
String host = {
redis::client(host);
args && args->args[args[args[{
hset(args->args[args[args[{
{
redis::redis_error&E) {
redis_hset_init(UDF_INIT *initid,messagE) {
{
value) 需要三个参数
message,);E);
arg_type[!= StriNG_RESULT ||
arg_type[!= StriNG_RESULT ||
arg_type[!=StriNG_RESULT) {
message,E);
arg_type[StriNG_RESULT;
arg_type[StriNG_RESULT;
arg_type[StriNG_RESULT;
ptr =
编译链接：
[zhxilin@localhost mysql-
redis-test]$ g++ -shared -fPIC -I /usr/include/mysql -lboost_
serialization -lboost_system -lboost_thread -o libmy
redis.so anet.c test.cpp
编译时需要加上-lboost_serialization -lboost_system -lboost_thread， 表示需要链接三个动态库：libboost_serialization.so、libboost_system.so、libboost_thread.so，否则在运行时会报缺少函数定义的错误。
编译出libmyredis.so之后，将其拷贝到mysql的插件目录下并提权：
[root@localhost mysql-
redis-test]#
redis.so /usr/lib64/mysql/plugin/ & redis.so
完成之后登录MySQL，创建关联函数测试一下：
@mysql
redis_hset`;
Query OK,C)
@H_783_0@mysql<span style="color: #808080">> <span style="color: #0000ff">CREATE <span style="color: #0000ff">FUNCTION redis_hset <span style="color: #0000ff">RETURNS StriNG SONAME <span style="color: #ff0000">'<span style="color: #ff0000">libmyredis.so<span style="color: #ff0000">'<span style="color: #000000">;
Query OK,<span style="color: #800000; font-weight: bold">0 rows affected (<span style="color: #800000; font-weight: bold">0.02 seC)
先删除老的UDF，注意函数名加反引号（``）。调用UDF测试，返回0，执行成功：
@H_965_15@mysql 262_10288@CT redis_hset();
redis_hset(C)
打开redis-cli，查看结果：
四. 通过MySQL触发器刷新redis
在上一节的基础上，我们想让MySQL在增删改查的时候自动调用UDF，还需要借助MySQL触发器。触发器可以监听INSERT、updatE、deletE等基本操作。在MySQL中，创建触发器的基本语法如下：
trigGERtrigger_name
trigger_time
trigger_event trigger_statement
trigger_time表示触发时机，值为AFTER或BEFORE；
trigger_event表示触发的事件，值为INSERT、updatE、deletE等；
trigger_statement表示触发器的程序体，可以是一句sql语句或者调用UDF。
在trigger_statement中，如果有多条sql语句，需要用BEGIN...END包含起来：
由于MySQL默认的结束分隔符是分号（;），如果我们在BEGIN...END中出现了分号，将被标记成结束，此时没法完成触发器的定义。有一个办法，可以调用DELIMITER命令来暂时修改结束分隔符，用完再改会分号即可。比如改成$：
@mysql> DELIMITER $
我们开始定义一个触发器，监听对student表的插入操作，student表在上一篇文章中创建的，可以查看http://www.cnblogs.com/zhxilin/p/5897211.html" target="_blank">上一篇文章。
@H_965_15@mysql trigGERstudent
AFTER student
262_10288@CT redis_hset(CONCAT(stu_);
262_10288@CT redis_hset(CONCAT(stu_);
262_10288@CT redis_hset(CONCAT(stu_);
gender 262_10288@CT redis_hset(CONCAT(stu_gender);
262_10288@CT redis_hset(CONCAT(stu_);
创建完触发器可以通过show查看，或者drop删除：
@mysql
trigGER tg_student;
接下来我们调用一句插入语句，然后观察redis和MySQL数据的变化：
@mysql
student );
Query OK,1 row affected (C)
redis的结果：
stu_09388165
gender"
以上结果表明，当MySQL插入数据时，通过触发器调用UDF，实现了自动刷新redis的数据。另外，调用MySQL插入的命令，可以通过C++实现，进而就实现了在C++的业务逻辑里，只需调用MySQL++的接口就能实现MySQL数据库和redis缓存的更新，这部分内容在http://www.cnblogs.com/zhxilin/p/5897211.html" target="_blank">上一篇文章已经介绍过了。
通过实践，能体会到MySQL和redis是多么相亲相爱吧！^_^
本篇文章讲了从最基础的UDF开始，再到通过UDF连接redis插入数据，再进一步介绍通过MySQL trigger自动更新redis数据的整个思路，实现了一个目标，即只在业务代码中更新MySQL数据库，进而redis能够自动同步刷新。
@H_783_0@mySQL对UDF函数和触发器的支持，使得实现redis数据和MySQL自动同步成了可能。当然UDF毕竟是通过插件的形式运行在MySQL中的，并没有过多的安全干预，一旦插件发生致命性崩溃，有可能MySQL也会挂，所以在编写UDF的时候需要非常谨慎！
以上内容来自：http://www.cnblogs.com/zhxilin/archive/2016/09/30/5923671.html
大佬总结
以上是大佬教程为你收集整理的通过mysql自动同步redis全部内容，希望文章能够帮你解决通过mysql自动同步redis所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。
标签：
