lpf
/
CNCEC_SUBQHSE_WUHUAN
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
CNCEC_SUBQHSE_WUHUAN/SGGL/BLL/SQLHelper.cs

977 lines
35 KiB
C#
Raw Normal View History

20210430
2021-04-30 10:28:37 +08:00
using System;
using System.Data;
using System.Data.SqlClient;
using System.Collections;
namespace BLL
{
/// <summary>
/// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݷ<EFBFBD><DDB7>ʲ<EFBFBD><CAB2><EFBFBD><EFBFBD>Ļ<EFBFBD><C4BB>࣬<EFBFBD><E0A3AC>װ<EFBFBD><D7B0>һЩ<D2BB><D0A9><EFBFBD>ݿ<EFBFBD><DDBF><EFBFBD><EFBFBD>ʵı<CAB5><C4B1><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
///
public class SQLHelper
{
private static string connectionString = Funs.ConnString;
20220717 pagebase
2022-07-17 09:15:38 +08:00
private static SqlConnection Connection = new SqlConnection(connectionString);
20210430
2021-04-30 10:28:37 +08:00
20220717 pagebase
2022-07-17 09:15:38 +08:00
public static SqlConnection GetConn()
{
return Connection;
}
20210430
2021-04-30 10:28:37 +08:00
/// <summary>
///<2F><>RunProcedure<72><65><EFBFBD><EFBFBD> <20><><EFBFBD><EFBFBD> SqlCommand <20><><EFBFBD><EFBFBD>.
/// </summary>
/// <param name="storedProcName">Name of the stored procedure in the DB, eg. sp_DoTask</param>
/// <param name="parameters">Array of IDataParameter objects containing parameters to the stored proc</param>
/// <returns>Newly instantiated SqlCommand instance</returns>
private static SqlCommand BuildIntCommand(string storedProcName, IDataParameter[] parameters)
{
SqlCommand command = BuildQueryCommand(storedProcName, parameters);
command.Parameters.Add(new SqlParameter("ReturnValue",
SqlDbType.Int,
4, /* Size */
ParameterDirection.ReturnValue,
false, /* is nullable */
0, /* byte precision */
0, /* byte scale */
string.Empty,
DataRowVersion.Default,
null));
return command;
}
/// <summary>
/// <20><>BuildIntCommand<6E>б<EFBFBD><D0B1><EFBFBD><EFBFBD>õ<EFBFBD>˽<EFBFBD>к<EFBFBD><D0BA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڹ<EFBFBD><DAB9><EFBFBD> SqlCommand <20><><EFBFBD><EFBFBD>.
/// </summary>
/// <param name="storedProcName">Name of the stored procedure</param>
/// <param name="parameters">Array of IDataParameter objects</param>
/// <returns></returns>
private static SqlCommand BuildQueryCommand(string storedProcName, IDataParameter[] parameters)
{
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(storedProcName, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.StoredProcedure//ִ<>д洢<D0B4><E6B4A2><EFBFBD><EFBFBD>
};
foreach (SqlParameter parameter in parameters)
{
command.Parameters.Add(parameter);
}
return command;
}
finally
{
Connection.Close();
}
}
}
public static int RunProcedure(string storedProcName, IDataParameter[] parameters, out int rowsAffected)
{
int result;
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = BuildIntCommand(storedProcName, parameters);
command.CommandTimeout = 0;
rowsAffected = command.ExecuteNonQuery();//ִ<><D6B4><EFBFBD><EFBFBD><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD>̺󷵻صĽ<D8B5><C4BD><EFBFBD>
result = (int)command.Parameters["ReturnValue"].Value;
return result;
}
finally
{
Connection.Close();
}
}
}
/// <summary>
/// ͨ<><CDA8><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD>̻<EFBFBD><CCBB><EFBFBD><EFBFBD><EFBFBD>ID<49><44><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD>з<EFBFBD><D0B7><EFBFBD>ֵ<EFBFBD>и<EFBFBD>output<75><74><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
/// <param name="storedProcName"><3E>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
/// <returns></returns>
public static string RunProcNewId(string storedProcName)
{
string str = "";
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(storedProcName, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.StoredProcedure
};
command.Parameters.Add(new SqlParameter("@returnVal", SqlDbType.VarChar, 50));
command.Parameters["@returnVal"].Direction = ParameterDirection.Output;
command.ExecuteNonQuery();
str = command.Parameters["@returnVal"].Value.ToString();
}
finally
{
Connection.Close();
}
return str;
}
}
/// <summary>
/// ͨ<><CDA8><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ͱ<EFBFBD><CDB1><EFBFBD><EFBFBD>Լ<EFBFBD><D4BC><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ID<49><44><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD>з<EFBFBD><D0B7><EFBFBD>ֵ<EFBFBD>и<EFBFBD>output<75><74><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
/// <param name="storedProcName"><3E>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
/// <param name="tableName"><3E><><EFBFBD><EFBFBD></param>
/// <param name="columnName"><3E><><EFBFBD><EFBFBD></param>
/// <returns></returns>
public static string RunProcNewId(string storedProcName, string tableName, string columnName)
{
string str = "";
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(storedProcName, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.StoredProcedure
};
SqlParameter[] values = new SqlParameter[]
{
new SqlParameter("@tableName", tableName),
new SqlParameter("@columnName", columnName),
new SqlParameter("@returnVal", SqlDbType.VarChar, 10)
};
command.Parameters.AddRange(values);
command.Parameters["@returnVal"].Direction = ParameterDirection.Output;
command.ExecuteNonQuery();
str = command.Parameters["@returnVal"].Value.ToString();
}
finally
{
Connection.Close();
}
return str;
}
}
/// <summary>
/// ͨ<><CDA8><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ͱ<EFBFBD><CDB1><EFBFBD><EFBFBD>Լ<EFBFBD><D4BC><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ID<49><44><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD>з<EFBFBD><D0B7><EFBFBD>ֵ<EFBFBD>и<EFBFBD>output<75><74><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
/// <param name="storedProcName"><3E>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
/// <param name="tableName"><3E><><EFBFBD><EFBFBD></param>
/// <param name="columnName"><3E><><EFBFBD><EFBFBD></param>
/// <param name="perfix">ǰ׺</param>
/// <returns><3E><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ID</returns>
public static string RunProcNewId(string storedProcName, string tableName, string columnName, string projectId, string prefix)
{
string str = "";
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(storedProcName, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.StoredProcedure
};
SqlParameter[] values = new SqlParameter[]
{
new SqlParameter("@tableName", tableName),
new SqlParameter("@columnName", columnName),
new SqlParameter("@projectId", projectId),
new SqlParameter("@prefix", prefix),
new SqlParameter("@returnVal", SqlDbType.VarChar, 30)
};
command.Parameters.AddRange(values);
command.Parameters["@returnVal"].Direction = ParameterDirection.Output;
command.ExecuteNonQuery();
str = command.Parameters["@returnVal"].Value.ToString();
}
finally
{
Connection.Close();
}
return str;
}
}
/// <summary>
/// ͨ<><CDA8><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ͱ<EFBFBD><CDB1><EFBFBD><EFBFBD>Լ<EFBFBD><D4BC><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ID<49><44><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD>з<EFBFBD><D0B7><EFBFBD>ֵ<EFBFBD>и<EFBFBD>output<75><74><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
/// <param name="storedProcName"><3E>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
/// <param name="tableName"><3E><><EFBFBD><EFBFBD></param>
/// <param name="columnName"><3E><><EFBFBD><EFBFBD></param>
/// <param name="perfix">ǰ׺</param>
/// <returns><3E><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ID</returns>
public static string RunProcNewId(string storedProcName, string tableName, string columnName, string prefix)
{
string str = "";
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(storedProcName, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.StoredProcedure
};
SqlParameter[] values = new SqlParameter[]
{
new SqlParameter("@tableName", tableName),
new SqlParameter("@columnName", columnName),
new SqlParameter("@prefix", prefix),
new SqlParameter("@returnVal", SqlDbType.VarChar, 30)
};
command.Parameters.AddRange(values);
command.Parameters["@returnVal"].Direction = ParameterDirection.Output;
command.ExecuteNonQuery();
str = command.Parameters["@returnVal"].Value.ToString();
}
finally
{
Connection.Close();
}
return str;
}
}
/// <summary>
/// ͨ<><CDA8><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD>̻<EFBFBD><CCBB><EFBFBD>DataTable
/// </summary>
/// <param name="storedProcName"><3E>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
/// <returns></returns>
public static DataTable GetDataTableRunProc(string storedProcName, params SqlParameter[] parameters)
{
DataTable dataTable = new DataTable();
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(storedProcName, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.StoredProcedure
};
if (parameters != null)
{
command.Parameters.AddRange(parameters);
}
SqlDataAdapter adapter = new SqlDataAdapter(command);
adapter.Fill(dataTable);
}
finally
{
Connection.Close();
}
return dataTable;
}
}
/// <summary>
/// ͨ<><CDA8><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD>̻<EFBFBD><CCBB><EFBFBD>DataTable
/// </summary>
/// <param name="storedProcName"><3E>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
/// <returns></returns>
public static DataTable GetDataTableRunText(string strSql, params SqlParameter[] parameters)
{
DataTable dataTable = new DataTable();
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(strSql, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.Text
};
if (parameters != null)
{
command.Parameters.AddRange(parameters);
}
SqlDataAdapter adapter = new SqlDataAdapter(command);
adapter.Fill(dataTable);
}
finally
{
Connection.Close();
}
return dataTable;
}
}
/// <summary>
/// Will run a stored procedure, can only be called by those classes deriving
/// from this base. It returns a SqlDataReader containing the result of the stored
/// procedure.
/// </summary>
/// <param name="storedProcName">Name of the stored procedure</param>
/// <param name="parameters">Array of parameters to be passed to the procedure</param>
/// <returns>A newly instantiated SqlDataReader object</returns>
public static SqlDataReader RunProcedure(string storedProcName, IDataParameter[] parameters)
{
SqlDataReader returnReader;
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = BuildQueryCommand(storedProcName, parameters);
command.CommandTimeout = 0;
command.CommandType = CommandType.StoredProcedure;
returnReader = command.ExecuteReader();
}
finally { Connection.Close(); }
return returnReader;
}
}
/// <summary>
/// <20><>ȡ<EFBFBD>ַ<EFBFBD><D6B7><EFBFBD>
/// </summary>
/// <param name="sql">sql<71><6C><EFBFBD><EFBFBD></param>
/// <returns><3E>ַ<EFBFBD><D6B7><EFBFBD></returns>
public static string getStr(string sql)
{
string str = "";
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(sql, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.Text
};
str = command.ExecuteScalar().ToString();
}
finally
{
Connection.Close();
}
return str;
}
}
public static int GetIntValue(string sql)
{
int i = 0;
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(sql, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.Text
};
i = Convert.ToInt32(command.ExecuteScalar());
}
finally
{
Connection.Close();
}
return i;
}
}
/// <summary>
/// ִ<><D6B4>SQL<51><4C><EFBFBD><EFBFBD>
/// </summary>
/// <param name="sql">sql<71><6C><EFBFBD><EFBFBD></param>
public static void ExecutSql(string sql)
{
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(sql, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.Text
};
command.ExecuteNonQuery();
}
finally
{
Connection.Close();
}
}
}
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
/// <summary>
/// Creates a DataSet by running the stored procedure and placing the results
/// of the query/proc into the given tablename.
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
/// <param name="tableName"></param>
/// <returns></returns>
public static DataSet RunProcedure(string storedProcName, IDataParameter[] parameters, string tableName)
{
DataSet dataSet = new DataSet();
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlDataAdapter sqlDA = new SqlDataAdapter
{
SelectCommand = BuildQueryCommand(storedProcName, parameters)
};
sqlDA.SelectCommand.CommandTimeout = 0;
sqlDA.Fill(dataSet, tableName);
}
finally
{
Connection.Close();
}
return dataSet;
}
}
/// <summary>
/// Takes an -existing- dataset and fills the given table name with the results
/// of the stored procedure.
/// </summary>
/// <param name="storedProcName"></param>
/// <param name="parameters"></param>
/// <param name="dataSet"></param>
/// <param name="tableName"></param>
/// <returns></returns>
public static void RunProcedure(string storedProcName, IDataParameter[] parameters, DataSet dataSet, string tableName)
{
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlDataAdapter sqlDA = new SqlDataAdapter
{
SelectCommand = BuildIntCommand(storedProcName, parameters)
};
sqlDA.SelectCommand.CommandTimeout = 0;
sqlDA.Fill(dataSet, tableName);
}
finally
{
Connection.Close();
}
}
}
/// <summary>
/// <20><><EFBFBD>ڼ򵥵<DABC>Sql<71><6C>ѯ<EFBFBD><D1AF><EFBFBD><EFBFBD><EFBFBD><EFBFBD>DataSet
/// </summary>
/// <param name="strSql"></param>
/// <param name="tableName"></param>
/// <returns></returns>
public static DataSet RunSqlString(string strSql, string tableName)
{
DataSet dataSet = new DataSet();
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(strSql, Connection)
{
CommandTimeout = 0
};
SqlDataAdapter sqlDA = new SqlDataAdapter
{
SelectCommand = command
};
sqlDA.Fill(dataSet, tableName);
}
finally
{
Connection.Close();
}
return dataSet;
}
}
/// <summary>
/// <20><><EFBFBD>ڼ򵥵<DABC>Sql<71><6C>ѯ
/// </summary>
/// <param name="strSql"></param>
/// <param name="dataSet"></param>
/// <param name="tableName"></param>
public static void RunProcedure(string strSql, DataSet dataSet, string tableName)
{
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(strSql, Connection)
{
CommandTimeout = 0
};
SqlDataAdapter sqlDA = new SqlDataAdapter
{
SelectCommand = command
};
sqlDA.SelectCommand.CommandTimeout = 0;
sqlDA.Fill(dataSet, tableName);
}
finally
{
Connection.Close();
}
}
}
/// <summary>
/// <20><><EFBFBD>ڼ򵥵<DABC>Sqlִ<6C>У<EFBFBD><D0A3><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֵ<EFBFBD><D6B5><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݲ<EFBFBD><DDB2><EFBFBD><EFBFBD><EFBFBD><EFBFBD>͵<EFBFBD>
/// </summary>
/// <param name="strSql"></param>
/// <param name="result"></param>
public static void RunSqlString(string strSql, out int result)
{
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(strSql, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.Text
};
result = command.ExecuteNonQuery();
}
finally
{
Connection.Close();
}
}
}
/* public static DataSet RunProcedure(string storedProcName, IDataParameter[] parameters, string tableName )
{
DataSet dataSet = new DataSet();
if (Connection.State == ConnectionState.Open) Connection.Close();
Connection.Open();
SqlDataAdapter sqlDA = new SqlDataAdapter();
sqlDA.SelectCommand = BuildQueryCommand( storedProcName, parameters );
sqlDA.Fill( dataSet, tableName );
Connection.Close();
return dataSet;
}*/
/// <20><><EFBFBD>ش洢<D8B4><E6B4A2><EFBFBD><EFBFBD>ִ<EFBFBD>еĽ<D0B5><C4BD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
/// <param name="pur_name"><3E>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
/// <param name="parmList"><3E>洢<EFBFBD><E6B4A2><EFBFBD>̵<EFBFBD>{<7B><><EFBFBD><EFBFBD>--ֵ}<7D>ļ<EFBFBD><C4BC><EFBFBD></param>
// <20><><EFBFBD>ش洢<D8B4><E6B4A2><EFBFBD><EFBFBD>ִ<EFBFBD>еĽ<D0B5><C4BD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
public static DataTable RunProcedureGetTable(string pur_name, Hashtable parmList)
{
DataTable dt = new DataTable();
DataRow dr;
using (SqlConnection Connection = new SqlConnection(connectionString))
{
// <20><><EFBFBD>ô洢<C3B4><E6B4A2><EFBFBD><EFBFBD>pur_name<6D><65>
SqlCommand sqlCmd = new SqlCommand(pur_name, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.StoredProcedure
};
// Ϊ<><CEAA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֵ<EFBFBD><D6B5>
foreach (string parm in parmList.Keys)
{
sqlCmd.Parameters.Add(new SqlParameter("@" + parm, parmList[parm]));
}
// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ӡ<EFBFBD>
sqlCmd.Connection.Open();
SqlDataReader dreader = null;
try
{
dreader = sqlCmd.ExecuteReader();
for (int i = 0; i < dreader.FieldCount; i++)
{
DataColumn myDataColumn;
myDataColumn = new DataColumn
{
DataType = System.Type.GetType(dreader.GetFieldType(i).ToString()),
ColumnName = dreader.GetName(i),
Caption = dreader.GetName(i)
};
dt.Columns.Add(myDataColumn);
}
while (dreader.Read())
{
dr = dt.NewRow();
for (int i = 0; i < dreader.FieldCount; i++)
{
dr[i] = dreader[i];
}
dt.Rows.Add(dr);
}
dreader.Close();
}
catch (Exception ex)
{
string str = ex.Message.ToString();
// <20><><EFBFBD>ɹ<EFBFBD><C9B9><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʾ<EFBFBD><CABE>
throw new Exception(ex.ToString());
}
finally
{
// <20>ر<EFBFBD><D8B1><EFBFBD><EFBFBD>ӡ<EFBFBD>
sqlCmd.Connection.Close();
}
return dt;
}
}
/// </summary>
/// <param name="strSql">sql<71><6C></param>
/// <param name="parmList">sql{<7B><><EFBFBD><EFBFBD>--ֵ}<7D>ļ<EFBFBD><C4BC><EFBFBD></param>
public static DataTable RunSqlGetTable(string strSql)
{
DataTable dt = new DataTable();
DataRow dr;
using (SqlConnection Connection = new SqlConnection(connectionString))
{
// <20><><EFBFBD>ô洢<C3B4><E6B4A2><EFBFBD><EFBFBD>pur_name<6D><65>
SqlCommand sqlCmd = new SqlCommand(strSql, Connection)
{
CommandTimeout = 0
};
// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ӡ<EFBFBD>
sqlCmd.Connection.Open();
SqlDataReader dreader = null;
try
{
dreader = sqlCmd.ExecuteReader();
for (int i = 0; i < dreader.FieldCount; i++)
{
DataColumn myDataColumn;
myDataColumn = new DataColumn
{
DataType = System.Type.GetType(dreader.GetFieldType(i).ToString()),
ColumnName = dreader.GetName(i),
Caption = dreader.GetName(i)
};
dt.Columns.Add(myDataColumn);
}
while (dreader.Read())
{
dr = dt.NewRow();
for (int i = 0; i < dreader.FieldCount; i++)
{
dr[i] = dreader[i];
}
dt.Rows.Add(dr);
}
dreader.Close();
}
catch (Exception ex)
{
// <20><><EFBFBD>ɹ<EFBFBD><C9B9><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʾ<EFBFBD><CABE>
throw new Exception(ex.ToString());
}
finally
{
// <20>ر<EFBFBD><D8B1><EFBFBD><EFBFBD>ӡ<EFBFBD>
sqlCmd.Connection.Close();
}
return dt;
}
}
/// <20><><EFBFBD>ش洢<D8B4><E6B4A2><EFBFBD><EFBFBD>ִ<EFBFBD>еĽ<D0B5><C4BD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
/// <param name="pur_name"><3E>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
/// <param name="parmList"><3E>洢<EFBFBD><E6B4A2><EFBFBD>̵<EFBFBD>{<7B><><EFBFBD><EFBFBD>--ֵ}<7D>ļ<EFBFBD><C4BC><EFBFBD></param>
public static void RunProcedure(string pur_name, Hashtable parmList)
{
using (SqlConnection Connection = new SqlConnection(connectionString))
{
// <20><><EFBFBD>ô洢<C3B4><E6B4A2><EFBFBD><EFBFBD>pur_name<6D><65>
SqlCommand sqlCmd = new SqlCommand(pur_name, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.StoredProcedure
};
// Ϊ<><CEAA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֵ<EFBFBD><D6B5>
foreach (string parm in parmList.Keys)
{
sqlCmd.Parameters.Add(new SqlParameter("@" + parm, parmList[parm]));
}
// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ӡ<EFBFBD>
sqlCmd.Connection.Open();
try
{
sqlCmd.ExecuteNonQuery();
}
catch (Exception ex)
{
// <20><><EFBFBD>ɹ<EFBFBD><C9B9><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʾ<EFBFBD><CABE>
throw new Exception(ex.ToString());
}
finally
{
// <20>ر<EFBFBD><D8B1><EFBFBD><EFBFBD>ӡ<EFBFBD>
sqlCmd.Connection.Close();
}
}
}
/// <20><><EFBFBD>ش洢<D8B4><E6B4A2><EFBFBD><EFBFBD>ִ<EFBFBD>еĽ<D0B5><C4BD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
/// <param name="pur_name"><3E>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
/// <param name="parmList"><3E>洢<EFBFBD><E6B4A2><EFBFBD>̵<EFBFBD>{<7B><><EFBFBD><EFBFBD>--ֵ}<7D>ļ<EFBFBD><C4BC><EFBFBD></param>
public static void RunProcedure(string pur_name, Hashtable parmList, ref int returnValue)
{
using (SqlConnection Connection = new SqlConnection(connectionString))
{
// <20><><EFBFBD>ô洢<C3B4><E6B4A2><EFBFBD><EFBFBD>pur_name<6D><65>
SqlCommand sqlCmd = new SqlCommand(pur_name, Connection)
{
CommandTimeout = 0,
CommandType = CommandType.StoredProcedure
};
// Ϊ<><CEAA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֵ<EFBFBD><D6B5>
foreach (string parm in parmList.Keys)
{
sqlCmd.Parameters.Add(new SqlParameter("@" + parm, parmList[parm]));
}
// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ӡ<EFBFBD>
sqlCmd.Connection.Open();
try
{
returnValue = sqlCmd.ExecuteNonQuery();
}
catch (Exception ex)
{
// <20><><EFBFBD>ɹ<EFBFBD><C9B9><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʾ<EFBFBD><CABE>
throw new Exception(ex.ToString());
}
finally
{
// <20>ر<EFBFBD><D8B1><EFBFBD><EFBFBD>ӡ<EFBFBD>
sqlCmd.Connection.Close();
}
}
}
private static void AddParameterToCommand(SqlCommand cmd, SqlParameter[] param)
{
foreach (SqlParameter p in param)
{
cmd.Parameters.Add(p);
}
}
private static SqlCommand CreateCommand(CommandType commandType,
string commandText, SqlParameter[] param)
{
using (SqlConnection Connection = new SqlConnection(connectionString))
{
SqlCommand cmd = new SqlCommand
{
CommandTimeout = 0,
CommandType = commandType,
Connection = Connection
};
if (param != null)
{
AddParameterToCommand(cmd, param);
}
cmd.CommandText = commandText;
return cmd;
}
}
public static int ExecuteCommand(CommandType commandType,
string commandText, SqlParameter[] param)
{
SqlCommand cmd = CreateCommand(commandType, commandText, param);
cmd.CommandTimeout = 0;
SqlTransaction trans = null;
try
{
cmd.Connection.Open();
trans = cmd.Connection.BeginTransaction();
cmd.Transaction = trans;
int i = cmd.ExecuteNonQuery();
trans.Commit();
return i;
}
catch (SqlException se)
{
trans.Rollback();
throw se;
}
catch (Exception ex)
{
trans.Rollback();
throw ex;
}
finally
{
cmd.Connection.Close();
}
}
/// <summary>
/// ͨ<><CDA8><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ͱ<EFBFBD><CDB1><EFBFBD><EFBFBD>Լ<EFBFBD><D4BC><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ID<49><44><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD>з<EFBFBD><D0B7><EFBFBD>ֵ<EFBFBD>и<EFBFBD>output<75><74><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
/// <param name="storedProcName"><3E>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
/// <param name="tableName"><3E><><EFBFBD><EFBFBD></param>
/// <param name="columnName"><3E><><EFBFBD><EFBFBD></param>
/// <param name="projectId"><3E><>Ŀ<EFBFBD><C4BF></param>
/// <returns><3E><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>°汾<C2B0><E6B1BE></returns>
public static string RunProcNewId2(string storedProcName, string tableName, string columnName, string projectId)
{
string str = "";
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(storedProcName, Connection)
{
CommandType = CommandType.StoredProcedure
};
SqlParameter[] values = new SqlParameter[]
{
new SqlParameter("@tableName", tableName),
new SqlParameter("@columnName", columnName),
new SqlParameter("@projectId", projectId),
new SqlParameter("@returnVal", SqlDbType.VarChar, 30)
};
command.Parameters.AddRange(values);
command.Parameters["@returnVal"].Direction = ParameterDirection.Output;
command.ExecuteNonQuery();
str = command.Parameters["@returnVal"].Value.ToString();
}
finally
{
Connection.Close();
}
return str;
}
}
/// <summary>
/// ͨ<><CDA8><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ͱ<EFBFBD><CDB1><EFBFBD><EFBFBD>Լ<EFBFBD><D4BC><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ID<49><44><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD>з<EFBFBD><D0B7><EFBFBD>ֵ<EFBFBD>и<EFBFBD>output<75><74><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
/// <param name="storedProcName"><3E>洢<EFBFBD><E6B4A2><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
/// <param name="tableName"><3E><><EFBFBD><EFBFBD></param>
/// <param name="columnName"><3E><><EFBFBD><EFBFBD></param>
/// <param name="perfix">ǰ׺</param>
/// <returns><3E><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ID</returns>
public static string RunProcNewIdByProjectId(string storedProcName, string tableName, string columnName, string projectId, string prefix)
{
string str = "";
using (SqlConnection Connection = new SqlConnection(connectionString))
{
try
{
Connection.Open();
SqlCommand command = new SqlCommand(storedProcName, Connection)
{
CommandType = CommandType.StoredProcedure
};
SqlParameter[] values = new SqlParameter[]
{
new SqlParameter("@tableName", tableName),
new SqlParameter("@columnName", columnName),
new SqlParameter("@projectId", projectId),
new SqlParameter("@prefix", prefix),
new SqlParameter("@returnVal", SqlDbType.VarChar, 50)
};
command.Parameters.AddRange(values);
command.Parameters["@returnVal"].Direction = ParameterDirection.Output;
command.ExecuteNonQuery();
str = command.Parameters["@returnVal"].Value.ToString();
}
finally
{
Connection.Close();
}
return str;
}
}
/// <summary>
/// <20><><EFBFBD><EFBFBD>һ<EFBFBD><D2BB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
private static object newIdLocker = new object();
/// <summary>
/// <20><><EFBFBD><EFBFBD>һ<EFBFBD><D2BB><EFBFBD>µ<EFBFBD><C2B5><EFBFBD><EFBFBD><EFBFBD>ָ<EFBFBD><D6B8><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
/// <param name="table"></param>
/// <returns></returns>
public static string GetNewID(Type table)
{
lock (newIdLocker)
{
return Guid.NewGuid().ToString();
}
}
/// <summary>
/// <20><><EFBFBD><EFBFBD>һ<EFBFBD><D2BB><EFBFBD>µ<EFBFBD><C2B5><EFBFBD><EFBFBD><EFBFBD>ָ<EFBFBD><D6B8><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
/// </summary>
/// <returns></returns>
public static string GetNewID()
{
lock (newIdLocker)
{
return Guid.NewGuid().ToString();
}
}
/// <summary>
/// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>е<EFBFBD><D0B5><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֵ
/// </summary>
/// <param name="tableName"><3E><><EFBFBD><EFBFBD></param>
/// <param name="keyColumnName"><3E><><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
/// <returns><3E><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֵ</returns>
public static int GetMaxId(string tableName, string ColumnName)
{
int maxId = 0;
string str = "SELECT (ISNULL(MAX(" + ColumnName + "),0)+1) from " + tableName + "";
maxId = GetIntValue(str);
return maxId;
}
}
}