984 lines
36 KiB
C#
984 lines
36 KiB
C#
|
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;
|
|||
|
|
//private static SqlConnection Connection=new SqlConnection( connectionString );
|
|||
|
|
|
|||
|
|
//public static SqlConnection GetConn()
|
|||
|
|
//{
|
|||
|
|
// return Connection;
|
|||
|
|
//}
|
|||
|
|
/// <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);
|
|||
|
|
command.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);
|
|||
|
|
rowsAffected = command.ExecuteNonQuery();//ִ<><D6B4><EFBFBD><EFBFBD><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD>̺صĽ<D8B5><C4BD><EFBFBD>
|
|||
|
|
result = (int)command.Parameters["ReturnValue"].Value;
|
|||
|
|
}
|
|||
|
|
finally
|
|||
|
|
{
|
|||
|
|
Connection.Close();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <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);
|
|||
|
|
command.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);
|
|||
|
|
command.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);
|
|||
|
|
command.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="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);
|
|||
|
|
command.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;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
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);
|
|||
|
|
command.CommandType = CommandType.StoredProcedure;
|
|||
|
|
SqlParameter[] values = new SqlParameter[]
|
|||
|
|
{
|
|||
|
|
new SqlParameter("@tableName", tableName),
|
|||
|
|
new SqlParameter("@columnName", columnName),
|
|||
|
|
new SqlParameter("@prefix", prefix),
|
|||
|
|
new SqlParameter("@returnVal", SqlDbType.VarChar, 200)
|
|||
|
|
};
|
|||
|
|
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>
|
|||
|
|
/// <param name="toCode"><3E><>Ӧ<EFBFBD><D3A6><EFBFBD><EFBFBD></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 toCode)
|
|||
|
|
{
|
|||
|
|
string str = "";
|
|||
|
|
using (SqlConnection Connection = new SqlConnection(connectionString))
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
Connection.Open();
|
|||
|
|
SqlCommand command = new SqlCommand(storedProcName, Connection);
|
|||
|
|
command.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("@toCode", toCode),
|
|||
|
|
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);
|
|||
|
|
command.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>
|
|||
|
|
/// ͨ<><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);
|
|||
|
|
command.CommandType = CommandType.StoredProcedure;
|
|||
|
|
if (parameters != null)
|
|||
|
|
{
|
|||
|
|
command.Parameters.AddRange(parameters);
|
|||
|
|
}
|
|||
|
|
command.CommandTimeout = 1200;
|
|||
|
|
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.CommandType = CommandType.StoredProcedure;
|
|||
|
|
|
|||
|
|
returnReader = command.ExecuteReader();
|
|||
|
|
}
|
|||
|
|
finally
|
|||
|
|
{
|
|||
|
|
Connection.Close();
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return returnReader;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// ͨ<><CDA8><EFBFBD>洢<EFBFBD><E6B4A2><EFBFBD>̻<EFBFBD><CCBB><EFBFBD>DataTable
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="strSql">sql<71>ַ<EFBFBD><D6B7><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);
|
|||
|
|
command.CommandType = CommandType.Text;
|
|||
|
|
if (parameters != null)
|
|||
|
|
{
|
|||
|
|
command.Parameters.AddRange(parameters);
|
|||
|
|
}
|
|||
|
|
command.CommandTimeout = 1200;
|
|||
|
|
|
|||
|
|
SqlDataAdapter adapter = new SqlDataAdapter(command);
|
|||
|
|
adapter.Fill(dataTable);
|
|||
|
|
}
|
|||
|
|
finally
|
|||
|
|
{
|
|||
|
|
Connection.Close();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return dataTable;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <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);
|
|||
|
|
command.CommandType = CommandType.Text;
|
|||
|
|
|
|||
|
|
str = command.ExecuteScalar().ToString();
|
|||
|
|
}
|
|||
|
|
finally
|
|||
|
|
{
|
|||
|
|
Connection.Close();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return str;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// ִ<><D6B4>SQL<51><4C><EFBFBD><EFBFBD>
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="sql">sql<71><6C><EFBFBD><EFBFBD></param>
|
|||
|
|
public static void ExecutSql(string sql, params SqlParameter[] parameters)
|
|||
|
|
{
|
|||
|
|
using (SqlConnection Connection = new SqlConnection(connectionString))
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
Connection.Open();
|
|||
|
|
SqlCommand command = new SqlCommand(sql, Connection);
|
|||
|
|
command.CommandType = CommandType.Text;
|
|||
|
|
if (parameters != null)
|
|||
|
|
{
|
|||
|
|
command.Parameters.AddRange(parameters);
|
|||
|
|
}
|
|||
|
|
command.CommandTimeout = 1200;
|
|||
|
|
command.ExecuteNonQuery();
|
|||
|
|
}
|
|||
|
|
finally
|
|||
|
|
{
|
|||
|
|
Connection.Close();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public static void ExecutSql(string sql)
|
|||
|
|
{
|
|||
|
|
using (SqlConnection Connection = new SqlConnection(connectionString))
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
Connection.Open();
|
|||
|
|
SqlCommand command = new SqlCommand(sql, Connection);
|
|||
|
|
command.CommandType = CommandType.Text;
|
|||
|
|
command.CommandTimeout = 600;
|
|||
|
|
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();
|
|||
|
|
sqlDA.SelectCommand = BuildQueryCommand(storedProcName, parameters);
|
|||
|
|
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();
|
|||
|
|
sqlDA.SelectCommand = BuildIntCommand(storedProcName, parameters);
|
|||
|
|
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);
|
|||
|
|
command.CommandTimeout = 600;
|
|||
|
|
SqlDataAdapter sqlDA = new SqlDataAdapter();
|
|||
|
|
sqlDA.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);
|
|||
|
|
SqlDataAdapter sqlDA = new SqlDataAdapter();
|
|||
|
|
sqlDA.SelectCommand = command;
|
|||
|
|
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);
|
|||
|
|
command.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);
|
|||
|
|
sqlCmd.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();
|
|||
|
|
myDataColumn.DataType = System.Type.GetType(dreader.GetFieldType(i).ToString());
|
|||
|
|
myDataColumn.ColumnName = dreader.GetName(i);
|
|||
|
|
myDataColumn.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);
|
|||
|
|
|
|||
|
|
// <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();
|
|||
|
|
myDataColumn.DataType = System.Type.GetType(dreader.GetFieldType(i).ToString());
|
|||
|
|
myDataColumn.ColumnName = dreader.GetName(i);
|
|||
|
|
myDataColumn.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);
|
|||
|
|
sqlCmd.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);
|
|||
|
|
sqlCmd.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)
|
|||
|
|
{
|
|||
|
|
SqlCommand cmd = new SqlCommand();
|
|||
|
|
using (SqlConnection Connection = new SqlConnection(connectionString))
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
Connection.Open();
|
|||
|
|
cmd.CommandType = commandType;
|
|||
|
|
cmd.Connection = Connection;
|
|||
|
|
|
|||
|
|
if (param != null)
|
|||
|
|
{
|
|||
|
|
AddParameterToCommand(cmd, param);
|
|||
|
|
}
|
|||
|
|
cmd.CommandText = commandText;
|
|||
|
|
}
|
|||
|
|
finally
|
|||
|
|
{
|
|||
|
|
Connection.Close();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
return cmd;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public static int ExecuteCommand(CommandType commandType, string commandText, SqlParameter[] param)
|
|||
|
|
{
|
|||
|
|
SqlCommand cmd = CreateCommand(commandType, commandText, param);
|
|||
|
|
int i = 0;
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
i = cmd.ExecuteNonQuery();
|
|||
|
|
|
|||
|
|
return i;
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
throw ex;
|
|||
|
|
}
|
|||
|
|
finally
|
|||
|
|
{
|
|||
|
|
cmd.Connection.Close();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public static SqlDataReader RunSql(string strSql)
|
|||
|
|
{
|
|||
|
|
SqlDataReader returnReader;
|
|||
|
|
using (SqlConnection Connection = new SqlConnection(connectionString))
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
Connection.Open();
|
|||
|
|
SqlCommand command = new SqlCommand(strSql, Connection);
|
|||
|
|
command.CommandType = CommandType.Text;
|
|||
|
|
|
|||
|
|
returnReader = command.ExecuteReader();
|
|||
|
|
}
|
|||
|
|
finally
|
|||
|
|
{
|
|||
|
|
Connection.Close();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
return returnReader;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <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><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;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public static int getIntValue(string sql)
|
|||
|
|
{
|
|||
|
|
int i = 0;
|
|||
|
|
using (SqlConnection Connection = new SqlConnection(connectionString))
|
|||
|
|
{
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
Connection.Open();
|
|||
|
|
SqlCommand command = new SqlCommand(sql, Connection);
|
|||
|
|
command.CommandType = CommandType.Text;
|
|||
|
|
|
|||
|
|
i = Convert.ToInt32(command.ExecuteScalar());
|
|||
|
|
}
|
|||
|
|
finally
|
|||
|
|
{
|
|||
|
|
Connection.Close();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
return i;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|