using System;
using System.Data;
using System.Data.SqlClient;namespace localhost
{
/// <summary>
/// AccessDB 的摘要说明。
/// 数据库通用模块
/// 数据库通用模块
///陈根发
///2005-1-4
/// </summary>
public class AccessDB
{
private string Connectstr="server=(local);database=NanJingHotLine;uid=sa;pwd=sa";
private SqlDataAdapter da;
private SqlConnection Dataconnection;
private DataSet ds;
public AccessDB()
{
//
// TODO: 在此处添加构造函数逻辑
//
}
//打开连接
// public string Get_cnnstr
// {
// get
// {
// return Connectstr;
//
// }
// set
// {
// if(Connectstr!=value)
// {
// Connectstr=value;
// }
// }
// } private void OpenConn()
{
log log=new log (); try
{
Dataconnection =new SqlConnection();
if (Dataconnection.State ==ConnectionState.Closed)
{
Dataconnection.ConnectionString = Connectstr;
Dataconnection.Open();
}
}
catch(System.Exception e)
{
log.Save(e, "");
}
}
//==================================================
//关闭连接
//===================================================
private void CloseConn()
{
log log=new log ();
try
{
if( Dataconnection.State == ConnectionState.Open)
{
Dataconnection.Close();
}
}
catch(System.Exception e)
{
log.Save(e, "");
} }
// 事务处理一
private void OpenTransConn()
{
log log=new log ();
SqlConnection tmpConn;
try
{
tmpConn =new SqlConnection();
tmpConn.ConnectionString = Connectstr;
tmpConn.Open();
}
catch(System.Exception e)
{
log.Save(e, "");
}
}
//事务处理二
public void CloseTransConn(SqlConnection conn)
{
log log=new log ();
try
{
if(conn.State == ConnectionState.Open)
{
conn.Close();
}
}
catch(System.Exception e)
{
log.Save(e, "");
} }
//操作是否成功
public Boolean UpdateDataBase(String sqlstr )
{
log log=new log ();
try
{
OpenConn();
SqlCommand cmdtables=new SqlCommand (sqlstr,Dataconnection);
cmdtables.CommandType = CommandType.Text;
cmdtables.ExecuteNonQuery();
cmdtables = null;
CloseConn();
}
catch(System.Exception e)
{
log.Save(e, "");
return false;
}
return true; }
// '************************************
//'定义一个用于返回数据集的公共查询函数
//'***********************************
public DataSet GetDataFromDB( String sqlstr )
{
log log=new log ();
try
{
OpenConn();
da = new SqlDataAdapter(sqlstr, Dataconnection);
ds = new DataSet();
ds.Clear();
da.Fill(ds);
da = null;
CloseConn();
}
catch(System.Exception e)
{
log.Save(e, "");
}
finally
{
CloseConn();
}
if(ds.Tables.Count>0 || ds.Tables[0].Rows .Count >=0 )
{
return ds;
}
else
{
return null;
}
}
}}
using System.Data;
using System.Data.SqlClient;namespace localhost
{
/// <summary>
/// AccessDB 的摘要说明。
/// 数据库通用模块
/// 数据库通用模块
///陈根发
///2005-1-4
/// </summary>
public class AccessDB
{
private string Connectstr="server=(local);database=NanJingHotLine;uid=sa;pwd=sa";
private SqlDataAdapter da;
private SqlConnection Dataconnection;
private DataSet ds;
public AccessDB()
{
//
// TODO: 在此处添加构造函数逻辑
//
}
//打开连接
// public string Get_cnnstr
// {
// get
// {
// return Connectstr;
//
// }
// set
// {
// if(Connectstr!=value)
// {
// Connectstr=value;
// }
// }
// } private void OpenConn()
{
log log=new log (); try
{
Dataconnection =new SqlConnection();
if (Dataconnection.State ==ConnectionState.Closed)
{
Dataconnection.ConnectionString = Connectstr;
Dataconnection.Open();
}
}
catch(System.Exception e)
{
log.Save(e, "");
}
}
//==================================================
//关闭连接
//===================================================
private void CloseConn()
{
log log=new log ();
try
{
if( Dataconnection.State == ConnectionState.Open)
{
Dataconnection.Close();
}
}
catch(System.Exception e)
{
log.Save(e, "");
} }
// 事务处理一
private void OpenTransConn()
{
log log=new log ();
SqlConnection tmpConn;
try
{
tmpConn =new SqlConnection();
tmpConn.ConnectionString = Connectstr;
tmpConn.Open();
}
catch(System.Exception e)
{
log.Save(e, "");
}
}
//事务处理二
public void CloseTransConn(SqlConnection conn)
{
log log=new log ();
try
{
if(conn.State == ConnectionState.Open)
{
conn.Close();
}
}
catch(System.Exception e)
{
log.Save(e, "");
} }
//操作是否成功
public Boolean UpdateDataBase(String sqlstr )
{
log log=new log ();
try
{
OpenConn();
SqlCommand cmdtables=new SqlCommand (sqlstr,Dataconnection);
cmdtables.CommandType = CommandType.Text;
cmdtables.ExecuteNonQuery();
cmdtables = null;
CloseConn();
}
catch(System.Exception e)
{
log.Save(e, "");
return false;
}
return true; }
// '************************************
//'定义一个用于返回数据集的公共查询函数
//'***********************************
public DataSet GetDataFromDB( String sqlstr )
{
log log=new log ();
try
{
OpenConn();
da = new SqlDataAdapter(sqlstr, Dataconnection);
ds = new DataSet();
ds.Clear();
da.Fill(ds);
da = null;
CloseConn();
}
catch(System.Exception e)
{
log.Save(e, "");
}
finally
{
CloseConn();
}
if(ds.Tables.Count>0 || ds.Tables[0].Rows .Count >=0 )
{
return ds;
}
else
{
return null;
}
}
}}
解决方案 »
- 数据保存后,如何刷新本窗口呢?
- 对于不返回任何键列信息的 SelectCommand,不支持 UpdateCommand 的动态 SQL 生成
- .NET和c#之间有什么关系?
- C# 时间格式化 05-jan-2008
- C#怎么模拟多个用户登录一个网站
- HTML的Select的问题
- C# 窗体内的所有双击事件
- 候捷翻译了一本C# Primer谁知道什么时候上市?
- 关于一个 udp 多播的问题。
- 如何使自定义控件的事件触发自定义控件所在的窗口中的事件!!!
- 高分求,可以加分,flashget等下载软件,托拽焦点内文字或者下载地址到浮动窗口用c#如何实现
- 大家帮我看看,为什么我刚装的.net 用c#建立web项目的时候 项目名那里是灰色的!
然后dr["Field1"] = XXX;
……
然后dataset.AddRow(dr);操作时,你可以DataRow dr = dataset.table["XXX"].Rows.find(yourrow);
然后dr[]操作这个row
然后update这个dataset