MySQL Server закрывает соединение при выполнении запроса [закрыто] ⇐ MySql

[Anonymous]

Я использовал Putty, чтобы создать соединение SSH (rlogin) на моем сервере удаленной базы данных (MySQL). Похоже, он работает (без исключения на dbconnection.open ()) < /p>
позже в моем приложении я выполняю следующий код: < /p>
MySqlCommand getCustomers = new MySqlCommand("SELECT * FROM Customer WHERE Active = 1 ORDER BY CustomerName", dbConnection);

MySqlDataReader customersReader = getCustomers.ExecuteReader();
< /code>
getCustomers.execuTerReader (). Вызывает исключение: < /p>

socketException: установленное соединение было прервано программным обеспечением в вашем хост -машине < /p>
< /blockquote>
Я положил на Statement reecter statemied at atemired at atemired. Это открыто в этот момент, поэтому может показаться, что оператор приводит к закрытию соединения. против ключей) < /p>
Вот класс, который я использую для создания соединения: < /p>
using MySqlConnector;
using Renci.SshNet;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Bella
{
public class DBConnection
{
public static MySqlConnection getConnection()
{
string sshServer = "mySSHServer";

string sshUserName = "ainswort";

string sshPassword = "mySSHPassword";

string databaseServer = "mySSHServer";

string databaseUserName = "ainswort_Anita";

string databasePassword = "myDBPassword";

var (sshClient, localPort) = ConnectSsh(sshServer, sshUserName, sshPassword, databaseServer: databaseServer);

using (sshClient)

{

MySqlConnectionStringBuilder csb = new MySqlConnectionStringBuilder

{

Server = "127.0.0.1",

Port = localPort,

UserID = databaseUserName,

Password = databasePassword,

};

MySqlConnection connection = new MySqlConnection(csb.ConnectionString);

connection.Open();

return connection;

}

}

public static (SshClient SshClient, uint Port) ConnectSsh(string sshHostName, string sshUserName, string sshPassword = null,

string sshKeyFile = null, string sshPassPhrase = null, int sshPort = 7822, string databaseServer = "localhost", int databasePort = 3306)

{

// check arguments

if (string.IsNullOrEmpty(sshHostName))

throw new ArgumentException($"{nameof(sshHostName)} must be specified.", nameof(sshHostName));

if (string.IsNullOrEmpty(sshHostName))

throw new ArgumentException($"{nameof(sshUserName)} must be specified.", nameof(sshUserName));

if (string.IsNullOrEmpty(sshPassword) && string.IsNullOrEmpty(sshKeyFile))

throw new ArgumentException($"One of {nameof(sshPassword)} and {nameof(sshKeyFile)} must be specified.");

if (string.IsNullOrEmpty(databaseServer))

throw new ArgumentException($"{nameof(databaseServer)} must be specified.", nameof(databaseServer));

// define the authentication methods to use (in order)

var authenticationMethods = new List();

if (!string.IsNullOrEmpty(sshKeyFile))

{

authenticationMethods.Add(new PrivateKeyAuthenticationMethod(sshUserName,

new PrivateKeyFile(sshKeyFile, string.IsNullOrEmpty(sshPassPhrase) ? null : sshPassPhrase)));

}

if (!string.IsNullOrEmpty(sshPassword))

{

authenticationMethods.Add(new PasswordAuthenticationMethod(sshUserName, sshPassword));

}

// connect to the SSH server

var sshClient = new SshClient(new ConnectionInfo(sshHostName, sshPort, sshUserName, authenticationMethods.ToArray()));

sshClient.Connect();

// forward a local port to the database server and port, using the SSH server

var forwardedPort = new ForwardedPortLocal("127.0.0.1", databaseServer, (uint)databasePort);

sshClient.AddForwardedPort(forwardedPort);

forwardedPort.Start();

return (sshClient, forwardedPort.BoundPort);

}
}
}


Подробнее здесь: https://stackoverflow.com/questions/794 ... ting-query