之前在 中已经讲了如何配置出 MyCat。下面讲其相关的使用。
对于 MyCat 监控官网还提供一个 MyCat-eye web 系统来展示它的运行情况。
下载:http://dl.mycat.io/
运行 eye 之前还需要安 zookeeper,所以先安装 ,
解压到 D:\zookeeper-3.4.6
到目录 conf 下创建 zoo.cfg 文件,默认就是加载这个文件,文件内容 我直接 copy 的 sample 里面的
- #zoo.cfg 的内容
- # 心跳检查的时间 2秒
- tickTime=2000
- # 初始化时 连接到服务器端的间隔次数,总时间10*2=20秒
- initLimit=10
- # ZK Leader 和follower 之间通讯的次数,总时间5*2=10秒
- syncLimit=5
- # 存储内存中数据库快照的位置,如果不设置参数,更新事务日志将被存储到默认位置。
- dataDir=D:\\zookeeper-3.4.6\\zkdata
- # 错误日志的存放位置
- dataLogDir=F:\\zookeeper-3.4.6\\logs
- # ZK 服务器端的监听端口
- clientPort=2181
然后 cd 到 bin 目录下 执行 zkServer.cmd 就启动成功了。
注意:dataDir 和 dataLogDir 目录不会自动创建,得手动创建才能启动。
可以用 netstat -ano|findstr "2181" 看看是否 OK。
也可以用 JPS 查看启动的 JAVA 进程的情况,会出现这样
- C:\windows\system32>jps
- 8068
- 10040 QuorumPeerMain // 这东西是zk的东西,源码有介绍
- 10556 Jps
也可以用自带客户端命令 : zkCli.cmd -server 127.0.0.1:2181
关于 JPS 的东西,可以自己去 JAVA_HOME\bin 目录下去看,里面很多命令
安装好 zookeeper 后,启动 MyCat
windows 启动
启动 start.bat
inux 启动
启动 start.sh
打开 mycat-web 窗口
输入网址:http://localhost:8082/mycat/
若没配置好 zookeeper 会出现下面的页面
当配置好后会出现:
添加 mycat 服务,用户名,密码为之前配置的 mycat ,123456,保存
还可以添加对 mysql 的监控,在 mysql 管理中添加。
对 SQL 的监控我这测试了几天,还没数据,可能哪里配置没有加,所以后面再处理。eye 具体的使用资料网上不是很多,需要自己探索。
在 vs 中 nuget 引入 Pomelo.Data.MyCat,但安装报下面的错
错误提示 net 框架 4.5 版本低了,所以调到 4.6。
MyCatConnection, MyCatCommand 等内容在命名空间 Pomelo.Data.MyCat 中. 按照常规的 ADO.NET 开发流程即可实现对 MyCAT 的操作。
Pomelo.Data.MyCat 的使用与 mysql 一致:
封装基础代码:
- private static readonly string connectionString = "server=localhost;database=TESTDB;uid=mycat;pwd=123456";
- /// <summary>
- /// 执行SQL语句,返回影响的记录数
- /// </summary>
- /// <param name="SQLString">SQL语句</param>
- /// <returns>影响的记录数</returns>
- public static int ExecuteSql(string SQLString, params MyCatParameter[] cmdParms)
- {
- using (MyCatConnection connection = new MyCatConnection(connectionString))
- {
- using (MyCatCommand cmd = new MyCatCommand())
- {
- try
- {
- PrepareCommand(cmd, connection, null, SQLString, cmdParms);
- int rows = cmd.ExecuteNonQuery();
- cmd.Parameters.Clear();
- return rows;
- }
- catch (MyCatException e)
- {
- throw e;
- }
- }
- }
- }
- /// <summary>
- /// 执行查询语句,返回DataSet
- /// </summary>
- /// <param name="SQLString">查询语句</param>
- /// <returns>DataSet</returns>
- public static DataSet Query(string SQLString)
- {
- using (MyCatConnection connection = new MyCatConnection(connectionString))
- {
- DataSet ds = new DataSet();
- try
- {
- connection.Open();
- MyCatDataAdapter command = new MyCatDataAdapter(SQLString, connection);
- command.Fill(ds, "ds");
- }
- catch (MyCatException ex)
- {
- throw new Exception(ex.Message);
- }
- return ds;
- }
- }
- private static void PrepareCommand(MyCatCommand cmd, MyCatConnection conn, MyCatTransaction trans, string cmdText, MyCatParameter[] cmdParms)
- {
- if (conn.State != ConnectionState.Open)
- conn.Open();
- cmd.Connection = conn;
- cmd.CommandText = cmdText;
- if (trans != null)
- cmd.Transaction = trans;
- cmd.CommandType = CommandType.Text;//cmdType;
- if (cmdParms != null)
- {
- foreach (MyCatParameter parameter in cmdParms)
- {
- if ((parameter.Direction == ParameterDirection.InputOutput || parameter.Direction == ParameterDirection.Input) &&
- (parameter.Value == null))
- {
- parameter.Value = DBNull.Value;
- }
- cmd.Parameters.Add(parameter);
- }
- }
- }
插入数据:
- string name = textBox1.Text;
- if (string.IsNullOrEmpty(name)) return;
- StringBuilder strSql = new StringBuilder();
- strSql.Append("insert into hotnews(");
- strSql.Append("newsname)");
- strSql.Append(" values (");
- strSql.Append("@newsname)");
- MyCatParameter[] parameters = {
- new MyCatParameter("@newsname", MyCatDbType.VarChar,100),
- };
- parameters[0].Value = name;
- int rows = ExecuteSql(strSql.ToString(), parameters);
- if (rows > 0)
- {
- label1.Text = "添加成功";
- }
- else
- {
- label1.Text = "添加失败";
- }
查询数据:
- StringBuilder strSql = new StringBuilder();
- strSql.Append("select * ");
- strSql.Append(" FROM hotnews ");
- DataSet ds = Query(strSql.ToString());
- dataGridView1.DataSource = ds.Tables[0];
MyCat 主键 ID 自增长配置,但保存时还是会出现下面的情况,当还是没指定 ID 时,插入的 ID 还是下面的 ID 会导致插入失败,因此想做分布式最好是将 ID 设置为自己生成 GUID,这样不管哪个库都是全局唯一。若还是想自增型,可以参考园友这篇:
需要提醒的是 MyCat 不仅用于 MySQL,而且支持 Oracle、DB2、SQL Server、PostgreSQL 等
基于心跳的自动故障切换,支持读写分离,支持 MySQL 主从,以及 galera cluster 集群
支持单库内部任意 join,支持跨库 2 表 join,甚至基于 caltlet 的多表 join
支持数据的多片自动路由与聚合,支持 sum,count,max 等常用的聚合函数, 支持跨库分页
更多功能请参考官网
MyCat 官网:http://www.mycat.org.cn/
来源: http://www.cnblogs.com/zhangs1986/p/6418898.html