วันพุธที่ 1 มีนาคม พ.ศ. 2560
C# connect sql server
ตัวอย่าง การเขียน C# เชื่อมต่อ Sql server คำสั่ง Select
public DataTable selectSQL(string tableName,string hash, string area)
{
string query = string.Format(@"SELECT * FROM {0} where [MD5Hash] = @MD5Hash AND [Area] = @Area", tableName);
DataTable dt = new DataTable();
using (SqlConnection conn = new SqlConnection(connectionString))
using (SqlDataAdapter sda = new SqlDataAdapter(query, conn))
{
sda.SelectCommand.CommandTimeout = TimeOut;
sda.SelectCommand.Parameters.Add("@MD5Hash", SqlDbType.NVarChar);
sda.SelectCommand.Parameters["@MD5Hash"].Value = hash;
sda.SelectCommand.Parameters.Add("@Area", SqlDbType.NVarChar);
sda.SelectCommand.Parameters["@Area"].Value = area;
sda.Fill(dt);
}
return dt;
}
ตัวอย่าง การเขียน C# เชื่อมต่อ Sql server คำสั่ง delete
private bool deleteSQL(string tableName,string hash)
{
int num = 0;
string query = string.Format(@"DELETE FROM [dbo].{0}
WHERE [MD5Hash] = @MD5Hash", tableName);
using (SqlConnection conn = new SqlConnection(connectionString))
{
SqlCommand command = new SqlCommand(query, conn);
command.Parameters.Add("@MD5Hash", SqlDbType.NVarChar);
command.Parameters["@MD5Hash"].Value = hash;
try
{
conn.Open();
//Int32 rowsAffected = command.ex
num = num + command.ExecuteNonQuery();
//Console.WriteLine("RowsAffected: {0}", rowsAffected);
}
catch (SqlException sqlEx)
{
//System.ArgumentException argEx = new System.ArgumentException(sqlEx.Message);
//throw argEx;
Console.WriteLine();
}
finally
{
conn.Close();
}
}
if (num == 0)
{
return false;
}
else
{
return true;
}
}
สมัครสมาชิก:
ส่งความคิดเห็น (Atom)
ไม่มีความคิดเห็น:
แสดงความคิดเห็น