首页 / MYSQL / canal mysql select权限粒度

canal mysql select权限粒度

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了canal mysql select权限粒度，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含7881字，纯文字阅读大概需要12分钟。

内容图文

今天产品问了一个问题，问懵了

产品：canal在开通mysql权限时需要哪些权限

我：SELECT, REPLICATION SLAVE, REPLICATION CLIENT

产品：那SELECT权限要开通到表级还是库级（我们使用canal同步数据时最终选择到表）

我：en..... 晚会给你答案吧^-^.

于是乎今天就测试一下，不测不知道，一测怎加不加select权限都能正常同步binlog

场景一

本地有个mysql，直接在本地测试，删除库的select权限，也能正常同步binlog，于是乎就不淡定了，在网上查也没有个所以然

场景二

于是启动本地基于mha搭建的mysql高可用集群，再来使用canal同步主库binlog，将所要同步库的select权限删除，发现报错：

16:07:42.791 [WARN ] [destination = example7 , address = s129/192.168.3.129:3306 , EventParser] MysqlEventParser:463 | ERROR ## parse this event has an error , last position : [EntryPosition[included=false,journalName=mysql-bin.000009,position=4667,serverId=1,gtid=,timestamp=1615016220000]]
com.alibaba.otter.canal.parse.exception.CanalParseException: parse row data failed.
Caused by: com.alibaba.otter.canal.parse.exception.CanalParseException: com.google.common.util.concurrent.UncheckedExecutionException: com.alibaba.otter.canal.parse.exception.CanalParseException: fetch failed by table meta:`canal`.`test_canal_2_hive`
Caused by: com.google.common.util.concurrent.UncheckedExecutionException: com.alibaba.otter.canal.parse.exception.CanalParseException: fetch failed by table meta:`canal`.`test_canal_2_hive`
    at com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2203) ~[guava-18.0.jar:na]
    at com.google.common.cache.LocalCache.get(LocalCache.java:3937) ~[guava-18.0.jar:na]
    at com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:3941) ~[guava-18.0.jar:na]
    at com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4824) ~[guava-18.0.jar:na]
    at com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4830) ~[guava-18.0.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.TableMetaCache.getTableMeta(TableMetaCache.java:195) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.getTableMeta(LogEventConvert.java:950) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parseRowsEventForTableMeta(LogEventConvert.java:479) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parseRowsEvent(LogEventConvert.java:500) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parseRowsEvent(LogEventConvert.java:491) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parse(LogEventConvert.java:125) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parse(LogEventConvert.java:69) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.AbstractEventParser.parseAndProfilingIfNecessary(AbstractEventParser.java:417) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$3$1.sink(AbstractEventParser.java:217) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection.dump(MysqlConnection.java:178) [canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$3.run(AbstractEventParser.java:279) [canal.parse-1.1.4.jar:na]
    at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
Caused by: com.alibaba.otter.canal.parse.exception.CanalParseException: fetch failed by table meta:`canal`.`test_canal_2_hive`
Caused by: java.io.IOException: ErrorPacket [errorNumber=1142, fieldCount=-1, message=SELECT command denied to user 'canal_repl_user'@'192.168.3.1' for table 'test_canal_2_hive', sqlState=42000, sqlStateMarker=#]
 with command: desc `canal`.`test_canal_2_hive`
    at com.alibaba.otter.canal.parse.driver.mysql.MysqlQueryExecutor.query(MysqlQueryExecutor.java:61) ~[canal.parse.driver-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection.query(MysqlConnection.java:106) [canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.TableMetaCache.getTableMetaByDB(TableMetaCache.java:92) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.TableMetaCache.access$000(TableMetaCache.java:32) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.TableMetaCache$1.load(TableMetaCache.java:63) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.TableMetaCache$1.load(TableMetaCache.java:53) ~[canal.parse-1.1.4.jar:na]
    at com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3527) ~[guava-18.0.jar:na]
    at com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2319) ~[guava-18.0.jar:na]
    at com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2282) ~[guava-18.0.jar:na]
    at com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2197) ~[guava-18.0.jar:na]
    at com.google.common.cache.LocalCache.get(LocalCache.java:3937) ~[guava-18.0.jar:na]
    at com.google.common.cache.LocalCache.getOrLoad(LocalCache.java:3941) ~[guava-18.0.jar:na]
    at com.google.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4824) ~[guava-18.0.jar:na]
    at com.google.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4830) ~[guava-18.0.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.TableMetaCache.getTableMeta(TableMetaCache.java:195) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.getTableMeta(LogEventConvert.java:950) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parseRowsEventForTableMeta(LogEventConvert.java:479) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parseRowsEvent(LogEventConvert.java:500) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parseRowsEvent(LogEventConvert.java:491) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parse(LogEventConvert.java:125) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.dbsync.LogEventConvert.parse(LogEventConvert.java:69) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.AbstractEventParser.parseAndProfilingIfNecessary(AbstractEventParser.java:417) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$3$1.sink(AbstractEventParser.java:217) ~[canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.mysql.MysqlConnection.dump(MysqlConnection.java:178) [canal.parse-1.1.4.jar:na]
    at com.alibaba.otter.canal.parse.inbound.AbstractEventParser$3.run(AbstractEventParser.java:279) [canal.parse-1.1.4.jar:na]
    at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
16:07:42.792 [ERROR] [destination = example7 , address = s129/192.168.3.129:3306 , EventParser] MysqlEventParser:301 | dump address s129/192.168.3.129:3306 has an error, retrying. caused by 
com.alibaba.otter.canal.parse.exception.CanalParseException: com.alibaba.otter.canal.parse.exception.CanalParseException: parse row data failed.
Caused by: com.alibaba.otter.canal.parse.exception.CanalParseException: parse row data failed.

报错标红的说明了，表需要select权限，于是查到对应的源码：

canal mysql select权限粒度 - 文章图片

说明查询表元数据时show create table tableName和desc tableName都需要select权限，于是给对应表赋予select权限，同步正常

说明只要赋予表即select权限就可以了，那为什么本地不授权select也可以呢？

查了网上说和master_info_repository参数有关，两个环境确实不一样，本地master_info_repository=TABLE，mha中master_info_repository=FILE，但不知具体原因

使用命令：

#授权
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT, SHOW VIEW ON *.* TO `canal`@`%`
FLUSH PRIVILEGES;
#查询权限
SHOW GRANTS FOR 'canal'@'%';
#删除权限
REVOKE SELECT ON *.* FROM 'canal'@'%';
FLUSH PRIVILEGES;

内容总结

以上是互联网集市为您收集整理的canal mysql select权限粒度全部内容，希望文章能够帮你解决canal mysql select权限粒度所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/862487.html

来源：【匿名】

【上一篇】Mysql分布式之原生分表（查、删）05 【下一篇】用IE远程创建Mysql数据库的简易程序

更多 ►

【canal mysql select权限粒度】教程文章相关的互联网学习教程文章

mysql select是否会锁表？

mysql select是否会锁表？有的人说mysql的 select 会锁表，有的人说 mysql 的查询不会锁表。其他他们都对，没有，但是很片面。其实对于mysql的select 是否会锁表，这个完全取决于表采用的是什么存储引擎。这里我就拿大家最熟悉的存储引擎INNODB 和MYISAM 来说明这个问题。对于myisam的表select 是会锁定表的，会导致其他操作挂起，处于等待状态。对于innodb的表select 是不会锁表的。其实这里使用到了快照。快照这里不作讨...

MySQL SELECT 语句【图】

SELECT语句：products表如下：a 从一个表中选出一列：mysql> SELECT prod_name FROM products;b 从表中检索多个列：mysql>SELECT prod_id, prod_name FROM products;c 检索所有列：mysql> SELECT * FROM products;//见第一幅图d 检索不同行：mysql>SELECT DISTINCT prod_id FROM products;//当有多行产品id相同时，使用该语句时，多个相同的产品名称行，只显示一行。e 限制结果：mysql> SELECT prod_name FROM products LIMIT 5...

MYSQL中利用select查询某字段中包含以逗号分隔的字符串的记录方法【代码】

首先我们建立一张带有逗号分隔的字符串。 CREATE TABLE test(id int(6) NOT NULL AUTO_INCREMENT,PRIMARY KEY (id),pname VARCHAR(20) NOT NULL,pnum VARCHAR(50) NOT NULL);然后插入带有逗号分隔的测试数据 INSERT INTO test(pname,pnum) VALUES(‘产品1‘,‘1,2,4‘); INSERT INTO test(pname,pnum) VALUES(‘产品2‘,‘2,4,7‘); INSERT INTO test(pname,pnum) VALUES(‘产品3‘,‘3,4‘); INSERT INTO test(pname,pnum) VALUES...

PHPexcel 导入import 数据到 mysql: mysql 查询数据是否存在, 如果存在返回id, 不存在, 插入返回id. 2) mysql_query , mysql_connect, mysql_select_db, mysql_error, mysql_num_rows,mysql_close【代码】【图】

一: 要求: 上面的图表中的数据插入到 3张表中.1)t_vide_warehourse 分类表: 此表中包含一级分类和二级分类. 二级分类是一级分类的子级. 2)t_video_info 包名表此表管理第一张表. 并且只有第二次分类才可以有包名 .一个二级分类下可以有多个包. 3)t_video_file 文件表. 此表关联第二张表; 一个包下可以有多个文件. ---------------------------------------------------------------------------...

6-Python操作MySQL-增(insert)-删(delete)-改(update)-查(select)【代码】

增删改from pymysql import *def main():# 创建Connection连接conn = connect(host=‘localhost‘,port=3306,database=‘jing_dong‘,user=‘root‘,password=‘mysql‘,charset=‘utf8‘)# 获得Cursor对象cs1 = conn.cursor()# 执行insert语句，并返回受影响的行数：添加一条数据 # 增加count = cs1.execute(‘insert into goods_cates(name) values("硬盘")‘)#打印受影响的行数print(count)count = cs1.execute(‘insert into g...

UCenter info: MySQL Query Error SQL:SELECT value FROM [Table]vars WHERE noteexists

大家先看下数据库权限问题，然后再进行如下操作。SQL:SELECT value FROM [Table]vars WHERE name=‘noteexists2′ UCenter info: MySQL Query Error SQL:SELECT value FROM [Table]vars WHERE name=‘noteexists2′ Error:SELECT command denied to user ‘数据库‘@‘IP地址‘ for table ‘pre_ucenter_vars‘ Errno:1142 帮人迁移discuz，原以为很简单，数据导出，数据导入，修改uc_server/data/config.inc.php文件当中的数据库信...

逻辑备份,mysqldump,SELECT…INTO OUTFILE,恢复

逻辑备份mysqldumpmysqldump备份工具最初由Igor Romanenko编写完成，通常用来完成转存（dump）数据库的备份以及不同数据库之间的移植，例如从低版本的MySQL数据库升级到高版本的MySQL数据库，或者从MySQL数据库移植到Oracle和SQL Server等数据库等。mysqldump的语法如下：mysqldump [arguments] ＞ file_name如果想要备份所有的数据库，可以使用--all-databaes选项：mysqldump --all -databases ＞ dump.sql如果想要备份指定的数据...

Mysql select in 按id排序实现方法

表结构如下: mysql> select * from test; +----+-------+ | id | name | +----+-------+ | 1 | test1 | | 2 | test2 | | 3 | test3 | | 4 | test4 | | 5 | test5 | +----+-------+ 执行以下SQL: mysql> select * from test where id in(3,1,5); +----+-------+ | id | name | +----+-------+ | 1 | test1 | | 3 | test3 | | 5 | test5 | +----+-------+ 3 rows in set (0.00 sec) 这个select在mysql中得结果会自动按照id升序排列, ...

php操作mysql获取html标签<select>下拉列表数据【图】

650) this.width=650;" src="/upload/getfiles/default/2022/11/13/20221113025755550.jpg" title="psb (1)_副本.png" />650) this.width=650;" src="/upload/getfiles/default/2022/11/13/20221113025756099.jpg" title="psb_副本.png" />650) this.width=650;" src="/upload/getfiles/default/2022/11/13/20221113025756585.jpg" title="psb (2)_副本.png" />本文出自 “IT5808” 博客，请务必保留此出处http://it5808.blog.5...

Windows导出Mysql查询的数据Excel文件select * into outfile '文件路径' from【代码】

SELECT f_id,f_accountNum,f_addr into outfile ‘E://t1.xlsx‘ FROM tb_sg186info WHERE f_id >= 1 AND f_id <= 500000; SELECT f_id,f_accountNum,f_addr into outfile ‘E://t2.xlsx‘ FROM tb_sg186info WHERE f_id >= 500001 AND f_id <= 1000000; SELECT f_id,f_accountNum,f_addr into outfile ‘E://t3.xlsx‘ FROM tb_sg186info WHERE f_id >= 1000001 AND f_id <= 1500000; SELECT f_id,f_accountNum,f_addr into outfi...

mysql中insert与select的嵌套使用【代码】

如何在mysql从多个表中组合字段然后插入到一个新表中，通过一条sql语句实现。具体情形是：有三张表a、b、c，现在需要从表b和表c中分别查几个字段的值插入到表a中对应的字段。对于这种情况，我们可以使用如下的语句来实现：INSERTINTO db1_name(field1,field2)SELECT field1,field2 FROM db2_name当然，上面的语句比较适合两个表的数据互插，如果多个表就不适应了。对于多个表，我们可以先将需要查询的字段join起来，然后组成一个视...

Mysql Select的字段必须包含在Group By中如何解决

原因：由于mysql 设置了分组限制 “ONLY_FULL_GROUP_BY”可使用SELECT @@sql_mode 查看数据库是否有这个限制解决方法（临时）：删除分组限制SET sql_mode=(SELECT REPLACE(@@sql_mode,‘ONLY_FULL_GROUP_BY‘,‘‘));原文：https://www.cnblogs.com/sugarwxx/p/14832604.html

Mysql，再见吧！select * ! SQL调优

应用程序慢如牛，原因多多，可能是网络的原因、可能是系统架构的原因，还有可能是数据库的原因。那么如何提高数据库SQL语句执行速度呢？有人会说性能调优是数据库管理员（DBA）的事，然而性能调优跟程序员们也有莫大的关系。程序中嵌入的一行行的SQL语句，如果使用了一些优化小技巧，定能达到事半功倍的效果。技巧1 比较运算符能用 “=”就不用“<>”“=”增加了索引的使用几率。技巧2 明知只有一条查询结果，那请使用 “LIMIT...

MySQL检索数据-SELECT查询语句【代码】【图】

students表 1. 检索单个列SELECT name FROM students 返回结果：2. 检索多个列--用逗号分隔列名SELECT name,age,class FROM students返回结果：3. 检索所有列--使用星号*通配符SELECT*FROM students返回结果： 4. 检索不同的行（返回结果去重）--使用DISTINCTSELECTDISTINCT class FROM students返回结果：5. 限制结果--使用LIMIT子句，限制结果显示从第0行开始的1条数据SELECT*FROM students LIMIT 0,1--也可以写作LIMIT 1或LIMIT...

关于MySQL中select (select...) from ... 查询【代码】【图】

直接上例子：新建A表结构及数据如下：新建B表结构及数据如下：其中：B表和A表是一对多的关系（1：n）,B表的主键是A表的外键SELECT A.ha, (SELECT B.haha FROM B WHERE B.id2 = A.id2 ) AS haha FROM A;结果为：这意味着：在A表中取字段，同时取B表中的字段作为其中一个字段显示。其中，子句的查询结果并不影响原来A的记录条数。比如：SELECT A.ha, (SELECT B.haha FROM B WHERE B.id2 = A.id2 AND B.haha = "1") AS haha FROM A;结...

MYSQL - 技术教程分类

MySQL 教程 MySQL 安装 MySQL 管理 MySQL PHP 语法 MySQL 连接 MySQL 创建数据库 MySQL 删除数据库 MySQL 选择数据库 MySQL 数据类型 MySQL 创建数据表 MySQL 删除数据表 MySQL 插入数据 MySQL 查询数据 MySQL WHERE 子句 MySQL UPDATE 更新 MySQL DELETE 语句 MySQL LIKE 子句 MySQL UNION MySQL 排序 MySQL 分组 MySQL 连接的使用 MySQL NULL 值处理 MySQL 事务 MySQL ALTER命令 MySQL 索引 MySQL 临时表 MySQL 复制表 MySQL 元数据 MySQL 序列使用 MySQL 处理重复数据 MySQL 及 SQL 注入 MySQL 导出数据 MySQL 导入数据 MySQL 函数 MySQL 运算符 mysql 全部

MYSQL - 最热教程

sql分组取最大记录方法 mysql如何设置默认值 mysql创建数据表时指定默认值教程 MySQL 5.7 的初始化操作（root初始密码...Oracle中合并数据集(多行变一行)mysql 相同内容的字段合并为一条的方法解决mysql设置时区时的错误Unknown or ...解决ubuntu下mysql的'Access denied fo...ubuntu系统中MysqlERROR1045(28000)报错...mysql数据库设置不区分大小写

首页 / MYSQL / canal mysql select权限粒度

canal mysql select权限粒度

内容导读

内容图文

内容总结

内容备注

内容手机端

【canal mysql select权限粒度】教程文章相关的互联网学习教程文章

mysql select是否会锁表？

MySQL SELECT 语句【图】

MYSQL中利用select查询某字段中包含以逗号分隔的字符串的记录方法【代码】

PHPexcel 导入import 数据到 mysql: mysql 查询数据是否存在, 如果存在返回id, 不存在, 插入返回id. 2) mysql_query , mysql_connect, mysql_select_db, mysql_error, mysql_num_rows,mysql_close【代码】【图】

6-Python操作MySQL-增(insert)-删(delete)-改(update)-查(select)【代码】

UCenter info: MySQL Query Error SQL:SELECT value FROM [Table]vars WHERE noteexists

逻辑备份,mysqldump,SELECT…INTO OUTFILE,恢复

Mysql select in 按id排序实现方法

php操作mysql获取html标签<select>下拉列表数据【图】

Windows导出Mysql查询的数据Excel文件select * into outfile '文件路径' from【代码】

mysql中insert与select的嵌套使用【代码】

Mysql Select的字段必须包含在Group By中如何解决

Mysql，再见吧！select * ! SQL调优

MySQL检索数据-SELECT查询语句【代码】【图】

关于MySQL中select (select...) from ... 查询【代码】【图】

SELECT - 相关标签

MYSQL - 相关标签

MYSQL - 技术教程分类

MYSQL - 最新教程

MYSQL - 最热教程