Добрый день!
Помогите, пожалуйста, в следующем: как запустить процедуру асинхронно. У меня в коде идет проверка подключения к SQL серверу, сервера берутся из listbox.

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Data.SqlClient;

namespace StatConSQL
{
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}

private void button1_Click(object sender, EventArgs e)
{


foreach (object item in listBox1.Items)
{
con(item.ToString());
}
}
public void con(string serv)
{
String connString = "Integrated Security=SSPI;Persist Security Info=False;Initial Catalog=master;Data Source="+serv+";Connect Timeout=3";
using (var conn = new SqlConnection(connString))
{
try
{
conn.Open();
MessageBox.Show(serv+" conn.Open");
}
catch (SqlException ex)
{
MessageBox.Show(ex.ToString() + conn.ConnectionString.ToString());
}
}
}
}
}

Pallaris,

а можно набросок применимо к моему примеру?

Pallaris,

пробежаться по listbox и для каждого item выполнить con(item.ToString()).
Результат выполнения вывести например в console. Дело в том, что для каждого sql сервера разное время ответа, некоторые могут вообще быть выключенными и тогда время отклика может достигать 30 секунд.

Pallaris,

да не будет у меня message box. У меня вообще будет служба, которая будет брать значения из таблицы sql, а рез-ты будут записываться в другую таблицу. Здесь у меня простой пример, чтобы отработать решение.

Я просто не знаю как мою процедуру запускать ассинхронно. Хотелось бы простой пример как это сделать.

Вот что получилось, но одна проблема: идет чтение из таблицы имя сервера, проверяется подключение con(string serv).
Но при этом проверка идет последовательно, т.е. проверяется один сервер, затем 2-й и т.д. А можно как-то сделать чтобы проверка по всем серверам была параллельна?


public static void BeginDataBaseCall()
{
Console.WriteLine("BeginDataBaseCall()");
string connetionString = null;
connetionString = "Asynchronous Processing=true;Integrated Security=SSPI;Persist Security Info=False;Initial Catalog=Baza;Data Source=Server";
SqlConnection connection;
connection = new SqlConnection(connetionString);
SqlCommand command = new SqlCommand("Select servername from table", connection);
connection.Open();
command.BeginExecuteReader(EndDatabaseCall, command);
Console.ReadLine();
}
public static void EndDatabaseCall(IAsyncResult result)
{
Console.WriteLine("EndDatabaseCall");
StringBuilder builder = new StringBuilder();
builder.Append("DbCall Results: ");
SqlCommand command = result.AsyncState as SqlCommand;

try
{
using (SqlDataReader reader = command.EndExecuteReader(result))
{
while (reader.Read())
{
con(reader[0].ToString());
}
}
}
catch
{
throw;
}
finally
{
#region Cleanup

command.Connection.Close();
command.Connection.Dispose();
command.Dispose();

#endregion

}

Console.WriteLine(builder.ToString());

}
private static void con(string serv)
{
String connString = "Integrated Security=SSPI;Persist Security Info=False;Initial Catalog=master;Data Source=" + serv + ";Connect Timeout=3";
using (var conn = new SqlConnection(connString))
{
try
{
conn.Open();

string folderPath = @"c:\temp";
if (!System.IO.Directory.Exists(folderPath))
System.IO.Directory.CreateDirectory(folderPath);

FileStream fs = new FileStream(folderPath + "\\WindowsService.txt", FileMode.OpenOrCreate, FileAccess.Write);
StreamWriter m_streamWriter = new StreamWriter(fs);
m_streamWriter.BaseStream.Seek(0, SeekOrigin.End);
m_streamWriter.WriteLine("conn.Open "+ serv);
m_streamWriter.Flush();
m_streamWriter.Close();

conn.Close();
}
catch (SqlException ex)
{
string folderPath = @"c:\temp";
if (!System.IO.Directory.Exists(folderPath))
System.IO.Directory.CreateDirectory(folderPath);

FileStream fs = new FileStream(folderPath + "\\WindowsService.txt", FileMode.OpenOrCreate, FileAccess.Write);
StreamWriter m_streamWriter = new StreamWriter(fs);
m_streamWriter.BaseStream.Seek(0, SeekOrigin.End);
m_streamWriter.WriteLine(ex.ToString() + serv);
m_streamWriter.Flush();
m_streamWriter.Close();
}
}
}

Arm79,

да. Пока 25. В будущем около 2000

Arm79,

но это только в .NET Framework 4.5? А с 4.0 как ?