2010-08-11 20:55:09,489 INFO server.MysqlClientAuthenticator - Accepting request: conn=com.meidusa.amoeba.mysql.net.MysqlClientConnection@192.168.1.211:22709,hashcode=1583634598
2010-08-11 20:55:09,489 DEBUG auth - authentication time:3 Id=/192.168.1.211
2010-08-11 20:55:09,491 ERROR handler.CommandMessageHandler - <>

2010-08-11 20:55:09,491 WARN handler.CommandMessageHandler - session was killed!!
java.lang.Exception
at com.meidusa.amoeba.mysql.handler.CommandMessageHandler.endSession(CommandMessageHandler.java:643)
at com.meidusa.amoeba.mysql.handler.CommandMessageHandler.handleMessage(CommandMessageHandler.java:247)
at com.meidusa.amoeba.net.Connection.messageProcess(Connection.java:292)
at com.meidusa.amoeba.net.Connection.handleEvent(Connection.java:264)
at com.meidusa.amoeba.net.ConnectionManager.iterate(ConnectionManager.java:212)
at com.meidusa.amoeba.util.LoopingThread.run(LoopingThread.java:65)

————–以下是回复内容—————–
Session was killed 原因：
1、sql查询时间过长。导致amoeba中断超时的请求
2、客户端在请求过程中，amoeba需要改变客户端连接的一些环境，诸如select dbname等操作，如果db不存在，则也会发生类似问题

开始怀疑是dbcp的问题，但是另外一台同样的用法，但没有用amoeba就没有这样的问题，所以最终还是把问题锁定在amoeba上面，现在用1.2.1GA版的时候amoeba的日志会抛出下面的异常:

2010-08-11 10:30:48,035 INFO server.MysqlClientAuthenticator - Accepting request: conn=com.meidusa.amoeba.mysql.net.MysqlClientConnection@127.0.0.1:50439,hashcode=16994425

2010-08-11 10:30:48,036 DEBUG auth - authentication time:7 Id=/127.0.0.1

2010-08-11 10:30:48,073 ERROR handler.CommandMessageHandler - <>

2010-08-11 10:30:48,074 WARN handler.CommandMessageHandler - session was killed!!

java.lang.Exception

at com.meidusa.amoeba.mysql.handler.CommandMessageHandler.endSession(CommandMessageHandler.java:643)

at com.meidusa.amoeba.mysql.handler.CommandMessageHandler.handleMessage(CommandMessageHandler.java:247)

at com.meidusa.amoeba.net.Connection.messageProcess(Connection.java:292)

at com.meidusa.amoeba.net.Connection.handleEvent(Connection.java:264)

at com.meidusa.amoeba.net.ConnectionManager.iterate(ConnectionManager.java:212)

at com.meidusa.amoeba.util.LoopingThread.run(LoopingThread.java:65)

不清楚是不是哪里配置出问题了？
——————-以下是回复内容—————————
你的配置没有错，你需要看一下，有些sql是否耗时比较厉害？

—————以下是回复内容———————
如果这些表的规则一样，那么就可以在一个规则中配置就可以了
tableRule 中的name可以是 schema.name([,schema.name])*– 多个表可以用逗号分割

异常详细信息: MySql.Data.MySqlClient.MySqlException: #42000can not use this command here!!

我使用的mysql的.net连接器.
我不知道是哪里配置有错误.
盼复,谢谢!

———–以下是回复内容—————————
你好,可能有些mysql命令我这儿还没有实现,诸如通过非command命令行模式来跟服务器交互.
接下来将会增加这方面命令的支持.

——————–以下是回复内容——————-
利用amoeba做切分的时候，需要规避类似你上面的语句出现，除非你非常了解这些表的数据切分规则，确保他们在相同条件下数据是在相同的机器上面。

－－－－－－－以下是回复内容－－－－－－－－－－－
我们先略过如何配置dbServer，假设我们已经配置好了2个dbServer分别是:
dbServer1 — 存放myDB.user的 user_id < = 1000 的数据
dbServer2 -- 存放myDB.user的 user_id > 1000 的数据

那如何设置规则：
比如规则如下:

<tableRule name="user" schema="myDB" defaultPools="dbServer1,dbServer2">
<rule name="rule1">
<parameters>USER_ID</parameters>
<expression><![CDATA[ USER_ID <= 1000]]></expression>
<defaultPools>dbServer1</defaultPools>
</rule>
<rule name="rule2">
<parameters>USER_ID</parameters>
<expression><![CDATA[ USER_ID >1000]]></expression>
<defaultPools>dbServer2</defaultPools>
</rule>
</tableRule>

上面的规则tableRule：表示一个表或者多个表的规则，这些表都具有相同的规则,比如我有很多个table（db1.message db2.friend）并且他们规则都是一样的，
tableRule 中的name可以这样写”myDB.user,db1.message,db2.friend” 这儿的schema为默认，如果table前面没有带database名字，则用默认的myDB

<tableRule name="myDB.user,db1.message,db2.friend" schema="myDB" defaultPools="dbServer1,dbServer2">


我们再看这样的一条sql:
insert into myDB.user(user_id,name,age) values(333,'hello',108);
user表我们需要按照 user_id来进行水平切分，那么在所有sql中必须包含user_id，并且user_id必须有明确的值，否则amoeba将不知道 user_id的数据。

因此我们写这样的规则：

<rule name="rule1">
<parameters>USER_ID</parameters>
<expression><![CDATA[ USER_ID <= 1000]]></expression>
<defaultPools>dbServer1</defaultPools>
</rule>

上述的 parameters 中是参与规则切分表达式的 column名字，多个column按逗号分割
如果不包含parameters中设置的所有clolumns，则这条规则将不匹配。
再看我们的sql语句：
insert into myDB.user(user_id,name,age) values(333,'hello',108);
1. 首先amoeba先解析这个sql语句，得出myDB.user 这个表.并且解析这个sql语句中myDB.user 的所有条件(user_id=333 , name=’hello’, age=108)
2. 看myDB.user是否有相应的tableRule配置，如果没有则采用amoeba.xml中的defaultPools
3. 如果有myDB.user的tableRule，遍历这个tableRule中的所有Rule，匹配的过程是：首先看parameters中所有 column，比如rule1中有parameters=USER_ID，那么sql中一定需要包含user_id=**这个条件，否则这个规则将不匹配。

4. 如果匹配了以后，再判断这个sql是读的还是写的，如果读则将sql发生到 rule.readPools中执行，否则rule.writePools，如果 rule.readPools，rule.writePools都没配置，则会发送到 rule.defaultPools,
如果所有的规则都不匹配则将发送到 （tableRule.readPools/tableRule.writePools/tableRule.defaultPools)

举个例子：
比如我要执行一条sql： select * from myDB.user where user_id = 1;
这条sql应该发送到 dbServer1上面执行

－－－－－－以下是回复内容－－－－－－－－－－－－－－－
amoeba.xml里面的schema是初始化连接的时候默认连接的数据库

rule.xml里面的rule中的schema则是表示当前执行的sql是在哪个database下面，比如这样一个sql：
select * from myDB.testTable where id = 1;

这个时候rule中的schema应该是 myDB
这个sql也可以分成2步执行：
1、use myDB;
2、select * from testTable where id =1;
那么TableRule中只要schema=myDB 并且 name=testTable 将会执行这个rule