using System;
using System.Data;
using System.Data.SqlClient;
class SqlDemo {
static void Main(){
string connString = "server=(local)SQLEXPRESS;database=MyDatabase;Integrated Security=SSPI";
SqlConnection cn = new SqlConnection(connString);
cn.InfoMessage += new SqlInfoMessageEventHandler(CnInfoMessage);
cn.StateChange += new StateChangeEventHandler(CnStateChange);
SqlCommand cmd = new SqlCommand();
cmd.CommandText = "SELECT TOP 2 Id FROM Employee";
cmd.Connection = cn;
try
{
cn.Open();
SqlDataReader dr = cmd.ExecuteReader();
while(dr.Read())
{
Console.WriteLine(dr.GetInt32(0));
}
dr.Close();
cmd.CommandText = "PRINT 'Get Id for all Employees'";
cmd.ExecuteNonQuery();
}
catch(SqlException ex)
{
Console.WriteLine(ex.Message);
}
finally
{
cn.Close();
}
}
static void CnInfoMessage(object sender, SqlInfoMessageEventArgs ev)
{
foreach (SqlError err in ev.Errors)
{
Console.WriteLine("Entering InfoMessage Event Handler");
Console.WriteLine("Source- " + err.Source);
Console.WriteLine("State- " + err.State);
Console.WriteLine("Number- " + err.Number);
Console.WriteLine("Procedure- " + err.Procedure);
Console.WriteLine("Server- " + err.Server);
Console.WriteLine("Message- " + err.Message);
Console.WriteLine("Exiting InfoMessage Event Handler");
}
}
static void CnStateChange(object sender, StateChangeEventArgs ev)
{
Console.WriteLine("Entering StateChange EventHandler");
Console.WriteLine("Sender = "+ sender.ToString());
Console.WriteLine("Original State = "+ ev.OriginalState.ToString());
Console.WriteLine("Current State = "+ ev.CurrentState.ToString());
Console.WriteLine("Exiting StateChange EventHandler");
}
}
Month: February 2011
SqlConnection state change event
using System;
using System.Data;
using System.Data.SqlClient;
class SqlDemo {
static void Main(){
string connString = "server=(local)SQLEXPRESS;database=MyDatabase;Integrated Security=SSPI";
SqlConnection cn = new SqlConnection(connString);
SqlCommand cmd = new SqlCommand();
cmd.CommandText = "SELECT TOP 1 Id, FirstName FROM Employee";
cmd.Connection = cn;
cn.StateChange += new StateChangeEventHandler(CnStateChange);
try
{
cn.Open();
SqlDataReader dr = cmd.ExecuteReader();
while(dr.Read()) {
Console.WriteLine(dr.GetString(0) + "-" + dr.GetString(1));
}
}
catch(SqlException e1)
{
Console.WriteLine(e1.Message);
}
finally
{
cn.Close();
}
}
static void CnStateChange(object sender, StateChangeEventArgs ev)
{
Console.WriteLine("------------------------------");
Console.WriteLine("Entering StateChange EventHandler");
Console.WriteLine("Sender = "+ sender.ToString());
Console.WriteLine("Original State = "+ ev.OriginalState.ToString());
Console.WriteLine("Current State = "+ ev.CurrentState.ToString());
Console.WriteLine("Exiting StateChange EventHandler");
Console.WriteLine("------------------------------");
}
}
DataSource
using System;
using System.Data.SqlClient;
class MainClass {
public static void Main(string[] args) {
string conString = @"Data Source=.sqlexpress;" +
"Database=Northwind;Integrated Security=SSPI;" +
"Min Pool Size=5;Max Pool Size=15;Connection Reset=True;" +
"Connection Lifetime=600;";
SqlConnectionStringBuilder sb1 = new SqlConnectionStringBuilder(conString);
Console.WriteLine(" Database Source = " + sb1.DataSource);
SqlConnectionStringBuilder sb2 = new SqlConnectionStringBuilder(conString);
sb2.DataSource = @".sqlexpress";
Console.WriteLine(" " + sb2.ConnectionString);
}
}
Connection String
using System;
using System.Data.SqlClient;
class MainClass {
public static void Main() {
using (SqlConnection con = new SqlConnection()) {
con.ConnectionString =
@"Data Source = .sqlexpress;" +// local SQL Server instance
"Database = Northwind;" + // the sample Northwind DB
"Integrated Security = SSPI;" + // integrated Windows security
"Min Pool Size = 5;" + // configure minimum pool size
"Max Pool Size = 15;" + // configure maximum pool size
"Connection Reset = True;" + // reset connections each use
"Connection Lifetime = 600"; // set max connection lifetime
con.Open();
}
using (SqlConnection con = new SqlConnection()) {
con.ConnectionString =
@"Data Source = .sqlexpress;" +//local SQL Server instance
"Database = Northwind;" + //the sample Northwind DB
"Integrated Security = SSPI;" + //integrated Windows security
"Pooling = False"; //specify nonpooled connection
con.Open();
}
}
}
PacketSize
using System;
using System.Data;
using System.Data.SqlClient;
using System.Data.OleDb;
class MainClass {
public static void Main() {
using (SqlConnection con = new SqlConnection()) {
con.ConnectionString = @"Data Source=.sqlexpress;Database=Northwind;Integrated Security=SSPI";
con.Open();
if (con.State == ConnectionState.Open) {
Console.WriteLine(" Packet Size = " + con.PacketSize);
} else {
Console.WriteLine("SqlConnection failed to open.");
Console.WriteLine(" Connection State = " + con.State);
}
}
}
}
ConnectionTimeout
using System;
using System.Data;
using System.Data.SqlClient;
using System.Data.OleDb;
class MainClass {
public static void Main() {
using (SqlConnection con = new SqlConnection()) {
con.ConnectionString = @"Data Source=.sqlexpress;Database=Northwind;Integrated Security=SSPI";
con.Open();
if (con.State == ConnectionState.Open) {
Console.WriteLine(" Timeout = " + con.ConnectionTimeout);
} else {
Console.WriteLine("SqlConnection failed to open.");
Console.WriteLine(" Connection State = " + con.State);
}
}
}
}
WorkstationId
using System;
using System.Data;
using System.Data.SqlClient;
using System.Data.OleDb;
class MainClass {
public static void Main() {
using (SqlConnection con = new SqlConnection()) {
con.ConnectionString = @"Data Source=.sqlexpress;Database=Northwind;Integrated Security=SSPI";
con.Open();
if (con.State == ConnectionState.Open) {
Console.WriteLine(" Workstation Id = " + con.WorkstationId);
} else {
Console.WriteLine("SqlConnection failed to open.");
Console.WriteLine(" Connection State = " + con.State);
}
}
}
}

