Mycat大型项目使用案例

1、封面作者：PanHon glia ng仅供个人学习Mycat+percona+keepalived+haproxy作者：zuoyuez on 为什么 Mycat 难相信很多哥们做 mycat 不是不全就是这出错那里出错最后崩溃的边缘晃荡几分钟后不了了之，要么公司的mycat 是个这里提供一个例子至于 mycat 的介绍就是： 搜索框中输入 mycat1.下载安装mycat，javaroot no de24 src#tar -xf Mycat-server-1.4-RELEASE-20150901112004-li nux.tar.gz root no de24src#mv mycat/ /us

2、r/local/root no de24 src#useradd mycatroot no de24 local#chow n mycat:root mycat/ -Rroot no de24 src#rpm -ivh jre-8u51-li nu x-x64.rpmPrepari ng.# 100%1:jre1.8.0_51# 100%Un pack ing JAR files.rt.jar.jsse.jar.charsets.jar.localedata.jar.jfxrt.jar.plugi n.jar.javaws.jar.Deploy.jar.root no de24 src#jav

3、a -versionjava version 1.8.0_51Java(TM) SE Run time En viro nmen t (build 1.8.0_51-b16)Java HotSpot(TM) 64-Bit Server VM (build 25.51-b03, mixed mode)此处注意 java 版本不得低于 1.6至此 Mycat 安装就算完成了2. mysql环境以及Mycat配置我的环境如下2 : mysql dn3 mysql dn4 mysql dn35 mysql dn410.

4、1.166.26 mysql dn5配置hosts文件rootnode22 src#cat /etc/hosts localhost localhost.localdomain localhost4 localhost4.localdomain4:1localhost localhost.localdomain localhost6 localhost6.localdomain62node22 dn3 dn4 dn35 dn46 dn5传到各个机器fo

5、r i in 2 3 4 5 6 。 do scp /etc/hosts $i:/etc 。done为你的mycat用户设置个密码rootnode24 src#passwd mycatChanging password for user mycat.New password:BAD PASSWORD: it is WAY too shortBAD PASSWORD: is too simpleRetype new password:passwd: all authentication token

6、s updated successfully.原始mycat测试配置rootnode24 conf#./logs/wrapper.logrootnode24 conf#rootnode24 conf#pwd/usr/local/mycat/confrootnode24 conf#./bin/mycat startStarting Mycat-server.报错处理方案rootnode24 conf#cat ./logs/wrapper.logSTATUS | wrapper | 2015/09/18 01:27:36 | - Wrapper Started as DaemonSTATUS |

7、wrapper | 2015/09/18 01:27:36 | Launching a JVM.INFO | jvm 1 | 2015/09/18 01:27:36 | Java HotSpot(TM) 64-Bit Server VM warning: ignoring optionMaxPermSize=64M 。 support was removed in 8.0ERROR | wrapper | 2015/09/18 01:27:36 | JVM exited while loading the application.INFO | jvm 1 | 2015/09/18 01:27:

8、36 | Error: Exception thrown by the agent :.MalformedURLException: Local host name unknown: .UnknownHostException:node24: node24: unknown errorSTATUS | wrapper | 2015/09/18 01:27:41 | Launching a JVM.INFO | jvm 2 | 2015/09/18 01:27:41 | Java HotSpot(TM) 64-Bit Server VM warning: ignoring optionMaxPe

9、rmSize=64M 。 support was removed in 8.0INFO | jvm 2 | 2015/09/18 01:27:41 | Error: Exception thrown by the agent :.MalformedURLException: Local host name unknown: .UnknownHostException:node24: node24: unknown errorERROR | wrapper | 2015/09/18 01:27:41 | JVM exited while loading the application.STATU

10、S | wrapper | 2015/09/18 01:27:45 | Launching a JVM.INFO | jvm 3 | 2015/09/18 01:27:45 | Java HotSpot(TM) 64-Bit Server VM warning: ignoring optionMaxPermSize=64M 。 support was removed in 8.0ERROR | wrapper | 2015/09/18 01:27:45 | JVM exited while loading the application.INFO | jvm 3 | 2015/09/18 01

11、:27:45 | Error: Exception thrown by the agent :.MalformedURLException: Local host name unknown: .UnknownHostException:node24: node24: unknown errorSTATUS | wrapper | 2015/09/18 01:27:50 | Launching a JVM.INFO | jvm 4 | 2015/09/18 01:27:50 | Java HotSpot(TM) 64-Bit Server VM warning: ignoring optionM

12、axPermSize=64M 。 support was removed in 8.0INFO | jvm 4 | 2015/09/18 01:27:50 | Error: Exception thrown by the agent :.MalformedURLException: Local host name unknown: .UnknownHostException:node24: node24: unknown errorERROR | wrapper | 2015/09/18 01:27:50 | JVM exited while loading the application.S

13、TATUS | wrapper | 2015/09/18 01:27:54 | Launching a JVM.INFO | jvm 5 | 2015/09/18 01:27:54 | Java HotSpot(TM) 64-Bit Server VM warning: ignoring optionMaxPermSize=64M 。 support was removed in 8.0ERROR | wrapper | 2015/09/18 01:27:54 | JVM exited while loading the application.INFO | jvm 5 | 2015/09/1

14、8 01:27:54 | Error: Exception thrown by the agent :.MalformedURLException: Local host name unknown: .UnknownHostException:node24: node24: unknown errorFATAL | wrapper | 2015/09/18 01:27:54 | There were 5 failed launches in a row, each lasting less than300 seconds. Giving up.FATAL | wrapper | 2015/09

15、/18 01:27:54 | There may be a configuration problem: please check the logs.STATUS | wrapper | 2015/09/18 01:27:55 | - Wrapper Stopped 发现有报错 所以要先启动一下原始的连原始的都报错那还配置没有意义ERROR | wrapper | 2015/09/18 01:27:36 | JVM exited while loading the application.INFO | jvm 1 | 2015/09/18 01:27:36 | Error: Exception

16、 thrown by the agent :.MalformedURLException: Local host name unknown: .UnknownHostException:node24: node24: unknown error 看到了是域名的报错可能是刚刚我修改hosts 文件的时候没有写本机名rootnode24 conf#cat /etc/hosts localhost localhost1 localhost.localdomain localhost4 localhost4.localdomain4:1 localhost localhost.loc

17、aldomain localhost6 localhost6.localdomain62node22 dn3 dn4 dn35 dn46 dn5rootnode24 conf#hostnamenode24rootnode24 conf#cat /etc/sysconfig/networkNETWORKING=yesHOSTNAME=node24所以需要改变的是Hosts 文件中需要定义 node24改为rootnode24 conf#cat /etc/hosts127.

18、0.0.1 node24 localhost localhost1 localhost.localdomain localhost4 localhost4.localdomain4 :1localhost localhost.localdomain localhost6 localhost6.localdomain62 dn1 3 dn4 dn3 node245 dn46 dn5 rootnode24 conf#./bin/mycat restart Stopping Mycat-server

19、.Stopped Mycat-server.Starting Mycat-server.rootnode24 conf#cat ./logs/wrapper.logSTATUS | wrapper | 2015/09/18 02:17:28 | TERM trapped. Shutting down.STATUS | wrapper | 2015/09/18 02:17:29 | Wrapper Started as Daemon STATUS | wrapper |2015/09/18 02:17:30 | Launching a JVM.INFO | jvm 1 | 2015/09/18

20、02:17:30 | Java HotSpot(TM) 64-Bit Server VM warning: ignoring optionMaxPermSize=64M 。 support was removed in 8.0| 2015/09/18 02:17:31 | Wrapper (Version 3.2.3)| 2015/09/18 02:17:31 | Copyright 1999-2006 Tanuki Software, Inc. All RightsINFO | jvm 1 | 2015/09/18 02:17:31 | 2015/09/18 02:17:31 | log4j

21、 2015-09-18 02:17:31 ./conf/log4j.xml load| 2015/09/18 02:17:32 | MyCAT Server startup successfully. see logs in基于案例配置我有一张线上日志表数据海量CREATE TABLE zuolog (id bigi nt(15) NOT NULL COMMENT ,INFO | jvm 1INFO | jvm 1Reserved.INFO | jvm 1completed.INFO | jvm 1logs/mycat.logaccountcode varchar(30) NOT NULL C

22、OMMENT ,content varchar(300) DEFAULT NULL,note1 varchar(2) DEFAULT NULL,note2 varchar(2) DEFAULT NULL,isbackmoney tinyint(1) NOT NULL DEFAULT 1 COMMENT ,consumestauts tinyint(1) NOT NULL DEFAULT 0 COMMENT 0 ：完成 1：预消费 (消费状 态) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT=消费日志 。现在数据以及好几千了 所以需要 mycat 负载也高

23、所以架构图这里划一下手绘本事不大还望 见谅啊配置文件schema.xml配置rootnode24 conf#cat schema.xml !- -!- -!- -!- -!- - !- -!- - - -!- -!- -!- -select user()!- - select user()!-!-!- -select user()!- - select user()!- - select user()!- - !-artbeat select 1 from dualalter session setnls_date_format=yyyy-mm-dd hh24:mi:ss select use

24、r() -!- select user() -该配置文件是出错容易最多的地方需特别注意dataNode name 表示节点名称 dataHost 表示你数据库的名称 database 表示你路由的数据库的名称schema name 表示你 mycat 连接后端的 db1 db2 db3 db4 db5 在前端显示的库名字叫 yungui ，sqlMaxLimit 表示显示多少select user()minCon=1 balance=0 writeType=0!- -为一个数据库实例的配置balance=0参数 balanee 决定了哪些 MySQL 服务器参与到读 SQL 的负 载均衡中，0

25、为不开启读写分离，1 为全部的 readHost 与 standby writeHost 参与 select 语句的负载均 衡，比如我们配置了 1 主 3 从的 MySQL 主从环境， 并把第一个 从节点 MySQL配置为 dataHost 中的第二个 writeHost，以便主节点 宕机后，Mycat 自动切换到这个 writeHost 上来执行写操作，此时 balance=1 就意味着第一个 writeHost 不参与读 SQL 的负载均 衡，其他 3 个都参与；balance=2 则表示所有的 writeHost 不参 与，此时，只有 2 个 readHost 参与负载均衡。这里有一个细

26、节需要 你知道，readHost是从属于 writeHost 的， 即意味着它从那个 writeHost 获取同步数据， 因此，当它所属的 writeHost 宕机了， 则它 也不会再参与到读写分离中来， 即“不工作了”，这是因为 此时，它的数据已经“不可靠”了。基于这个考虑，目前 mycat 1.3 和 1.4 版本中，若想支持 MySQL 一主一从的标准配置，并且在 主节点宕机的情况下，从节点还能读取数据，则需要在 Mycat 里配 置为两个 writeHost 并设置 banlance=1。 selectuser()writeType=1 仅仅对于 galera for mysql 集群

27、这种多主多节点都能写入 的集群起效，此时 Mycat 会随机选择一个 writeHost 并写 入数据，对于非galera for mysql 集群，请不要配置 writeType=1 ，会 导致数据库不一致的严重问题。Mycat 目前支持自动方式、编程指定的两种读写分离方式： 自 动 方 式 ，即 一 个 查 询 SQL 是 自 动提 交 模 式 ， 对 应 于connection.setAutocommit(true) 或者 set autocommit=1 编程指定方式，即一个查询SQL 语句以/*balanee*/注解来确定其是走读节点还是写节点。在 1 .3 版本里，若事务内的的查询

28、语 句增加此注解，则强制其走读节点，而 1.4 版本里继续强化，可以 在非事务内的查询语句前增加此注解，强制走写节点，这个 增强是为了避免主从不同步的情况下要求查询到刚写入的数据而做 的增强 另外 1.4 开始支持 MySQL 主从复制状态绑定的读写分离机制，让读 更加安全可靠，配置如下：MyCAT 心跳检查语句配置为 show slave status ， dataHost 上定义两 个新属性： switchType=2 与slaveThreshold二100,此时意味着开启 MySQL 主从复制状态绑定的读写分离与切换机制，Mycat 心跳机制通过检测 show slave status

29、中 的Seconds_Behind_Master, Slave_IO_Running,Slave_SQL_Running 三个字段来确定当前主从同步的状态以及 Sec on ds_Behi nd_Maste 主从复制时延，当 Sec on ds_Behi nd_MasterslaveThreshold 时，读写分离筛选器会过滤掉此 Slave 机器，防止读到很久之前的旧数据，而当主节点宕机后，切换逻辑会检查 Slave 上的 Seconds_Behind_Master 是否为 0,为 0 时则表示主从同步,可以安全切换,否则不会切换。switchType 目前有三种选择：- -1 表示不自动切

30、换- 1 默认值,自动切换- 2 基于 MySQL 主从同步的状态决定是否切换下面为参考配置：show slave status /ddataHostconf/log4j.xml 中配置日志输出级别为 debug 时，当选择节点的时 候，会输出如下日志：16:37:21.660 DEBUG Processor0-E3 (PhysicalDBPool.java:333) -select read source hostM1 fordataHost:localhost116:37:21.662 DEBUG Processor0-E3 (PhysicalDBPool.java:333) -selec

31、t read source hostM1 fordataHost:localhost1根据这个信息，可以确定某个 SQL 发往了哪个读(写)节点，据此 可以分析判断是否发生了读写分离。用 MySQL 客户端连接到 Mycat 的 9066 管理端口，执行 showdata node,也能看出负载均衡的情况，其中execute 字段表明该片上执行过的 SQL 累计数：!输入图片说明 （ 在这里输入图片标题 ） 至于应用中的哪些数据查询比较适合开启读写分离，总结下来大概 有以下几种：- 列表界面，通常是浏览查询功能，这类的数据访问频繁但实时性要 求比较低，有几秒几十秒的延迟，通常感觉不出来，淘 宝

32、界面里，已售出的商品个数往往比商家后台看到的数据要延迟很 大，也说明了它是一个快照数据- 某个数据的详细信息页面，通常也访问较为频繁，但事实性要求不高- 历史时刻的数据，比如昨天的数据，上个月的，这种数据即使有修 改，也概率很低Mycat 的读写分离，默认是按照该 SQL 是否有事务包裹，由于一些 高层框架如 Hibernate、Spring 等往往会自动追加事务控制语 句，将查询语句变成事务内的语句，当你开启 Mycat Debug 日志级 别后，就可能很清楚的看到这一点，日志中会出现如下的序 列，此时不会走读写分离，因此建议程序设计的时候，手工控制事 务，让这些查询语句自动提交，这个做法也

33、有利于加快MySQL 的执行过程set autocomomit=0 select * commit因为我是 percona 集群无需配置读写分离什么的了Mysql授权以及配置文件配置文件加入如下两句 log_bin_trust_function_creators=1_ _ _lower_case_table_names = 1 在每一台 schema.xml 配置文件定义过得 mysql 上授权如下GRANT ALL PRIVILEGES ON *.* TO root10.1.166.% IDENTIFIED BY 123456 WITH GRANTOPTION 。GRANT ALL PRIV

34、ILEGES ON *.* TO root IDENTIFIED BY 123456 WITH GRANTOPTION 。GRANT ALL PRIVILEGES ON *.* TO rootlocalhost IDENTIFIED BY 123456 WITH GRANTOPTION 。flush privileges 。 这里的密码与上面配置文件的密码相对应 如果授权错误则会报错配置数据名密码rootnode24 conf#vi server.xml druidparser!- 1- !-40960 -!-132-!-65535-!-0-!-1-!-1-!-16-!-1

35、0 ： 开 启 小 数 量 级 ( 默 认) ；1：开启亿级数据排序100 亿级数量排序批量323280669066300000409632-xinchengyunguiyunguixinchengyunguiyunguitrue!- 1 -!- test -配置节点数rootnode22 conf#vi rule.xml id func1 user_idfunc1 sharding_id/5 id jump-consistent-hash 0 5160认是 160 倍，也就是虚拟节点数是物理节点数的160 倍 -!- weightMapFile节点的权重，没

36、有指定权重的节点默认是 1。以properties 文件的格式填写，以从0 开始到 count-1 的整数值也就是节点索引为key，以节点权重值为值。所有权重值必须是正整数，否 则以 1 代替 -!- /etc/mycat/bucketMapPath 用于测试时观察各物理节点与虚拟节点的分布情况，如果指定了这个属性， 会把虚拟节点的 murmur hash 值 与物理节点的映射按行输出到这个文件，没有默认值，如果不指定，就不会输出任何东西 - partition-hash-int.txt function name=rang-long rootnode22 conf#vi rule.xml i

37、d func1 user_idfunc1 sharding_id hash-int idrang-longidmod-longidmurmurcreate_datecalldateidrang-modidjump-consistent-hash05 !- /etc/mycat/bucketMapPath partition-hash-int.txtautopartition-long.txt 58128 24 yyyy-MM-dd 2015-01-01partition-range-mod.txt 3 启动测试rootnode24 conf#rm -rf perties

38、删除掉之前原始测试启动后生成的文件里面记 录了节点信息rootnode24 conf#cat ./logs/wrapper.log STATUS | wrapper | 2015/09/18 02:17:28 | TERM trapped.Shutting down.STATUS | wrapper | 2015/09/18 02:17:29 | Wrapper Started as DaemonSTATUS | wrapper | 2015/09/18 02:17:30 | Launching a JVM.INFO | jvm 1 | 2015/09/18 02:17:30 | Java H

39、otSpot(TM) 64-Bit Server VM warning: ignoring optionMaxPermSize=64M 。 support was removed in 8.0INFO | jvm 1 | 2015/09/18 02:17:31 | Wrapper (Version 3.2.3)INFO | jvm 1 | 2015/09/18 02:17:31 | Copyright 1999-2006 Tanuki Software, Inc. All Rights Reserved.INFO | jvm 1 | 2015/09/18 02:17:31 |INFO | jv

40、m 1 | 2015/09/18 02:17:31 | log4j 2015-09-18 02:17:31 ./conf/log4j.xml load completed.INFO | jvm 1 | 2015/09/18 02:17:32 | MyCAT Server startup successfully. see logs in logs/mycat.logSTATUS | wrapper | 2015/09/18 03:39:27 | TERM trapped. Shutting down.STATUS | wrapper | 2015/09/18 03:39:28 | Wrappe

41、r Started as DaemonSTATUS | wrapper | 2015/09/18 03:39:29 | Launching a JVM.INFO | jvm 1 | 2015/09/18 03:39:29 | Java HotSpot(TM) 64-Bit Server VM warning: ignoringoption MaxPermSize=64M 。 support was removed in 8.0INFO | jvm 1INFO | jvm 1Reserved.INFO | jvm 1INFO | jvm 1INFO | jvm 1| 2015/09/18 03:

42、39:30 | Wrapper (Version 3.2.3)| 2015/09/18 03:39:30 | Copyright 1999-2006 Tanuki Software, Inc. All Rights| 2015/09/18 03:39:30 | 2015/09/18 03:39:30 | 2015/09/18 03:39:30 | WrapperSimpleApp: Encountered an error running main:java.lang.ExceptionInInitializerErrorINFO | jvm 1 | 2015/09/18 03:39:30 |

43、 java.lang.ExceptionInInitializerErrorINFO|jvm1|2015/09/1803:39:30|org.opencloudb.MycatStartup.main(MycatStartup.java:46)INFO|jvm1|2015/09/1803:39:30|sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)INFO|jvm1|2015/09/1803:39:30|sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)INF

44、O|jvm1|2015/09/1803:39:30|sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)INFO | jvm 1 | 2015/09/18 03:39:30 | at java.lang.reflect.Method.invoke(Unknown Source)INFO | jvm 1 | 2015/09/18 03:39:30 | atorg.tanukisoftware.wrapper.WrapperSimpleApp.run(WrapperSimpleApp.java:240)INFO | jvm

45、1 | 2015/09/18 03:39:30 | at java.lang.Thread.run(Unknown Source)INFO | jvm 1 | 2015/09/18 03:39:30 | Caused by: org.opencloudb.config.util.ConfigException: useradminz duplicated!INFO|jvm1|2015/09/1803:39:30|atorg.opencloudb.config.loader.xml.XMLServerLoader.loadUsers(XMLServerLoader.java:168)INFO|j

46、vm1|2015/09/1803:39:30|atorg.opencloudb.config.loader.xml.XMLServerLoader.load(XMLServerLoader.java:88)INFO|jvm1|2015/09/1803:39:30|atorg.opencloudb.config.loader.xml.XMLServerLoader.(XMLServerLoader.java:61)INFO|jvm1|2015/09/1803:39:30|atorg.opencloudb.config.loader.xml.XMLConfigLoader.(XMLConfigLo

47、ader.java:60)INFO|jvm1|2015/09/1803:39:30|atorg.opencloudb.ConfigInitializer.(ConfigInitializer.java:64)INFO|jvm1|2015/09/1803:39:30|atorg.opencloudb.MycatConfig.(MycatConfig.java:69)INFO|jvm1|2015/09/1803:39:30|atorg.opencloudb.MycatServer.(MycatServer.java:103)atatatatINFO|jvm1|2015/09/1803:39:30|

48、atorg.opencloudb.MycatServer.(MycatServer.java:72)INFO | jvm 1 | 2015/09/18 03:39:30 | . 7 more STATUS | wrapper | 2015/09/18 03:39:32 | - WrapperStopped rootnode24 conf#cat ./logs/mycat.log 看到如上的报错at java.lang.Thread.run(Unknown Source) 是第二个这个不能改user yungui truerootnode24 conf#cat server.xml druidp

49、arser!- 1- !-40960 -!-1 32 -!-65535-!-0- !-1- !-1- !-16- !-1 0 ： 开 启 小 数 量 级 ( 默 认) ；1：开启亿级数据排序100 亿级数量排序批量32name=processorExecutor328066name=managerPort9066300000name=bindIp4096name=processors32 -xinchengyunguiyunguiuseryunguitrue!- 1 -!- test -再起启动成功。rootnode24 conf#cat dnindex.pr

50、operties#update#Fri Sep 18 03:58:06 CST 20156=05=04=03=02=0生成新的这个文件创建表mysql -uadminz -pzuo123 -h -P8066 -Dyunguimysql show databases。+-+| DATABASE |+-+| yungui |propertypropertyproperty INSERT INTO elog ( id, accountcode, consumetype, consum

51、evalue, moneytype,chargedtype, targetid, consumetime, opuserid, content, note1, note2, isbackmoney,consumestauts) VALUES (1945, 118271404223146566920190, 0, -0.5, 0, 0, 10214131,2014-07-03 09:43:13, 347, NULL, NULL, NULL, 1, 0)。Query OK, 1 row affected (0.01 sec)INSERT INTO elog (accountcode, consum

52、etype, consumevalue, moneytype, chargedtype,targetid, consumetime, opuserid, content, note1, note2, isbackmoney, consumestauts) VALUES(118271404223146566920190, 0, -0.5, 0, 0, 10214131, 2014-0703 09:43:13, 347, NULL, NULL,NULL, 1, 0)。ERROR 1003 (HY000): mycat sequnce err.java.lang.NumberFormatExcept

53、ion: null mysql上面是什么问题呢？去除 id 列插入就报错了 这说明了 自增主键不能自增况下可为负)，以元为单位，最小值为 0.1,moneytype tinyint(2) NOT NULL COMMENT 0chargedtype tinyint(2) NOT NULL COMMENT 0targetid decimal(11,0) NOT NULL COMMENT consumetime datetime NOT NULL DEFAULT：普通 1 ：优惠券 ,：放件 1 揽件 2 广告， 3 市民卡充值 , 快件id,揽件 id,广告 id 等 （消费实体 id） , 17

54、53-01-0112:00:00 COMMENT yyyy-dd-自增主键1. 配置 server.xml 开启数据库层面设计的自增主键 还有基于本地的和 catle 的 但是我这里 用基于数据库的也是 mycat 作者推荐的方式12. 配置 sequence_db_perties rootnode24 conf#vi sequence_db_perties#sequence stored in datanodeGLOBAL=dn1COMPANY=dn1CUSTOMER=dn1ORDERS=dn1tt2=dn1TT2=dn1elog=dn1ELOG=dn1重启

55、mycattail -f /usr/local/mycat/logs/mycat.log pool,create new connection for hostS1 of schema db1 通过本地方式连接rootnode24 conf#mysql -p123456Warning: Using a password on the command line interface can be insecure. Welcome to the MySQLmonitor. Commands end with 。 or g.Your MySQL connection id is 135Server

56、version: 5.6.22-log MySQL Community Server (GPL)Copyright (c) 2000, 2014, Oracle and/or its affiliates. All rights reserved.Oracle is a registered trademark of Oracle Corporation and/or its affiliates. Other names may betrademarks of their respective owners.Type help。 or h for help. Type c to clear

57、the current input statement. 下面的操作需在每一台数据库实例上做mysqlDROP TABLE IF EXISTS MYCA T_SEQUENCE 。DROP FUNCTION IF EXISTS mycat_seq _n extval 。09/18 06:38:49.139 INFO Timer1 (PhysicalDatasource.java:373)pool,create new connection for hostS1 of schema db509/18 06:38:49.140 INFO Timer1 (PhysicalDatasource.java

58、:373)pool,create new connection for hostS1 of schema db409/18 06:38:49.149 INFO Timer1 (PhysicalDatasource.java:373)pool,create new connection for hostS1 of schema db309/18 06:38:49.150 INFO Timer1 (PhysicalDatasource.java:373)pool,create new connection for hostS1 of schema db209/18 06:38:49.152 INF

59、O Timer1 (PhysicalDatasource.java:373)-not ilde connection in-not ilde connection in-not ilde connection in-not ilde connection in-not ilde connection inDROP FUNCTION IF EXISTS mycat_seq_setval 。DROP FUNCTION IF EXISTS mycat_seq_setval 。CREATE TABLE MYCA T_SEQUENCE ( name VARCHAR(50) NOT NULL, curre

60、nt_value INT NOTNULL, increment INT NOT NULL DEFAULT 100, PRIMARY KEY (name) ) ENGINE=InnoDB 。- Function structure for mycat_seq_currvalDROP FUNCTION IF EXISTS mycat_seq_currval 。DELIMITER 。CREATE FUNCTION mycat_seq_currval(seq_name VARCHAR(50) RETURNS varchar(64)CHARSET latin1DETERMINISTICBEGINDECL