潇洒紫焰 发表于 2018-11-7 08:43:45

Mysql数据迁移至Redis

  之前看了几篇文章,有所启发,下面写个详细点的,亲测可用
  最终目标:将Mysql表中商品信息以hash格式存入Redis中;
  形如 hmset h:good_id:234 商品名 cat_id 分类id price 商品价格 .....
  现有一张商品表 goods,字段若干,

  一   将下面代码保存至 goods.sql,格式遵守redis的通讯协议,后面会讲到。
  SELECT CONCAT(
  "*8\r\n",                        // 表示redis命令有 8个字段 包括命令和参数
  '$',LENGTH(redis_cmd),'\r\n',redis_cmd,'\r\n',
  '$',LENGTH(key_name),'\r\n',key_name,'\r\n',
  '$',LENGTH(param1),'\r\n',param1,'\r\n',
  '$',LENGTH(param1_val),'\r\n',param1_val,'\r\n'
  '$',LENGTH(param2),'\r\n',param2,'\r\n'
  '$',LENGTH(param2_val),'\r\n',param2_val,'\r\n'
  '$',LENGTH(param3),'\r\n',param3,'\r\n'
  '$',LENGTH(param3_val),'\r\n',param3_val,'\r' //最后一行没有 \n
  ) FROM (            //下面 8行对应上面的设定的8个字段
  SELECT 'HMSET' as `redis_cmd`,
  concat('h:good:id:',goods_id) as `key_name`,
  concat('good_name') as param1,      //concat中的字符串是redis中的field名
  goods_name as param1_val,      //颜色字段是数据库中字段名
  concat('cat_id') as param2,
  cat_id as param2_val,
  concat('price') as param3,
  shop_price as param3_val
  FROM goods)                      //from表名
  as table2
  ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  上面的代码等价于
  hmset h:good:id:234 apple cat_id 88 price 500.00
  字段可以随意设置,但要保持上下一致。
  二 执行
  mysql -uroot -proot dbname --skip-column-names --raw < goods.sql | redis-cli --pipe
  齐活儿。
  附:redis通讯协议格式官方连接 http://redis.io/topics/mass-insert
  例
  *3 CR LF//三个字段
$3 CR LF//第一个字段 ‘set’ 有3个字节SET CR LF //字段内容set$4 CR LF//第二个字段key1有4个字节key1 CR LF //字段二内容 mykey$4 CR LF//第三个字段有4个字节val1 CR LF //字段三内容 val1  结果:set key1 val1
  相关链接:http://dcw.ca/blog/2013/01/02/mysql-to-redis-in-one-step/
  http://redis.io/topics/mass-insert
  http://www.oschina.net/translate/mysql-to-redis-in-one-step

页: [1]
查看完整版本: Mysql数据迁移至Redis