Каков наилучший способ проверить соединение с SQL Server программно? - PullRequest
64 голосов
/ 14 марта 2010

Мне нужно разработать одну подпрограмму, которая будет запускаться каждые 5 минут, чтобы проверить, работает ли список SQL Server (от 10 до 12).

Я могу попытаться получить простой запрос на каждом из серверов, но это означает, что мне нужно создать таблицу, представление или хранимую процедуру на каждом сервере, даже если я использую какой-либо уже созданный SP, мне нужно зарегистрировать пользователь на каждом сервере тоже. Серверы не находятся в одном и том же физическом расположении, поэтому выполнение этих требований будет сложной задачей. Есть ли способ просто "пинговать" из C # один SQL Server?

Заранее спасибо!

Ответы [ 10 ]

63 голосов
/ 14 марта 2010

Выполнить SELECT 1 и проверить, возвращает ли ExecuteScalar значение 1.

60 голосов
/ 30 марта 2012

У меня были проблемы с EF, когда соединение с сервером было остановлено или приостановлено, и я поднял тот же вопрос. Так что для полноты приведенных ответов здесь приведен код.

/// <summary>
/// Test that the server is connected
/// </summary>
/// <param name="connectionString">The connection string</param>
/// <returns>true if the connection is opened</returns>
private static bool IsServerConnected(string connectionString)
{
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        try
        {
            connection.Open();
            return true;
        }
        catch (SqlException)
        {
            return false;
        }
    }
}
10 голосов
/ 09 июля 2013

Смотрите следующий проект на GitHub: https://github.com/ghuntley/csharp-mssql-connectivity-tester

try
{
    Console.WriteLine("Connecting to: {0}", AppConfig.ConnectionString);
    using (var connection = new SqlConnection(AppConfig.ConnectionString))
    {
        var query = "select 1";
        Console.WriteLine("Executing: {0}", query);

        var command = new SqlCommand(query, connection);

        connection.Open();
        Console.WriteLine("SQL Connection successful.");

        command.ExecuteScalar();
        Console.WriteLine("SQL Query execution successful.");
    }
}
catch (Exception ex)
{
    Console.WriteLine("Failure: {0}", ex.Message);
}
7 голосов
/ 14 марта 2010

Не установит ли соединение с базой данных это для вас? Если база данных не работает, вы не сможете установить соединение.

1 голос
/ 14 марта 2010

Для того, что предложил Джоэл Коорн, вы уже пробовали использовать утилиту с именем tcping . Я знаю, что это то, что вы не делаете программно. Это автономный исполняемый файл, который позволяет пинговать каждый указанный интервал времени. Это не в C #, хотя. Кроме того .. Я не уверен, что это сработает, если на целевой машине установлен брандмауэр .. ммм ..

[Я новичок в этом сайте и по ошибке добавил это как комментарий, теперь добавил это как ответ. Дайте мне знать, если это можно сделать здесь, поскольку у меня есть дубликаты комментариев (как комментарий и как ответ) здесь. Я не могу удалить комментарии здесь.]

1 голос
/ 14 марта 2010

Найдите открытый приемник на порту 1433 (порт по умолчанию). Если вы получите какой-либо ответ после создания там tcp-соединения, возможно, сервер работает.

0 голосов
/ 11 октября 2017

Похоже на ответ, предложенный Андреем, но я использую:

Выберите GetDate () в качестве CurrentDate

Это позволяет мне увидеть, есть ли у SQL Server и клиента какие-либо проблемы с разницей во временных зонах, в одном действии.

0 голосов
/ 14 июня 2017
public static class SqlConnectionExtension
{
    #region Public Methods

    public static bool ExIsOpen(this SqlConnection connection, MessageString errorMsg)
    {
        if (connection == null) return false;
        if (connection.State != ConnectionState.Open)
        {
            try
            {
                connection.Open();
            }
            catch (Exception ex) { errorMsg.Append(ex.ToString()); }
        }
        return true;
    }

    public static bool ExIsReady(this SqlConnection connction, MessageString errorMsg)
    {
        if (ExIsOpen(connction, errorMsg) == false) return false;
        try
        {
            using (SqlCommand command = new SqlCommand("select 1", connction))
            using (SqlDataReader reader = command.ExecuteReader())
                if (reader.Read()) return true;
        }
        catch (Exception ex) { errorMsg.Append(ex.ToString()); }
        return false;
    }

    #endregion Public Methods
}



public class MessageString : IDisposable
{
    #region Protected Fields

    protected StringBuilder _messageBuilder = new StringBuilder();

    #endregion Protected Fields

    #region Public Constructors

    public MessageString()
    {
    }

    public MessageString(int capacity)
    {
        _messageBuilder.Capacity = capacity;
    }

    public MessageString(string value)
    {
        _messageBuilder.Append(value);
    }

    #endregion Public Constructors

    #region Public Properties

    public int Length {
        get { return _messageBuilder.Length; }
        set { _messageBuilder.Length = value; }
    }

    public int MaxCapacity {
        get { return _messageBuilder.MaxCapacity; }
    }

    #endregion Public Properties

    #region Public Methods

    public static implicit operator string(MessageString ms)
    {
        return ms.ToString();
    }

    public static MessageString operator +(MessageString ms1, MessageString ms2)
    {
        MessageString ms = new MessageString(ms1.Length + ms2.Length);
        ms.Append(ms1.ToString());
        ms.Append(ms2.ToString());
        return ms;
    }

    public MessageString Append<T>(T value) where T : IConvertible
    {
        _messageBuilder.Append(value);
        return this;
    }

    public MessageString Append(string value)
    {
        return Append<string>(value);
    }

    public MessageString Append(MessageString ms)
    {
        return Append(ms.ToString());
    }

    public MessageString AppendFormat(string format, params object[] args)
    {
        _messageBuilder.AppendFormat(CultureInfo.InvariantCulture, format, args);
        return this;
    }

    public MessageString AppendLine()
    {
        _messageBuilder.AppendLine();
        return this;
    }

    public MessageString AppendLine(string value)
    {
        _messageBuilder.AppendLine(value);
        return this;
    }

    public MessageString AppendLine(MessageString ms)
    {
        _messageBuilder.AppendLine(ms.ToString());
        return this;
    }

    public MessageString AppendLine<T>(T value) where T : IConvertible
    {
        Append<T>(value);
        AppendLine();
        return this;
    }

    public MessageString Clear()
    {
        _messageBuilder.Clear();
        return this;
    }

    public void Dispose()
    {
        _messageBuilder.Clear();
        _messageBuilder = null;
    }

    public int EnsureCapacity(int capacity)
    {
        return _messageBuilder.EnsureCapacity(capacity);
    }

    public bool Equals(MessageString ms)
    {
        return Equals(ms.ToString());
    }

    public bool Equals(StringBuilder sb)
    {
        return _messageBuilder.Equals(sb);
    }

    public bool Equals(string value)
    {
        return Equals(new StringBuilder(value));
    }

    public MessageString Insert<T>(int index, T value)
    {
        _messageBuilder.Insert(index, value);
        return this;
    }

    public MessageString Remove(int startIndex, int length)
    {
        _messageBuilder.Remove(startIndex, length);
        return this;
    }

    public MessageString Replace(char oldChar, char newChar)
    {
        _messageBuilder.Replace(oldChar, newChar);
        return this;
    }

    public MessageString Replace(string oldValue, string newValue)
    {
        _messageBuilder.Replace(oldValue, newValue);
        return this;
    }

    public MessageString Replace(char oldChar, char newChar, int startIndex, int count)
    {
        _messageBuilder.Replace(oldChar, newChar, startIndex, count);
        return this;
    }

    public MessageString Replace(string oldValue, string newValue, int startIndex, int count)
    {
        _messageBuilder.Replace(oldValue, newValue, startIndex, count);
        return this;
    }

    public override string ToString()
    {
        return _messageBuilder.ToString();
    }

    public string ToString(int startIndex, int length)
    {
        return _messageBuilder.ToString(startIndex, length);
    }

    #endregion Public Methods
}
0 голосов
/ 10 января 2017

Подключение к mssql через C # очень проблематично.

Дескрипторы не будут единообразными после того, как мы подключимся, хотя мы закрыли соединение после подключения.

Я где-то читал, что это проблема .Net 4.0, и если вы используете .Net 3.5, все должно быть в порядке.

0 голосов
/ 14 марта 2010

Почему бы просто не подключиться к сеансу telnet на порту сервера sql. Если он подключается, сервер sql работает и счастлив, если нет, вам не повезло.

Этот другой StackOverflow post может быть хорошим началом для этого.

EDIT: Хорошо, теперь я полностью прочитал другие посты, это не совсем лучшее решение ... Тем не менее, если вы просто хотите пропинговать порт ....

...