MyCat.Data.MyCatClient.MyCatException:“Unknown command”

[conanl5566]

MyCat.Data.MyCatClient.MyCatException:“Unknown command”

循环执行的时候 为什么会这样
for (int i = 0; i < 1000; i++)

		{
			var conn = new MyCatConnection("server=localhost;port=8066;database=TESTDB;uid=root;pwd=123456;CharSet=utf8;pooling=true");
		 conn.Execute("INSERT INTO `test` (`name`) VALUES ( '" + System.DateTime.Now.ToString() + "')");
		}

结果只插入第一条马上报错

[yukozh]

1. MyCatConnector has not been published yet, are you sure you are using this library? Are you using the Pomelo.Data.MyCat?
2. You have to paste your exception, stack trace, library version, MyCAT version when you opening an issue.
3. The connection must be opened when executing a command.
4. Since you want to execute the command in a loop, your code should be:

using (var conn = new MyCatConnection("<Your connnection string>"))
{
    conn.Open();
    for (var i = 0; i < 100; i++)
    {
        var command = new MyCatCommand("Your sql command", conn);
        command.ExecuteNonQuery();
    }
}

5. Your code has a SQL injection leak, please DO NOT concat command string. To use parameter query will solve this leak.
6. Pomelo Foundation accepts English issue only, you'd better open issue in English, thanks.

[conanl5566]

for (int i = 0; i <100 ; i++)

		{

			//   ThreadStart threadStart = new ThreadStart(dddd);

			Thread thread = new Thread(new System.Threading.ParameterizedThreadStart(dddd));

			thread.Start(i);

		}




static  void dddd(object arg)
	{

		using (var conn = new MyCatConnection("server=localhost;port=8066;database=TESTDB;uid=root;pwd=123456;CharSet=utf8;pooling=true;Connection Timeout=10"))
		{
			conn.Open();
			for (var i = 0; i < 100; i++)
			{
				var command = new MyCatCommand("INSERT INTO `test` (`name`) VALUES ( '" + System.DateTime.Now.ToString() + "')", conn);
				command.ExecuteNonQuery();
			}
		}

发生了 MyCat.Data.MyCatClient.MyCatException
HResult=0x80004005
Message=backend connect: ConnectionException [code=1040, msg=Too many connections]
Source=mscorlib
StackTrace:
在 System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
在 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
在 System.Runtime.CompilerServices.ConfiguredValueTaskAwaitable1.ConfiguredValueTaskAwaiter.GetResult() 在 MyCat.Data.MyCatClient.Results.ResultSet.<ReadResultSetHeaderAsync>d__1.MoveNext() 在 C:\Users\admin\Desktop\MyCATConnector-master\src\MyCATConnector\MyCatClient\Results\ResultSet.cs 中: 第 34 行 在 System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task) 在 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) 在 System.Runtime.CompilerServices.ConfiguredTaskAwaitable1.ConfiguredTaskAwaiter.GetResult()
在 MyCat.Data.MyCatClient.MyCatDataReader.d__62.MoveNext() 在 C:\Users\admin\Desktop\MyCATConnector-master\src\MyCATConnector\MyCatClient\MyCatDataReader.cs 中: 第 220 行
在 System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
在 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
在 System.Runtime.CompilerServices.ConfiguredTaskAwaitable.ConfiguredTaskAwaiter.GetResult()
在 MyCat.Data.MyCatClient.MyCatDataReader.d__61.MoveNext() 在 C:\Users\admin\Desktop\MyCATConnector-master\src\MyCATConnector\MyCatClient\MyCatDataReader.cs 中: 第 214 行
在 System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
在 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
在 System.Runtime.CompilerServices.ConfiguredTaskAwaitable1.ConfiguredTaskAwaiter.GetResult() 在 MyCat.Data.MyCatClient.CommandExecutors.TextCommandExecutor.<ExecuteReaderAsync>d__3.MoveNext() 在 C:\Users\admin\Desktop\MyCATConnector-master\src\MyCATConnector\MyCatClient\CommandExecutors\TextCommandExecutor.cs 中: 第 66 行 在 System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task) 在 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) 在 System.Runtime.CompilerServices.ConfiguredTaskAwaitable1.ConfiguredTaskAwaiter.GetResult()
在 MyCat.Data.MyCatClient.CommandExecutors.TextCommandExecutor.d__1.MoveNext() 在 C:\Users\admin\Desktop\MyCATConnector-master\src\MyCATConnector\MyCatClient\CommandExecutors\TextCommandExecutor.cs 中: 第 20 行
在 System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
在 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
在 System.Runtime.CompilerServices.ConfiguredTaskAwaitable1.ConfiguredTaskAwaiter.GetResult() 在 MyCat.Data.MyCatClient.MyCatCommand.<ExecuteNonQueryAsync>d__46.MoveNext() 在 C:\Users\admin\Desktop\MyCATConnector-master\src\MyCATConnector\MyCatClient\MyCatCommand.cs 中: 第 124 行 在 System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task) 在 System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) 在 System.Runtime.CompilerServices.TaskAwaiter1.GetResult()
在 MyCat.Data.MyCatClient.MyCatCommand.ExecuteNonQuery() 在 C:\Users\admin\Desktop\MyCATConnector-master\src\MyCATConnector\MyCatClient\MyCatCommand.cs 中: 第 59 行
在 ConsoleApp1.Program.dddd(Object arg) 在 C:\Users\admin\Desktop\MyCATConnector-master\ConsoleApp1\Program.cs 中: 第 49 行
在 System.Threading.ThreadHelper.ThreadStart_Context(Object state)
在 System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx)
在 System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx)
在 System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state)
在 System.Threading.ThreadHelper.ThreadStart(Object obj)

mysql 配置
max_connections=100000
mycat 配置

select user()

[conanl5566]

<dataHost name="localhost1" maxCon="1000000" minCon="1" balance="0"
		  writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
	<heartbeat>select user()</heartbeat>
	 <!--can have multi write hosts--> 
	<writeHost host="hostM1" url="localhost:3306" user="root"
			   password="123456">

[conanl5566]

pomelo.Data.MyCat 支持多线程 ？