日期:2013-02-20  浏览次数:20458 次

using System;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;

namespace DataLibrary
{
/// <summary>
/// 数据连接设置
/// </summary>
public class SqlConnect
{
static string sqlconnstr;

/// <summary>
/// 连接字符串
/// </summary>
public string ConnString
{
set
{
sqlconnstr=value;
}
get
{
return sqlconnstr;
}
}

/// <summary>
/// 取得连接
/// </summary>
/// <returns></returns>
public SqlConnection GetSqlConnection()
{
SqlConnection _connection=null;
if(sqlconnstr==null || sqlconnstr=="")
{
string SystemDir=System.Environment.SystemDirectory;
DisposalConductService DisposalConductService1= new DisposalConductService(SystemDir+"\\CBERP_Dis.DLL") ;
sqlconnstr = "server="+DisposalConductService1.GetValue("ServerName","(local)")
+";user id="+DisposalConductService1.GetValue("SqlAccount","sa")
+";password="+DisposalConductService1.GetValue("PassWord","jiayu520")
+";Database="+DisposalConductService1.GetValue("Database","CBERP");
}
try
{
_connection = new SqlConnection(sqlconnstr);
_connection.Open();
}
catch(SqlException SE)
{
if(SE.Number==17 || SE.Number==18456)
{
if( MessageBox.Show("数据库访问参数设置不正确,是否对需要对其进行设置?","提示",MessageBoxButtons.YesNo,MessageBoxIcon.Question)==DialogResult.Yes)
{
sqlconnstr="";
DisposalConduct config = new DisposalConduct();
config.ShowDialog();
_connection=GetSqlConnection();
}
else
{
MessageBox.Show("建立数据库连接失败,程序不能继续运行!","错误",MessageBoxButtons.OK,MessageBoxIcon.Stop);
Application.ExitThread();
Application.Exit();
}
}
else
{
MessageBox.Show(SE.Message,"提示信息",MessageBoxButtons.OK,MessageBoxIcon.Information);
_connection.Close();
}
}
return _connection;
}
}

/// <summary>
/// 数据配置
/// </summary>
public class DataCatena : IDisposable
{
private SqlConnection _connection;
/// <summary>
/// 数据配置
/// </summary>
public DataCatena()
{
SqlConnect sqlconnect = new SqlConnect();
_connection = sqlconnect.GetSqlConnection();
_connection.Close();
}

/// <summary>
/// 数据配置
/// </summary>
/// <param name="connStr">连接字符串</param>
public DataCatena(String connStr)
{
_connection = new SqlConnection(connStr);
}

/// <summary>
/// 取得DataView
/// </summary>
/// <param name="Sqlstr">连接字符串</param>
/// <returns>数据视图</returns>
public DataView GetDataView(String Sqlstr)
{
DataView dv=null;
SqlDataAdapter myCommand = new SqlDataAdapter(Sqlstr, _connection);
DataSet ds = new DataSet();
try
{
myCommand.Fill(ds,"table");
dv=ds.Tables["table"].DefaultView;
}
catch(SqlException exc)
{
DebugBox db = new DebugBox(Sqlstr + "\r\n" + exc.Message);
db.Show();
}
return dv;
}

/// <summary>
/// 清理资源
/// </summary>
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(true);
}

/// <summary>
/// 清理所有正在使用的资源。
/// </summary><