dawnbreaks / mysql2redis Goto Github PK

when the free_resources is called,
I think you want to close the pFile and redisFree sredisContext ?

hello,

I used password in redis for security reason so how I connect mysql with redis by using password.
please help...

Thanks

or is there a plan to support it?

every time mysql restart,i have to login mysql client and have manual exe redis_servers_set_v2("127.0.0.1", 6379); function everytime,can you tell me how could i exe this automatic?

BEGIN
DECLARE done INT DEFAULT FALSE;
DECLARE v_id INT;
DECLARE v_ret INT;
DECLARE cur CURSOR FOR SELECT u.user_id FROM kid_users u WHERE u.latest_login_time>=DATE(DATE_ADD(NOW(),INTERVAL -1 DAY)) AND EXISTS(SELECT * FROM kid_child_info WHERE user_id=u.user_id AND gender IN(0,1)) ORDER BY u.latest_login_time DESC;
DECLARE CONTINUE HANDLER FOR NOT FOUND SET done = TRUE;

OPEN cur;
read_loop: LOOP
	FETCH cur INTO v_id;
	IF done THEN
		LEAVE read_loop;
	END IF;

	SET v_ret=redis_command_v2('LPUSH', 'calcReadingRecommendForYou', CONCAT(v_id));
END LOOP;
CLOSE cur;

END

DELIMITER $$
CREATE TRIGGER user_consult_insert_trigger AFTER INSERT ON user_consult
FOR EACH ROW BEGIN
set @id = redis_servers_set_v2("127.0.0.1", 6369);
set @ret = redis_command_v2("", 0, "lpush",
concat("user-consultation-list-", NEW.user_id),
concat(NEW.id)
);
set @ret = redis_command_v2("", 0, "lpush",
concat("consultant-consultation-list-", NEW.consultant_id),
concat(NEW.id)
);
set @ret = redis_command_v2("", 0, "set",
concat("user_consult-", NEW.id),
json_object(
NEW.id as "id",
NEW.user_id as "user_id",
NEW.consultant_id as "consultant_id",
NEW.service_id as "service_id",
NEW.service_type as "service_type",
NEW.title as "title",
NEW.content as "content",
NEW.ctime as "ctime",
NEW.reply_num as "reply_num"
)
);
END$$
DELIMITER ;

the code above is my trigger.this trigger always insert primary id into user-consultation-list* twice

os : centos-5.6
jemalloc: jemalloc-3.5.1
apr: apr-1.4.6
apr-util: apr-util-1.5.2
hiredis: hiredis-master
#1126 - Can't open shared library 'lib_mysqludf_redis_v2.so' (errno: 0 /opt/mysql-5.5.15/lib/plugin/lib_mysqludf_redis_v2.so: undefined symbol: info)

base on MySQL-server-5.6.32-1.linux_glibc2.5.i386.rpm , when I make the mysql2redis,the below message showed:

[root@localhost mysql2redis]# make
gcc -Werror -O2 -g /usr/bin/mysql_config --include -I/usr/local/include -I/usr/local/apr/include -I./ -I. -fPIC -shared -rdynamic lib_mysqludf_redis.c -lhiredis -L"/usr/lib64/mysql/plugin" -L/usr/local/apr/lib -lapr-1 -laprutil-1 -o lib_mysqludf_redis_v2.so
cc1: warnings being treated as errors
In file included from lib_mysqludf_redis.h:26,
from lib_mysqludf_redis.c:5:
/usr/include/mysql/m_string.h: In function ‘skip_trailing_space’:
/usr/include/mysql/m_string.h:261: error: cast from pointer to integer of different size
/usr/include/mysql/m_string.h:261: error: cast to pointer from integer of different size
/usr/include/mysql/m_string.h:263: error: cast from pointer to integer of different size
/usr/include/mysql/m_string.h:263: error: cast to pointer from integer of different size
/usr/include/mysql/m_string.h:265: error: cast from pointer to integer of different size
make: *** [compile] Error 1

the function ‘skip_trailing_space’ like below:

static inline const uchar *skip_trailing_space(const uchar *ptr,size_t len)
{
const uchar *end= ptr + len;

if (len > 20)
{
const uchar *end_words= (const uchar *)(intptr)
(((ulonglong)(intptr)end) / SIZEOF_INT * SIZEOF_INT);
const uchar *start_words= (const uchar *)(intptr)
((((ulonglong)(intptr)ptr) + SIZEOF_INT - 1) / SIZEOF_INT * SIZEOF_INT);

DBUG_ASSERT(((ulonglong)(intptr)ptr) >= SIZEOF_INT);
if (end_words > ptr)
{
  while (end > end_words && end[-1] == 0x20)
    end--;
  if (end[-1] == 0x20 && start_words < end_words)
    while (end > start_words && ((unsigned *)end)[-1] == SPACE_INT)
      end -= SIZEOF_INT;
}

}
while (end > ptr && end[-1] == 0x20)
end--;
return (end);
}

THANKS FOR HELP.

i use this code, but list is not trimed:

SET v_redis_ret=redis_command_v2('LTRIM', 'UserReadingRecord4', 0, 4);

Check out the unstable branch to see the latest features:
https://github.com/DGKSK8LIFE/redisql

Hi,
I'm new to Redis and MySQL. Could you tell me how to check the data entered in Redis from Mysql?