mysql memcached udf_MySQL UDF同步 memcached
MySQL memcached UDFs
UDFs 是 User Defined Functions 的缩写，指 Mysql 的用户定义函数，应用可以通过使用这些函数从 Mysql5.0 以上版本的数据库中访问 Memcached 写入或者获得数据。此外，从 Mysql5.1 开始支持触发器，这样就可以在触发器中使用 UDFs 直接更新 Memcached 的内容，减轻了应用程序设计和编写的复杂性。下面我们简要介绍 UDFs 的安装和使用：
UDFs 的安装，需要在数据库服务器上安装两个包，分别是 libmemcached 和 memcached_functions_mysql ，都可以从
[url]http://download.tangent.org/[/url] 下载。
Libmemcached 包的安装比较简单，只要从网上下载最新的包解压后安装即可：
cd libmemcached-0.22
configure
make
make install
memcached_functions_mysql 安装的时候需要指定 Mysql 服务的路径，其他并没有什么特别的地方：
cd memcached_functions_mysql-0.4
./configure --with-mysql=/home/mysql/bin/mysql_config
make
make install
ubuntu下安装mysql找不到mysql_config
安装“libmysqlclient15-dev”包就可以了 apt-get install libmysqlclient15-dev
这样就能在mysql的bin目录里找到mysql_config
安装完成之后，需要将 libmemcached_functions_mysql 的库文件拷贝到 mysql/lib 目录下的 plugin 目录中。
cp /usr/local/lib/libmemcached_functions_mysql* /home/mysql/lib/plugin/.
首次使用的时候，需要使用 CREATE FUNCTION 来初始化用户定义函数。有两种方法可以初始化所有提供的用户定义函数，一个是执行 memcached_functions_mysql-0.4/sql 目录下的 install_functions.sql ；另一个是执行 memcached_functions_mysql-0.4/utils/install.pl 。
创建好函数之后，就可以使用这些函数进行 Memcached 的操作，首先需要定义 Memcached 服务器，假设我们测试的环境配置了两个 Memcached 服务器( 192.168.0.1 和 192.168.0.2 )，都使用默认端口 11211 ：
mysql> SELECT memc_servers_set('192.168.0.1:11211,192.168.0.2:11211');
配置完成后，就可以进行数据的写入和读取的操作了，下面我们创建了一个临时表用来介绍通过触发器更新 Memcached 的简要步骤：
创建测试表：
mysql> create table test3 (
-> id int(3) not null,
-> name varchar(64) not null default '',
-> primary key (id)
-> );
Query OK, 0 rows affected (0.17 sec)
给自增变量赋初值：
mysql> select memc_set('id:sequence', 0);
+----------------------------+
| memc_set('id:sequence', 0) |
+----------------------------+
| 0 |
+----------------------------+
1 row in set (0.00 sec)
mysql>
在测试表上创建 insert 触发器：
mysql> DELIMITER |
mysql>
mysql> DROP TRIGGER IF EXISTS test3_insert;
-> CREATE TRIGGER test3_insert
-> BEFORE INSERT ON test3
-> FOR EACH ROW BEGIN
-> SET NEW.id= memc_increment('id:sequence');
-> SET @mm= memc_set(concat('id:',NEW.id), NEW.name);
-> END |
Query OK, 0 rows affected, 1 warning (0.00 sec)
Query OK, 0 rows affected (0.00 sec)
mysql>
mysql> DELIMITER ;
mysql>
插入记录：
mysql> insert into test3 (name) values ('memcached');
Query OK, 1 row affected (0.00 sec)
mysql> insert into test3 (name) values ('test');
Query OK, 1 row affected (0.00 sec)
mysql> insert into test3 (name) values ('mysql');
Query OK, 1 row affected (0.00 sec)
mysql> select * from test3;
+----+-----------+
| id | name |
+----+-----------+
| 1 | memcached |
| 2 | test |
| 3 | mysql |
+----+-----------+
3 rows in set (0.00 sec)
访问 Memcached 可以得到已经通过触发器写入缓存的记录：
mysql> select memc_get('id:1');
+------------------+
| memc_get('id:1') |
+------------------+
| memcached |
+------------------+
1 row in set (0.00 sec)
mysql> select memc_get('id:2');
+------------------+
| memc_get('id:2') |
+------------------+
| test |
+------------------+
1 row in set (0.00 sec)
mysql> select memc_get('id:3');
+------------------+
| memc_get('id:3') |
+------------------+
| mysql |
+------------------+
1 row in set (0.00 sec)