以前做的一个项目,数据库从SQL2005换成MYSQL,但是运行报错
public static Rs_new GetRs_newById(int id)
{
string sql = "SELECT * FROM rs_news WHERE Id = @Id";
try
{
MySqlDataReader reader = DBHelper.GetReader(sql, new MySqlParameter("@Id", id));
if (reader.Read())
{
Rs_new rs_new = new Rs_new();
rs_new.Id = (int)reader["id"];
rs_new.Ntitle = (string)reader["ntitle"];
rs_new.Ncontent = (string)reader["ncontent"]; reader.Close(); return rs_new;
}
else
{
reader.Close();
return null;
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
}
reader.Reader()进不去,DBHelper.GetReader的方法如下
public static MySqlDataReader GetReader(string sql, params MySqlParameter[] sqlParameter)
{
MySqlDataReader dr;
MySqlConnection conn = new MySqlConnection(ConnStr);
MySqlCommand comm = new MySqlCommand(sql, conn);
comm.Parameters.AddRange(sqlParameter);
conn.Open();
dr = comm.ExecuteReader(CommandBehavior.CloseConnection);
return dr;
}
到底哪里出错了,我纠结啊,高手帮忙下吧
public static Rs_new GetRs_newById(int id)
{
string sql = "SELECT * FROM rs_news WHERE Id = @Id";
try
{
MySqlDataReader reader = DBHelper.GetReader(sql, new MySqlParameter("@Id", id));
if (reader.Read())
{
Rs_new rs_new = new Rs_new();
rs_new.Id = (int)reader["id"];
rs_new.Ntitle = (string)reader["ntitle"];
rs_new.Ncontent = (string)reader["ncontent"]; reader.Close(); return rs_new;
}
else
{
reader.Close();
return null;
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
throw e;
}
}
reader.Reader()进不去,DBHelper.GetReader的方法如下
public static MySqlDataReader GetReader(string sql, params MySqlParameter[] sqlParameter)
{
MySqlDataReader dr;
MySqlConnection conn = new MySqlConnection(ConnStr);
MySqlCommand comm = new MySqlCommand(sql, conn);
comm.Parameters.AddRange(sqlParameter);
conn.Open();
dr = comm.ExecuteReader(CommandBehavior.CloseConnection);
return dr;
}
到底哪里出错了,我纠结啊,高手帮忙下吧
修改成while试一下