class Execute
{
private SqlConnection strConnection;
private SqlDataAdapter adapter;
private DataSet ds;
public Execute(string strConn)
{
this.strConnection = new SqlConnection(strConn);
}
public string strSQL { get; set; }
public string strType { get; set; }
public DataSet selectStoredProcedure(string code,string year)
{
//insertLogData("procedure");
ds = new DataSet();
adapter = new SqlDataAdapter();
this.strConnection.Open();
SqlCommand cmd = new SqlCommand(this.strSQL, this.strConnection);
cmd.CommandType = CommandType.StoredProcedure; // set it to stored proc
cmd.Parameters.Add("@code", SqlDbType.VarChar).Value = code;
cmd.Parameters.Add("@target_year", SqlDbType.VarChar).Value = year;
adapter = new SqlDataAdapter(cmd);
adapter.Fill(ds);
this.adapter.Dispose();
this.strConnection.Close();
return ds;
}
public DataSet selectCommand()
{
ds = new DataSet();
adapter = new SqlDataAdapter();
this.strConnection.Open();
adapter.SelectCommand = new SqlCommand(this.strSQL, this.strConnection);
adapter.Fill(ds);
this.adapter.Dispose();
this.strConnection.Close();
return ds;
}
public int insertCommand()
{
//insertLogData("insert");
adapter = new SqlDataAdapter();
this.strConnection.Open();
adapter.InsertCommand = new SqlCommand(this.strSQL, this.strConnection);
int i = adapter.InsertCommand.ExecuteNonQuery();
this.adapter.Dispose();
this.strConnection.Close();
return i;
}
public int updateCommand()
{
//insertLogData("update");
adapter = new SqlDataAdapter();
this.strConnection.Open();
adapter.UpdateCommand = strConnection.CreateCommand();
adapter.UpdateCommand.CommandText = this.strSQL;
int i = adapter.UpdateCommand.ExecuteNonQuery();
this.adapter.Dispose();
this.strConnection.Close();
return i;
}
public int deleteCommand()
{
//insertLogData("delete");
adapter = new SqlDataAdapter();
this.strConnection.Open();
adapter.DeleteCommand = strConnection.CreateCommand();
adapter.DeleteCommand.CommandText = this.strSQL;
int i = adapter.DeleteCommand.ExecuteNonQuery();
this.adapter.Dispose();
this.strConnection.Close();
return i;
}
}
Method เอาไว้เก็บ Log ไฟล์
public void insertLogData(string tbstatus)
{
string sql = "insert into tbllogdata (username,createdate,sqltext,tbstatus) values ";
sql += "('xxx',getdate(),'" + this.strSQL + "','" + tbstatus + "')";
adapter = new SqlDataAdapter();
this.strConnection.Open();
adapter.InsertCommand = new SqlCommand(sql, this.strConnection);
adapter.InsertCommand.ExecuteNonQuery();
this.adapter.Dispose();
this.strConnection.Close();
}