วันพุธที่ 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;
            }
        }

ไม่มีความคิดเห็น:

แสดงความคิดเห็น