我是memsql数据库的新手,我在linux redhat v6上安装了memsql数据库服务器。
我还创建了一个名为“test”的测试数据库,用户名是:root,密码是:root
我可以在本地连接到这个数据库,我也知道我可以使用mysql provider for odbc从windows连接到memsql数据库。我试图从windows连接到memsql,但出现了一个错误(连接失败:驱动程序在“读取初始通信包”时与mysql服务器失去连接)。
我的问题是:是否可以从windows连接到memsql数据库?如果是,我如何使用c(我应该使用什么提供者、配置等)来实现这一点。
谢谢您
最佳答案
这看起来更像是网络/防火墙问题。最简单的检查方法是禁用客户端和服务器上的防火墙,以查看是否一切正常。
memsql只使用mysql兼容性,因此mysql的官方c客户端可以正常工作。您可以从nuget安装:https://www.nuget.org/packages/MySql.Data/
PM> Install-Package MySql.Data
以下是memsql文档中测试插入的一个快速示例:
http://docs.memsql.com/latest/concepts/multi_insert_examples/#c
using System;
using System.Data;
using System.Threading;
using System.Diagnostics;
using MySql.Data.MySqlClient;
namespace MemSQLTest {
//Thread creates a connection and inserts for 1000 milliseconds
public class WorkerThread {
public static void Thread() {
try {
IDbConnection conn;
conn = new MySql.Data.MySqlClient.MySqlConnection();
conn.ConnectionString = "Server=127.0.0.1;Uid=root;Pwd=;";
conn.Open();
IDbCommand dbcmd = conn.CreateCommand();
dbcmd.CommandText = "USE db";
dbcmd.ExecuteNonQuery();
dbcmd.CommandText = "INSERT INTO t VALUES (DEFAULT)";
Stopwatch stop = new Stopwatch();
stop.Start();
while(stop.ElapsedMilliseconds < 1000)
{
dbcmd.ExecuteNonQuery();
}
} catch (Exception ex) {
Console.WriteLine(ex.Message);
}
}
}
class MemSQLTest {
static void Main(string[] args) {
try {
IDbConnection conn;
conn = new MySql.Data.MySqlClient.MySqlConnection();
conn.ConnectionString = "Server=127.0.0.1;Uid=root;Pwd=;";
conn.Open();
//Initialize database with auto increment table
IDbCommand dbcmd = conn.CreateCommand();
dbcmd.CommandText = "DROP DATABASE IF EXISTS db";
dbcmd.ExecuteNonQuery();
dbcmd.CommandText = "CREATE DATABASE db";
dbcmd.ExecuteNonQuery();
dbcmd.CommandText = "USE db";
dbcmd.ExecuteNonQuery();
dbcmd.CommandText = "CREATE TABLE t (id int primary key auto_increment)";
dbcmd.ExecuteNonQuery();
//Initialize threads
Thread[] threads = new Thread[10];
for(int i = 0; i < 10; i++)
{
threads[i] = new Thread(new ThreadStart(WorkerThread.Thread));
threads[i].Start();
}
for(int i = 0; i < 10; i++)
{
threads[i].Join();
}
//Show select count(*) on auto increment table
dbcmd.CommandText = "SELECT COUNT(*) FROM t";
IDataReader reader = dbcmd.ExecuteReader();
while(reader.Read()) {
Console.WriteLine(reader["COUNT(*)"]);
}
} catch (Exception ex) {
Console.WriteLine(ex.Message);
}
}
}
}
关于c# - 从C#连接到MemSQL,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/24431268/