Heim > Datenbank > MySQL-Tutorial > 使用MyDBase连接SQL Server

使用MyDBase连接SQL Server

WBOY
Freigeben: 2016-06-07 14:53:24
Original
1378 Leute haben es durchsucht

使用ADO.NET自定义类MyDBase连接SQL Server数据库 using System; using System.Data; using System.Data.SqlClient; public class MyDBase { bool ECode=false; string ES; SqlConnection cn=new System.Data.SqlClient.SqlConnection(); DataSet Rs; publ

  使用ADO.NET自定义类MyDBase连接SQL Server数据库

  using System;

  using System.Data;

  using System.Data.SqlClient;

  public class MyDBase

  {

  bool ECode=false;

  string ES;

  SqlConnection cn=new System.Data.SqlClient.SqlConnection();

  DataSet Rs;

  public MyDBase(string MyDBServerName,string MyDataBaseName)

  {

  ECode = false;

  cn.ConnectionString="workstation id="+MyDBServerName+";packet size=4096;integrated security=SSPI;data source="+MyDBServerName+";persist security info=False;initial catalog="+MyDataBaseName;

  try

  {

  cn.Open();

  }

  catch (Exception e)

  {

  ES = e.Message;

  ECode = true;

  }

  }

  public MyDBase(string MyDBServerName, string MyDataBaseName, string sUerName, string sPasswd)

  {

  ECode = false;

  string sConn = "workstation id=" + MyDBServerName + ";packet size=4096;user id=" + sUerName + ";pwd=" + sPasswd + ";data source=" + MyDBServerName + ";persist security info=False;initial catalog=" + MyDataBaseName;

  cn.ConnectionString = sConn;

  try

  {

  cn.Open();

  }

  catch (Exception e)

  {

  ES = e.Message;

  ECode = true;

  }

  }

  public DataSet GetRecordset(string Sqls)

  {

  SqlCommand sqlCmd= new SqlCommand();

  sqlCmd.Connection = cn;

  sqlCmd.CommandText = Sqls;

  try

  {

  SqlDataAdapter adp = new SqlDataAdapter(sqlCmd);

  Rs = new DataSet();

  adp.Fill(Rs);

  }

  catch (Exception e)

  {

  ES = e.Message;

  ECode = true;

  return null;

  }

  return (Rs);

  }

  public int ExecuteSQLScalar(string Sqls)

  {

  string s;

  SqlCommand sqlCmd= new SqlCommand();

  sqlCmd.Connection = cn;

  sqlCmd.CommandText = Sqls;

  sqlCmd.CommandType = CommandType.Text;

  try

  {

  s = sqlCmd.ExecuteScalar().ToString();

  }

  catch (Exception e)

  {

  ES = e.Message;

  ECode = true;

  return -1;

  }

  return(int.Parse(s));

  }

  public string ExecuteSQLScalarTOstring(string Sqls)

  {

  string s;

  SqlCommand sqlCmd = new SqlCommand();

  sqlCmd.Connection = cn;

  sqlCmd.CommandText = Sqls;

  sqlCmd.CommandType = CommandType.Text;

  try

  {

  s = sqlCmd.ExecuteScalar().ToString();

  }

  catch (Exception e)

  {

  ES = e.Message;

  ECode = true;

  return "-1";

  }

  return s;

  }

  public string ExecuteSQLWithTrans(string Sqls)

  {

  string s;

  SqlTransaction myTrans;

  myTrans=cn.BeginTransaction();

  SqlCommand sqlCmd= new SqlCommand();

  sqlCmd.Connection = cn;

  sqlCmd.CommandText = Sqls;

  sqlCmd.CommandType = CommandType.Text;

  sqlCmd.Transaction =myTrans;

  sqlCmd.ExecuteNonQuery();

  //Sqls="SELECT @@IDENTITY AS ID";

  sqlCmd.CommandText =Sqls;

  try

  {

  s = sqlCmd.ExecuteScalar().ToString();

  }

  catch (Exception e)

  {

  ES = e.Message;

  ECode = true;

  myTrans.Commit();

  return "";

  }

  myTrans.Commit();

  return(s);

  }

  public void ExecuteSQL(string Sqls)

  {

  SqlCommand sqlCmd= new SqlCommand();

  sqlCmd.Connection = cn;

  sqlCmd.CommandText = Sqls;

  sqlCmd.CommandType = CommandType.Text;

  try

  {

  sqlCmd.ExecuteNonQuery();

  }

  catch (Exception e)

  {

  ES = e.Message;

  ECode = true;

  }

  }

  public SqlDataReader DBDataReader(string Sqls)

  {

  SqlCommand sqlCmd= new SqlCommand();

  sqlCmd.Connection = cn;

  sqlCmd.CommandText = Sqls;

  sqlCmd.CommandType = CommandType.Text;

  try

  {

  return sqlCmd.ExecuteReader(CommandBehavior.CloseConnection);

  }

  catch (Exception e)

  {

  ES = e.Message;

  ECode = true;

  return null;

  }

  }

  public void DBClose()

  {

  try

  {

  cn.Close();

  }

  catch (Exception e)

  {

  ES = e.Message;

  ECode = true;

  }

  }

  public bool ErrorCode()

  {

  return ECode;

  }

  public string ErrMessage()

  {

  return ES;

  }

  ~MyDBase()

  {

  //if (cn.State==ConnectionState.Open ) cn.Close();

Verwandte Etiketten:
Quelle:php.cn
Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Beliebte Tutorials
Mehr>
Neueste Downloads
Mehr>
Web-Effekte
Quellcode der Website
Website-Materialien
Frontend-Vorlage