- 浏览: 774908 次
- 性别:
- 来自: 杭州
-
文章分类
最新评论
-
liuweihug：
.net的请参考：Jquery+asp.net 后台数据传到前 ...
jquery ajax POST 例子详解 -
topbox163：
LZ，有LINUX 64位的WEBLOGIC没？
WebLogic11g|Oracle WebLogic Server 11gR1|下载
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using System.Collections;
using System.Data.SqlClient;
using System.Data.Common;
using System.Configuration;
namespace Common.Dba
{
public class DbSqlServerData:DbAccess
{
new SqlCommand cmd = null;
public DbSqlServerData()
{
//
// TODO: 在此处添加构造函数逻辑
//
conn = new SqlConnection();
conn.ConnectionString = ConnectionString;//Convert.ToString(ConfigurationManager.AppSettings["datasource"]); //Convert.ToString(System.Configuration.ConfigurationSettings.AppSettings["datasource"]);
//conn.ConnectionString = "initial catalog=idyan_new;data source=.;user id=bt;password=btbtbtbt;Connect Timeout=5000";
cmd = new SqlCommand();
cmd.Connection = conn as SqlConnection;
cmd.CommandTimeout = 0;
}
public DbSqlServerData(string constr)
{
//
// TODO: 在此处添加构造函数逻辑
//
conn = new SqlConnection();
//conn.ConnectionString = "initial catalog=pubs;data source=.;user id=sa;password=";
//conn.ConnectionString = Convert.ToString(System.Configuration.ConfigurationSettings.AppSettings["datasource"]);
conn.ConnectionString = constr;// "initial catalog=idyan_new;data source=.;user id=bt;password=btbtbtbt";
cmd = new SqlCommand();
cmd.Connection = conn as SqlConnection;
cmd.CommandTimeout = 0;
}
/// <summary>
/// 获取数据根据Sql语句
/// </summary>
/// <param name="Sql"></param>
/// <returns></returns>
public override DataTable GetTable(string sql)
{
DataSet ds = new DataSet();
try
{
cmd.CommandText = sql;
cmd.CommandType = CommandType.Text;
SqlDataAdapter da = new SqlDataAdapter();
da.SelectCommand = cmd;
da.Fill(ds);
}
catch (Exception ex)
{
return null;
}
return ds.Tables[0] ?? new DataTable();
}
/// <summary>
/// 获取数据根据sql语句
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public override DataSet GetDataSet(string sql)
{
DataSet ds = new DataSet();
try
{
cmd.CommandText = sql;
cmd.CommandType = CommandType.Text;
SqlDataAdapter da = new SqlDataAdapter();
da.SelectCommand = cmd;
da.Fill(ds);
}
catch (Exception ex)
{
return null;
}
return ds;
}
/// <summary>
/// 获取数据根据sql语句
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public override DataSet GetDataSet(string sql, DbParameter[] pas)
{
DataSet ds = new DataSet();
try
{
cmd.Parameters.Clear();
cmd.CommandText = sql;
foreach (SqlParameter pa in pas)
{
cmd.Parameters.Add(pa);
}
cmd.CommandType = CommandType.Text;
SqlDataAdapter da = new SqlDataAdapter();
da.SelectCommand = cmd;
da.Fill(ds);
}
catch (Exception ex)
{
return null;
}
return ds;
}
/// <summary>
/// 获取数据根据sql语句 带参数 的
/// </summary>
/// <param name="sql"></param>
/// <param name="pas"></param>
/// <returns></returns>
public override DataTable GetTable(string sql, params DbParameter[] pas)
{
DataSet ds = new DataSet();
try
{
cmd.CommandText = sql;
cmd.CommandType = CommandType.Text;
SqlDataAdapter da = new SqlDataAdapter();
da.SelectCommand = cmd;
cmd.Parameters.Clear();
foreach (SqlParameter temppa in pas)
{
cmd.Parameters.Add(temppa);
}
da.Fill(ds);
}
catch (Exception ex)
{
return null;
}
return ds.Tables[0] ?? new DataTable();
}
/// <summary>
/// 获取数据根据sql语句 带参数 的
/// </summary>
/// <param name="sql"></param>
/// <param name="pas"></param>
/// <returns></returns>
public override DataTable GetProcTable(string procname, params DbParameter[] pas)
{
DataSet ds = new DataSet();
try
{
cmd.CommandType = CommandType.StoredProcedure;
cmd.CommandText = procname;
//cmd.CommandText = sql;
SqlDataAdapter da = new SqlDataAdapter();
da.SelectCommand = cmd;
cmd.Parameters.Clear();
foreach (SqlParameter temppa in pas)
{
cmd.Parameters.Add(temppa);
}
da.Fill(ds);
}
catch (Exception ex)
{
return null;
}
return ds.Tables[0] ?? new DataTable();
}
/// <summary>
/// 获取数据根据sql语句 带参数 的
/// </summary>
/// <param name="sql"></param>
/// <param name="pas"></param>
/// <returns></returns>
public override DataTable GetProcCursorTable(string procname, params DbParameter[] pas)
{
DataSet ds = new DataSet();
try
{
cmd.CommandType = CommandType.StoredProcedure;
cmd.CommandText = procname;
//cmd.CommandText = sql;
SqlDataAdapter da = new SqlDataAdapter();
da.SelectCommand = cmd;
cmd.Parameters.Clear();
foreach (SqlParameter temppa in pas)
{
cmd.Parameters.Add(temppa);
}
da.Fill(ds);
}
catch (Exception ex)
{
return null;
}
return ds.Tables[1] ?? new DataTable();
}
/// <summary>
/// 获取数据根据sql语句 带参数 的
/// </summary>
/// <param name="sql"></param>
/// <param name="pas"></param>
/// <returns></returns>
public override int GetProcState(string procname, params DbParameter[] pas)
{
int state = 0;
try
{
OpenConn();
cmd.CommandType = CommandType.StoredProcedure;
cmd.CommandText = procname;
cmd.Parameters.Clear();
foreach (SqlParameter temppa in pas)
{
cmd.Parameters.Add(temppa);
}
cmd.ExecuteNonQuery();
CloseConn();
state = Convert.ToInt32(pas[pas.Length - 1].Value);
}
catch
{
return 0;
}
return state;
}
/// <summary>
/// 获取数据根据sql语句 带参数 的
/// </summary>
/// <param name="sql"></param>
/// <param name="pas"></param>
/// <returns></returns>
public override int GetProcStateNo(string procname, params DbParameter[] pas)
{
int state = 0;
try
{
OpenConn();
cmd.CommandType = CommandType.StoredProcedure;
cmd.CommandText = procname;
cmd.Parameters.Clear();
foreach (SqlParameter temppa in pas)
{
cmd.Parameters.Add(temppa);
}
cmd.ExecuteNonQuery();
CloseConn();
state = 1;
// state = Convert.ToInt32(pas[pas.Length - 1].Value);
}
catch
{
return 0;
}
return state;
}
/// <summary>
/// 存储过程返回值的
/// </summary>
/// <param name="sql"></param>
/// <param name="pas"></param>
/// <returns></returns>
public override string GetProcStateReturnValue(string procname, params DbParameter[] pas)
{
string state = "";
try
{
OpenConn();
cmd.CommandType = CommandType.StoredProcedure;
cmd.CommandText = procname;
cmd.Parameters.Clear();
foreach (SqlParameter temppa in pas)
{
cmd.Parameters.Add(temppa);
}
cmd.Parameters.AddWithValue("@Return_Value", "").Direction = ParameterDirection.ReturnValue;
cmd.ExecuteNonQuery();
state = Convert.ToString(cmd.Parameters["@Return_Value"].Value);
state = state == null ? ("") : (state);
CloseConn();
// state = Convert.ToInt32(pas[pas.Length - 1].Value);
}
catch
{
return "";
}
return state;
}
/// <summary>
/// 根据sql语句返回跟新状态
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public override bool GetState(string sql)
{
bool succ = false;
try
{
cmd.CommandType = CommandType.Text;
cmd.CommandText = sql;
OpenConn();
succ = cmd.ExecuteNonQuery() > 0 ? (true) : (false);
CloseConn();
}
catch (Exception ex)
{
return false;
}
return succ;
}
/// <summary>
/// 根据sql语句返回跟新状态带参数的
/// </summary>
/// <param name="sql">sql语句</param>
/// <param name="pas">参数的集合</param>
/// <returns></returns>
public override bool GetState(string sql, params DbParameter[] pas)
{
bool succ = false;
try
{
cmd.CommandType = CommandType.Text;
cmd.CommandText = sql;
cmd.Parameters.Clear();
foreach (SqlParameter temppa in pas)
{
cmd.Parameters.Add(temppa);
}
OpenConn();
succ = cmd.ExecuteNonQuery() > 0 ? (true) : (false);
CloseConn();
}
catch
{
// this.ShowError(ex.Message);
//using (System.IO.StreamWriter sw = new System.IO.StreamWriter("D:\\error2008.txt"))
//{
// sw.Write(ex.Message);
// sw.Flush();
//}
return false;
}
return succ;
}
/// <summary>
/// 根据sql语句返回第一个单元格的数据
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public override string GetOne(string sql)
{
string res = "";
try
{
cmd.CommandType = CommandType.Text;
cmd.CommandText = sql;
OpenConn();
res = cmd.ExecuteScalar() == null ? ("") : (Convert.ToString(cmd.ExecuteScalar()));
CloseConn();
}
catch (Exception ex)
{
return null;
}
return res;
}
/// <summary>
/// 根据sql语句返回第一个单元格的数据带参数的
/// </summary>
/// <param name="sql"></param>
/// <param name="pas"></param>
/// <returns></returns>
public override string GetOne(string sql, params DbParameter[] pas)
{
string res = "";
try
{
cmd.CommandType = CommandType.Text;
cmd.CommandText = sql;
cmd.Parameters.Clear();
foreach (SqlParameter temppa in pas)
{
cmd.Parameters.Add(temppa);
}
OpenConn();
res = cmd.ExecuteScalar() == null ? ("") : (Convert.ToString(cmd.ExecuteScalar()));
CloseConn();
}
catch (Exception ex)
{
CloseConn();
return null;
}
return res;
}
/// <summary>
/// 返回数据的DataReader
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public override DbDataReader GetDataReader(string sql)
{
SqlDataReader dr = null;
try
{
cmd.CommandType = CommandType.Text;
conn.Open();
cmd.CommandText = sql;
dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
}
catch (Exception ex)
{
return null;
}
return dr;
}
/// <summary>
/// 返回数据的DataReader带参数的
/// </summary>
/// <param name="sql"></param>
/// <param name="pas"></param>
/// <returns></returns>
public override DbDataReader GetDataReader(string sql, params DbParameter[] pas)
{
SqlDataReader dr = null;
try
{
cmd.CommandType = CommandType.Text;
conn.Open();
cmd.Parameters.Clear();
foreach (SqlParameter temppa in pas)
{
cmd.Parameters.Add(temppa);
}
cmd.CommandText = sql;
dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
}
catch (Exception ex)
{
return null;
}
return dr;
}
/// <summary>
/// 事务处理函数
/// </summary>
/// <param name="al"></param>
/// <returns></returns>
public override bool GetTranState(ArrayList al)
{
cmd.CommandType = CommandType.Text;
OpenConn();
SqlTransaction tran = (conn as SqlConnection).BeginTransaction();
cmd.Transaction = tran;
try
{
for (int i = 0; i < al.Count; i++)
{
cmd.CommandText = Convert.ToString(al[i]);
cmd.ExecuteNonQuery();
}
tran.Commit();
CloseConn();
}
catch
{
tran.Rollback();
CloseConn();
return false;
}
return true;
}
/// <summary>
/// 分页函数
/// </summary>
/// <param name="pagesize"></param>
/// <param name="columns"></param>
/// <param name="tablename"></param>
/// <param name="pid"></param>
/// <param name="order"></param>
/// <param name="current"></param>
/// <returns></returns>
public override DataTable GetPageData(int current, int pagesize, string columns, string tablename, string pid, string where, string order)
{
current = current - 1 >= 0 ? (current - 1) : (0);
string sql = string.Format("select top {0} {1} from {2} where 1=1 and {3} not in(select top {4}{3} from {2} where 1=1{5} order by {6}){5} order by {6}", pagesize, columns, tablename, pid, current * pagesize, where, order);
return GetTable(sql);
}
/// <summary>
/// 分页存储过程的调用
/// </summary>
/// <param name="current"></param>
/// <param name="pagesize"></param>
/// <param name="columns"></param>
/// <param name="tablename"></param>
/// <param name="pid"></param>
/// <param name="where"></param>
/// <param name="order"></param>
/// <returns></returns>
public override DataTable GetProcPageData(int current, int pagesize, string columns, string tablename, string pid, string where, string order, string ordertype)
{
SqlParameter[] pas = { new SqlParameter("@PageIndex", current), new SqlParameter("@PageSize", pagesize), new SqlParameter("@Columns", columns), new SqlParameter("@Tablename", tablename), new SqlParameter("@Where", where), new SqlParameter("@Order", order), new SqlParameter("@OrderType", ordertype), new SqlParameter("@Pid", pid) };
return GetProcTable("Pages", pas);
//current = current - 1 >= 0 ? (current - 1) : (0);
//string sql = string.Format("select top {0} {1} from {2} where 1=1 and {3} not in(select top {4}{3} from {2} where 1=1{5} order by {6}){5} order by {6}", pagesize, columns, tablename, pid, current * pagesize, where, order);
//return GetTable(sql);
}
/// <summary>
/// 分页存储过程的调用
/// </summary>
/// <param name="current"></param>
/// <param name="pagesize"></param>
/// <param name="columns"></param>
/// <param name="tablename"></param>
/// <param name="pid"></param>
/// <param name="where"></param>
/// <param name="order"></param>
/// <returns></returns>
public override DataTable GetProcData(int current, int pagesize, string columns, string tablename, string pid, string where, string order, string resultCount, string distinct)
{
SqlParameter[] pas = { new SqlParameter("@TableNames", SqlDbType.NVarChar, 200), new SqlParameter("@PrimaryKey", SqlDbType.NVarChar, 100), new SqlParameter("@Order", SqlDbType.NVarChar, 200), new SqlParameter("@CurrentPage", SqlDbType.Int), new SqlParameter("@PageSize", SqlDbType.Int), new SqlParameter("@Fields", SqlDbType.NVarChar, 800), new SqlParameter("@Filter", SqlDbType.NVarChar, 1000), new SqlParameter("@ResultCount", SqlDbType.NVarChar, 12), new SqlParameter("@distinct", SqlDbType.NVarChar, 12) };
pas[0].Value = tablename;
pas[1].Value = pid;
pas[2].Value = order;
pas[3].Value = current;
pas[4].Value = pagesize;
pas[5].Value = columns;
pas[6].Value = where;
pas[7].Value = resultCount;
pas[8].Value = distinct;
return this.GetProcTable("Pages", pas);
}
/// <summary>
/// 分页存储过程的调用
/// </summary>
/// <param name="current"></param>
/// <param name="pagesize"></param>
/// <param name="columns"></param>
/// <param name="tablename"></param>
/// <param name="pid"></param>
/// <param name="where"></param>
/// <param name="order"></param>
/// <returns></returns>
public override DataTable GetProcAdminData(int current, int pagesize, string columns, string tablename, string pid, string where, string order, string resultCount, string distinct)
{
SqlParameter[] pas = { new SqlParameter("@TableNames", SqlDbType.NVarChar, 200), new SqlParameter("@PrimaryKey", SqlDbType.NVarChar, 100), new SqlParameter("@Order", SqlDbType.NVarChar, 200), new SqlParameter("@CurrentPage", SqlDbType.Int), new SqlParameter("@PageSize", SqlDbType.Int), new SqlParameter("@Fields", SqlDbType.NVarChar, 800), new SqlParameter("@Filter", SqlDbType.NVarChar, 200), new SqlParameter("@ResultCount", SqlDbType.NVarChar, 24), new SqlParameter("@Distinct", SqlDbType.NVarChar, 12) };
pas[0].Value = tablename;
pas[1].Value = pid;
pas[2].Value = order;
pas[3].Value = current;
pas[4].Value = pagesize;
pas[5].Value = columns;
pas[6].Value = where;
pas[7].Value = resultCount;
pas[8].Value = distinct;
return this.GetProcTable("Pages", pas);
}
public override DbParameter[] MakeParameters(params string[] str)
{
SqlParameter[] pas = new SqlParameter[str.Length/ 2];
for (int i = 0; i < str.Length / 2; i++)
{
pas[i] = new SqlParameter(string.Format("@{0}", str[2 * i]), str[2 * i + 1]);
}
return pas;
}
}
}
发表评论
-
小型ASP服务器|简洁asp服务器
2010-11-27 22:34 728小ASP Web2005服务器 一套强大简洁 的ASPWEB ... -
POP3(Post Office Protocol 3)
2010-11-28 16:29 660POP3(Post Office Protocol 3)即邮局 ... -
王德用有量
2010-11-29 21:13 723王德用有量 ＜原文＞ 王武恭公德用善抚士，状貌雄传动 ... -
2010年圣诞节祝福短信大全
2010-11-30 18:36 6262010年圣诞节祝福短信大全(2) 2010-11-29 1 ... -
恶心的腾讯把我的字变成表情了 如何去掉它
2010-12-02 09:32 652今天在打晕的时候竟然出了个破狗在晕头转向的 在表情里 把使用快 ... -
各类数据库分页共享
2010-12-02 11:13 592MSSQL： select * from ( select ... -
sqllite 管理工具和查询工具
2010-12-02 11:28 853sqllite 管理工具和查询工具 http://files. ... -
分居两地的爱恋才是真的
2010-12-02 13:18 584一定有许多人不同意，毕竟分隔两地，不能照顾依偎着对方，心里的失 ... -
CPI|什么是CPI指数
2010-12-12 12:03 1022什么是CPI指数？ ... -
固定层样式
2010-12-13 17:26 701固定层样式 作用：让层一直在右下角 position:fixe ... -
圣诞节由来|圣诞节
2010-12-19 11:09 663每年的12 ... -
圣诞节起源|圣诞节
2010-12-19 11:12 661圣诞节的由来 教会开始并无圣诞节，约在耶稣升天后百余年内 ... -
人不成熟特征
2010-11-20 09:30 748人成熟与不成熟跟年龄没有关系，人成熟不成熟，就是你能不能站在对 ... -
查看自己外网ip的网址
2010-11-20 10:33 1558查看自己的上网的外网ip http://www.goudian ... -
冬天祝福短信大全
2010-11-20 20:33 819冬天祝福短信大全（新）2009-11-18 11:13 雪 ... -
.net 获取目录uri |虚拟目录
2010-11-22 22:22 860Response.Write(Request.Url. ... -
新年祝福短信|2011
2010-11-23 16:01 685诚喜悦型新年祝福短信：1、新的1年开始，祝好事接2连3，心情4 ... -
新年祝福短信|幽默
2010-11-23 16:02 618幽默搞笑型新年祝福短 ... -
2011年新年英语祝福短信
2010-11-23 16:04 712最好的足球网址导航：265足球之家 最好的足球网址导航：265 ... -
新年祝福短信
2010-11-23 16:05 597新年祝福短信：新的一 ...
相关推荐
查看 SQL Server 数据库连接数的多种方法 SQL Server 数据库连接数是一个重要的性能指标，它可以帮助数据库管理员了解当前数据库的工作负载和性能。查看数据库连接数有多种方法，本文将介绍四种不同的方法来查看 ...
在 Java 应用程序中，需要使用 JDBC 驱动来连接 SQLServer 数据库。JDBC 驱动需要配置 SSH tunnelling，以便通过 SSH 服务器连接数据库。 4. 配置 Hibernate Hibernate 是一个流行的 ORM 框架，用于将 Java 对象...
C#SqlServer数据库链接帮助类
标题“sqlserver数据库连接类.rar”表明这是一个关于使用VC++编程语言通过ADO（ActiveX Data Objects）连接到SQL Server数据库的资源包。描述提到“VC++ 数据库连接ADO 可以编译使用”，这意味着提供的代码文件是...
总的来说，C#连接SQL Server数据库的过程包括：导入必要的命名空间，构建连接字符串，创建并打开连接，定义查询，执行查询并读取结果，最后关闭连接。通过这个过程，你可以从数据库获取数据并在应用程序中进行处理和...
酒店管理系统，连接SQLServer 数据库 C++/Qt酒店管理系统，连接SQLServer 数据库 C++/Qt酒店管理系统，连接SQLServer 数据库 C++/Qt酒店管理系统，连接SQLServer 数据库 C++/Qt酒店管理系统，连接SQLServer 数据库 ...
Navicat Premium 连接 SQL Server 数据库遇到问题及解决方法 Navicat Premium 是一个功能强大且功能丰富的数据库管理工具，支持多种数据库管理系统，包括 SQL Server、MySQL、Oracle 等。但是在使用 Navicat ...
用于描述与SQL SERVER连接时用到的一些常用函数，可实现大多数操作
自动化 wincc连接sql server数据库脚本，不需要wincc授权，直连sql server数据库。解决归档导出问题
以下将详细讲解如何使用C++通过ADO连接到SQL Server数据库，并基于提供的"ConnDatabase"源代码进行学习。 1. ADO简介：ADO是微软的组件对象模型（COM）接口，它提供了一种简单的方式来访问各种数据源，包括SQL ...
在“quartz实例sqlserver数据库连接”这个主题中，我们主要讨论如何配置Quartz与SQL Server数据库进行交互，以存储和管理调度信息。 首先，Quartz需要一个持久化存储来保存作业（Jobs）和触发器（Triggers）的信息...
在远程连接SQL Server数据库时，关键在于构建正确的连接字符串。例如，在上述代码中，连接字符串"server=.;database=" + textBox1.Text.Trim() + ";Integrated Security=SSPI;"指定了服务器（本机，即"."），数据库...
zktime5.0考勤机连接sqlserver数据库，创建及连接方法 1. 数据库管理系统（DBMS）：sqlserver是微软公司开发的一种关系数据库管理系统（RDBMS），用于存储、处理和保护数据。 2. 数据库创建：在sqlserver中，创建...
本文将详细阐述SQL Server数据库的连接步骤，以及与之相关的JDBC（Java Database Connectivity）设置。 1. **SQL Server数据库连接步骤**： - **安装SQL Server**：首先，你需要在计算机上安装SQL Server。这通常...
通过Oracle通用连接访问SQL Server数据库的方法为IT领域提供了一种跨数据库系统进行数据交互的有效途径。这种方法主要依赖于Oracle数据库的异构服务功能，允许用户从Oracle环境中直接查询或操作其他类型数据库（如...
SqlDbx.exe很可能是一个小巧且直观的SQL Server数据库管理工具，设计得像微软的Office应用一样易于使用，使得数据库操作对新手更为友好。 SqlDbx可能具有以下特性： 1. **连接功能**：能够快速连接到SQL Server实例...
"C#操作SQL Server数据库通用类" 本文档中提供了一个通用的C#类，用于访问SQL Server数据库。该类名为DataAccess，位于insurer命名空间中。该类提供了基本的数据库操作，包括打开和关闭数据库连接、执行存储过程、...
1.4 建立连接：使用DriverManager类连接到SQLServer数据库，并获取Connection对象。 1.5 建立载体：使用Connection对象创建Statement对象，以便执行SQL语句。 1.6 发出数据请求：使用Statement对象执行SQL语句，并...
本文将深入探讨SQL Server数据库连接池以及Java JDBC（Java Database Connectivity）如何进行调用。 首先，我们来理解什么是数据库连接池。数据库连接池是一种在应用服务器启动时预先建立的数据库连接集合，这些...