76 lines
2.8 KiB
C#
76 lines
2.8 KiB
C#
using SYNC_SAP_MES;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Data.SqlClient;
|
|
using System.Linq;
|
|
using System.Text;
|
|
|
|
namespace SYNC_SAP_MES
|
|
{
|
|
public class SqlOperation
|
|
{
|
|
public static bool ExecuteStoredProcedure(string name, SqlParameter[] sqlParameters, out string errorMessage)
|
|
{
|
|
return DataLinkMesWork.SQLCommon.ExecuteStoredProcedure(name, PP.ConnectionString, ref sqlParameters, out errorMessage);
|
|
}
|
|
public static bool ExecuteStoredProcedure(string name, SqlParameter[] sqlParameters, out DataTable dt, out string errorMessage)
|
|
{
|
|
return DataLinkMesWork.SQLCommon.ExecuteStoredProcedure(name, PP.ConnectionString, ref sqlParameters, out dt, out errorMessage);
|
|
}
|
|
public static bool ExecuteStoredProcedure(string name, SqlParameter[] sqlParameters, out DataSet ds, out string errorMessage)
|
|
{
|
|
return DataLinkMesWork.SQLCommon.ExecuteStoredProcedure(name, PP.ConnectionString, ref sqlParameters, out ds, out errorMessage);
|
|
}
|
|
public static bool ExecuteSql(string sql, out DataTable dt, out string errorMessage)
|
|
{
|
|
try
|
|
{
|
|
return DataLinkMesWork.SQLCommon.ExecuteSql(sql, PP.ConnectionString, out dt, out errorMessage);
|
|
}
|
|
catch (Exception ex) {
|
|
dt = null;
|
|
errorMessage = ex.Message;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
public static bool ExecuteSql(string sql, out string errorMessage)
|
|
{
|
|
return DataLinkMesWork.SQLCommon.ExecuteSql(sql, PP.ConnectionString, out errorMessage);
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 通过SqlBulkCopy复制table数据到数据库
|
|
/// </summary>
|
|
/// <param name="dataset"></param>
|
|
public static bool SqlbulkcopyInsert(DataTable dt,out string ErrMessage)
|
|
{
|
|
bool success = false;
|
|
ErrMessage = "";
|
|
try
|
|
{
|
|
// SqlBulkCopy sqlbulkcopy = new SqlBulkCopy(connectString, SqlBulkCopyOptions.KeepIdentity);//删除自增ID插入原始数据
|
|
SqlBulkCopy sqlbulkcopy = new SqlBulkCopy(PP.ConnectionString, SqlBulkCopyOptions.UseInternalTransaction);//批量事务处理
|
|
sqlbulkcopy.DestinationTableName = dt.TableName;//数据库中的表名
|
|
for (int i = 0; i < dt.Columns.Count; i++)
|
|
{
|
|
var columnName = dt.Columns[i].ColumnName.ToString();
|
|
sqlbulkcopy.ColumnMappings.Add(columnName, columnName);
|
|
}
|
|
sqlbulkcopy.WriteToServer(dt);
|
|
success = true;
|
|
}
|
|
catch (Exception err)
|
|
{
|
|
ErrMessage=err.Message;
|
|
}
|
|
return success;
|
|
|
|
}
|
|
|
|
|
|
}
|
|
}
|