您的位置:首页 > 数据库

c# 连接访问数据库

2017-06-22 13:09 197 查看
先构建实体类

public class UserInfo
{
public int username { get; set; }
public string password { get; set; }
}


拼接sql语句

protected UserInfo user = new UserInfo();

public oblog_adminDA(UserInfo user)
{
this.user = user;

}

public bool Insert()
{
try
{
#region 生成插入的sql语句
string sql = "INSERT INTO UserInfo ( ";
sql += "username,";
sql += "password";
sql += ") VALUES(";
sql += "@username,";
sql += "@password";
sql += ")";

#endregion

#region 生成用于插入的sqlparameters,用与传递各参数

System.Data.SqlClient.SqlParameter[] myParameter = new System.Data.SqlClient.SqlParameter[2];

myParameter[0] = new System.Data.SqlClient.SqlParameter();
myParameter[0].ParameterName = "@username";
if (this.user.username != null && this.user.username.Trim().Length > 0)
{
myParameter[0].Value = this.user.username;
}
else
{
myParameter[0].Value = System.DBNull.Value;
}
myParameter[1] = new System.Data.SqlClient.SqlParameter();
myParameter[1].ParameterName = "@password";
if (this.user.password != null && this.user.password.Trim().Length > 0)
{
myParameter[1].Value = this.user.password;
}
else
{
myParameter[1].Value = System.DBNull.Value;
}

#endregion

this.op.Execute(sql, myParameter);
return true;
}
catch (Exception ex)
{
throw ex;
}
}


执行sql

public int Execute(string CmdText, params SqlParameter[] parameters)
{
try
{
SqlCommand objComm = new SqlCommand();
//objConn为连接字符串
objComm.Connection = objConn;
objComm.CommandTimeout = 0;
objComm.CommandText = CmdText;
objComm.CommandType = CommandType.Text;
foreach (SqlParameter prm in parameters)
{
objComm.Parameters.Add(prm);
}
if (objConn.State != ConnectionState.Open)
{ objConn.Open(); }
return objComm.ExecuteNonQuery();
}
catch (Exception objErr)
{
return -1;
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: