|
|
@@ -1,1010 +0,0 @@
|
|
|
-using Oracle.ManagedDataAccess.Client;
|
|
|
-using System;
|
|
|
-using System.Data;
|
|
|
-using System.Text;
|
|
|
-using System.Collections.Generic;
|
|
|
-
|
|
|
-namespace MES_Interface
|
|
|
-{
|
|
|
- /// <summary>
|
|
|
- /// 数据库操作类
|
|
|
- /// </summary>
|
|
|
- class DataHelper
|
|
|
- {
|
|
|
- //系统默认的的连接字符串
|
|
|
- private string ConnectionStrings = "";
|
|
|
- //用户选择的数据库的连接字符串
|
|
|
- public static OracleConnection connection = null;
|
|
|
- //用户选择的数据库的连接字符串
|
|
|
- OracleCommand command = null;
|
|
|
- /// <summary>
|
|
|
- /// 执行构造函数的时候打开数据库的链接
|
|
|
- /// </summary>
|
|
|
- public DataHelper(string Environment)
|
|
|
- {
|
|
|
- try
|
|
|
- {
|
|
|
- if (Environment.ToUpper() == "FORMAl")
|
|
|
- {
|
|
|
- ConnectionStrings = "Password=select!#%*(;User ID=MES;Pooling=false;Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=117.25.180.218)(PORT=1521)))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=orcl)));";
|
|
|
- }
|
|
|
- else if (Environment.ToUpper() == "TEST")
|
|
|
- {
|
|
|
- ConnectionStrings = "Password=select!#%*(;User ID=MES_TEST;Pooling=false;Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=117.25.180.218)(PORT=1521)))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=orcl)));";
|
|
|
- }
|
|
|
- connection = new OracleConnection(ConnectionStrings);
|
|
|
- connection.Open();
|
|
|
- }
|
|
|
- catch (Exception)
|
|
|
- {
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 获取第一行第一列的信息
|
|
|
- /// </summary>
|
|
|
- public object getFieldDataByCondition(string TableName, string Field, string Condition)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- string sql = "select " + Field + " from " + TableName + " where " + Condition;
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter();
|
|
|
- ad.SelectCommand = command;
|
|
|
- ad.Fill(dt);
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- if (dt.Rows.Count > 0)
|
|
|
- {
|
|
|
- return dt.Rows[0][0];
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- return "";
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 获取指定表的记录的条数 ,带条件
|
|
|
- /// </summary>
|
|
|
- /// <returns></returns>
|
|
|
- public int getRowCount(string TableName, string Condition)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- string sql = "select count(1) from " + TableName + " where " + Condition;
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- ad.Fill(dt);
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- return int.Parse(dt.Rows[0][0].ToString());
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 获取指定表的记录的条数 ,不带条件
|
|
|
- /// </summary>
|
|
|
- /// <param name="TableName"></param>
|
|
|
- /// <returns></returns>
|
|
|
- public int getRowCount(string TableName)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- string sql = "select count(1) from " + TableName;
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- ad.Fill(dt);
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- return int.Parse(dt.Rows[0][0].ToString());
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 通过表名和获取单行的记录
|
|
|
- /// </summary>
|
|
|
- public DataTable getFieldsDataByCondition(string TableName, string[] Fields, string Condition)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- string sql = "select ";
|
|
|
- sql += AddField(Fields);
|
|
|
- sql += " from " + TableName + " where " + Condition + " and rownum=1";
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- ad.Fill(dt);
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- return dt;
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 按分页获取数据
|
|
|
- /// </summary>
|
|
|
- /// <param name="TableName">表名</param>
|
|
|
- /// <param name="Fields">查询字段</param>
|
|
|
- /// <param name="CurrentPage">当前页面</param>
|
|
|
- /// <param name="PageSize">页面展示条数</param>
|
|
|
- /// <param name="Caller"></param>
|
|
|
- /// <returns></returns>
|
|
|
- // SELECT * FROM (SELECT A.* FROM (SELECT* FROM datalist) A WHERE ROWNUM <= 50) WHERE ROWNUM >= 21
|
|
|
- public DataTable getFieldsDatasByPageing(string TableName, string Fields, int CurrentPage, int PageSize, string Caller, params string[] condition)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- StringBuilder sql = new StringBuilder();
|
|
|
- //先查询出配置出去的列
|
|
|
- //获取查询的列
|
|
|
- string[] caption = GetCaptionFromField(Fields);
|
|
|
- //获取对应列的描述
|
|
|
- string[] field = GetField(Fields);
|
|
|
- sql.Append(" select * from (select RowNum RN, A.* from (select ");
|
|
|
- sql.Append(AddField(caption));
|
|
|
- if (condition.Length > 0)
|
|
|
- {
|
|
|
- if (condition[0] != null && condition[0].Trim() != "")
|
|
|
- sql.Append(" from " + TableName + " where " + condition[0] + " ) A where ROWNUM <=" + CurrentPage * PageSize + ") where RN>" + (CurrentPage - 1) * PageSize);
|
|
|
- else
|
|
|
- sql.Append(" from " + TableName + ") A where ROWNUM <= " + CurrentPage * PageSize + ") where RN> " + (CurrentPage - 1) * PageSize);
|
|
|
- }
|
|
|
- command = new OracleCommand(sql.ToString(), connection);
|
|
|
- Reconnect(command);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- ad.Fill(dt);
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- dt.Columns.RemoveAt(0);
|
|
|
- foreach (DataColumn dc in dt.Columns)
|
|
|
- {
|
|
|
- dc.ColumnName = field[dt.Columns.IndexOf(dc)];
|
|
|
- dc.Caption = caption[dt.Columns.IndexOf(dc)];
|
|
|
- }
|
|
|
- return dt;
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 通过表名，字段和条件获取DataTable类型的数据
|
|
|
- /// </summary>
|
|
|
- public DataTable getFieldsDatasByCondition(string TableName, string[] Fields, string Condition)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- string sql = "select ";
|
|
|
- sql += AddField(Fields);
|
|
|
- sql += " from " + TableName + " where " + Condition;
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- ad.Fill(dt);
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- return dt;
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 通过表名，字段获取DataTable类型的数据
|
|
|
- /// </summary>
|
|
|
- public DataTable getFieldsDatas(string TableName, string Fields)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- string sql = "select ";
|
|
|
- sql += Fields;
|
|
|
- sql += " from " + TableName;
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- ad.SelectCommand = command;
|
|
|
- ad.Fill(dt);
|
|
|
- foreach (DataColumn dc in dt.Columns)
|
|
|
- {
|
|
|
- dc.Caption = "测试测试";
|
|
|
- }
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- return dt;
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 根据DataTable和指定的表名更新数据,如果需要保存新增的数据则需要传递一条Insert的SQL
|
|
|
- /// </summary>
|
|
|
- /// <param name="DataTable"></param>
|
|
|
- /// <param name="TableName"></param>
|
|
|
- /// <param name="Condition"></param>
|
|
|
- public void UpDateTableByCondition(DataTable DataTable, string TableName, string PrimaryKey, params string[] sql)
|
|
|
- {
|
|
|
- if (DataTable == null)
|
|
|
- {
|
|
|
- return;
|
|
|
- }
|
|
|
- StringBuilder sb = new StringBuilder();
|
|
|
- //预防插入的DataTable中存在不属于该表的列，在进行下一步操作之前全部剔除
|
|
|
- DataTable data = (DataTable)ExecuteSql("select Column_Name,Data_Type from cols where TABLE_name=upper('" + TableName + "')", "select");
|
|
|
- //将所有的字段拼接起来
|
|
|
- for (int i = 0; i < data.Rows.Count; i++)
|
|
|
- {
|
|
|
- sb.Append("#" + data.Rows[i]["Column_Name"].ToString());
|
|
|
- }
|
|
|
- //移除掉所有不属于该表的列
|
|
|
- for (int i = DataTable.Columns.Count - 1; i >= 0; i--)
|
|
|
- {
|
|
|
- if (!sb.ToString().Contains(DataTable.Columns[i].ColumnName.ToUpper()))
|
|
|
- {
|
|
|
- DataTable.Columns.RemoveAt(i);
|
|
|
- }
|
|
|
- }
|
|
|
- sb.Clear();
|
|
|
- //计算有多少个是新加的行,根据主键为空来进行判断
|
|
|
- int NewRowCount = 0;
|
|
|
- for (int i = 0; i < DataTable.Rows.Count; i++)
|
|
|
- {
|
|
|
- if (DataTable.Rows[i][PrimaryKey] == null || DataTable.Rows[i][PrimaryKey].ToString() == "")
|
|
|
- {
|
|
|
- NewRowCount = NewRowCount + 1;
|
|
|
- }
|
|
|
- }
|
|
|
- if (sql.Length > 0)
|
|
|
- {
|
|
|
- if (NewRowCount > 0)
|
|
|
- {
|
|
|
- //获取参数的个数
|
|
|
- int paramsNum = sql[0].Split(':').Length - 1;
|
|
|
- //解析参数的数据
|
|
|
- string[] param = GetParamFromSQL(sql[0]);
|
|
|
- //新建一个二维数组去
|
|
|
- string[][] param_array = new string[paramsNum][];
|
|
|
- //实例化每个一维数组
|
|
|
- for (int i = 0; i < paramsNum; i++)
|
|
|
- {
|
|
|
- param_array[i] = new string[NewRowCount];
|
|
|
- }
|
|
|
- //设置每列参数的索引
|
|
|
- int num = 0;
|
|
|
- //变量所有的行，如果有主键为空的则移除，不为空的进行参数的拼接
|
|
|
- for (int i = DataTable.Rows.Count - 1; i >= 0; i--)
|
|
|
- {
|
|
|
- if (DataTable.Rows[i][PrimaryKey] == null || DataTable.Rows[i][PrimaryKey].ToString() == "")
|
|
|
- {
|
|
|
- //当为新添加行的时候才去设置参数，设置过后索引+1
|
|
|
- for (int j = 0; j < paramsNum; j++)
|
|
|
- {
|
|
|
- param_array[j][num] = DataTable.Rows[i][param[j]].ToString();
|
|
|
- }
|
|
|
- DataTable.Rows.RemoveAt(i);
|
|
|
- num++;
|
|
|
- }
|
|
|
- }
|
|
|
- BatchInsertDataTable(sql[0], param, param_array);
|
|
|
- }
|
|
|
- }
|
|
|
- //不是新增行的启用更新的方法
|
|
|
- sb.Append("update " + TableName + " set ");
|
|
|
- //拼接语句，特殊处理日期
|
|
|
-
|
|
|
- foreach (DataColumn dc in DataTable.Columns)
|
|
|
- {
|
|
|
- if (!dc.DataType.ToString().Equals("System.DateTime"))
|
|
|
- {
|
|
|
- sb.Append(dc.Caption + "=:" + dc.Caption + ",");
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- sb.Append(dc.Caption + "=:" + dc.Caption + ",");
|
|
|
- }
|
|
|
- }
|
|
|
- sb.Remove(sb.Length - 1, 1);
|
|
|
- sb.Append(" where " + PrimaryKey + "=:" + PrimaryKey);
|
|
|
- command = new OracleCommand(sb.ToString(), connection);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- // 参数的长度是DataTable的行数决定的
|
|
|
- command.ArrayBindCount = DataTable.Rows.Count;
|
|
|
- //默认全部是Varchar2类型的
|
|
|
- OracleDbType ob = OracleDbType.Varchar2;
|
|
|
- for (int i = 0; i < DataTable.Columns.Count; i++)
|
|
|
- {
|
|
|
- object[] param = new object[DataTable.Rows.Count];
|
|
|
- for (int j = 0; j < DataTable.Rows.Count; j++)
|
|
|
- {
|
|
|
- DateTime dt = DateTime.Now;
|
|
|
- if (DateTime.TryParse(DataTable.Rows[j][i].ToString(), out dt))
|
|
|
- {
|
|
|
- param[j] = dt;
|
|
|
- ob = OracleDbType.Date;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- ob = OracleDbType.Varchar2;
|
|
|
- param[j] = DataTable.Rows[j][i];
|
|
|
- }
|
|
|
- }
|
|
|
- //添加批量更新的参数
|
|
|
- command.Parameters.Add(new OracleParameter(DataTable.Columns[i].Caption, ob, param, ParameterDirection.Input));
|
|
|
- }
|
|
|
- ad.UpdateCommand = command;
|
|
|
- ad.Update(DataTable);
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 获取DbFind的数据的DataTable的结构
|
|
|
- /// </summary>
|
|
|
- /// <param name="field"></param>
|
|
|
- /// <param name="caller"></param>
|
|
|
- /// <returns></returns>
|
|
|
- public DataTable GetDbFindDataTable(string field, string caller)
|
|
|
- {
|
|
|
- string sql = "select * from dbfindsetui where ds_caller='" + caller + "' and ds_whichui='" + field + "'";
|
|
|
- DataTable dt = (DataTable)ExecuteSql(sql, "select");
|
|
|
- if (dt.Rows.Count != 0)
|
|
|
- {
|
|
|
- //通过#号分割字段
|
|
|
- string[] dbfield = dt.Rows[0]["ds_findtoui"].ToString().Split('#');
|
|
|
- string[] cnfield = dt.Rows[0]["ds_dbcaption"].ToString().Split('#');
|
|
|
- //获取查询要查询的Table
|
|
|
- string dbtable = dt.Rows[0]["ds_tables"].ToString();
|
|
|
- //拼接查询的字段
|
|
|
- for (int i = 0; i < dbfield.Length; i++)
|
|
|
- {
|
|
|
- dbfield[i] = dbfield[i].Split(',')[0];
|
|
|
- }
|
|
|
- //新建一个空的DataTable
|
|
|
- DataTable dt1 = new DataTable();
|
|
|
- //往空的DataTable添加结构,ColumnName是中文，Caption是实际的字段名称
|
|
|
- for (int i = 0; i < cnfield.Length; i++)
|
|
|
- {
|
|
|
- dt1.Columns.Add(cnfield[i]);
|
|
|
- dt1.Columns[i].Caption = dbfield[i];
|
|
|
- }
|
|
|
- //返回一个带有结构的空的DataTable
|
|
|
- //DbFind.BindTable1 = dbtable;
|
|
|
- return dt1;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- return null;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 获取配置列表中的数据，支持DaatList,Form,DetailGrid
|
|
|
- /// </summary>
|
|
|
- /// <param name="Caller"></param>
|
|
|
- /// <param name="Type"></param>
|
|
|
- /// <param name="condition"></param>
|
|
|
- /// <returns></returns>
|
|
|
- public DataTable GetConfigureData(string Caller, string Type, string condition)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- //用于拼接SQL语句
|
|
|
- StringBuilder Sql = new StringBuilder();
|
|
|
- //用于设置不同Type时设置对应表的字段
|
|
|
- string getField = "";
|
|
|
- string getCaption = "";
|
|
|
- string getTable = "";
|
|
|
- switch (Type.ToUpper())
|
|
|
- {
|
|
|
- case "DATALIST":
|
|
|
- getField = "dld_field"; getCaption = "dld_caption"; getTable = "dld_table";
|
|
|
- Sql.Append("select * from datalistdetail where dld_caller='" + Caller + "'");
|
|
|
- break;
|
|
|
- case "FORM":
|
|
|
- getField = "fd_field"; getCaption = "fd_caption"; getTable = "fd_table";
|
|
|
- Sql.Append("select * from formdetail where fd_foid=( select fo_id from form where fo_caller='" + Caller + "')");
|
|
|
- break;
|
|
|
- case "DETAILGRID":
|
|
|
- getField = "dg_field"; getCaption = "dg_caption"; getTable = "dg_table";
|
|
|
- Sql.Append("select * from detailgrid where dg_caller='" + Caller + "'");
|
|
|
- break;
|
|
|
- }
|
|
|
- command = new OracleCommand(Sql.ToString(), connection);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- ad.Fill(dt);
|
|
|
- //清除掉之前的内容重新拼接
|
|
|
- Sql.Clear();
|
|
|
- Sql.Append("select ");
|
|
|
- string[] field = new string[dt.Rows.Count];
|
|
|
- string[] caption = new string[dt.Rows.Count];
|
|
|
- DataTable dt1 = new DataTable();
|
|
|
- //记录描述和字段名称
|
|
|
- foreach (DataRow dr in dt.Rows)
|
|
|
- {
|
|
|
- field[dt.Rows.IndexOf(dr)] = dr[getCaption].ToString();
|
|
|
- caption[dt.Rows.IndexOf(dr)] = dr[getField].ToString();
|
|
|
- Sql.Append(dr[getField] + ",");
|
|
|
- }
|
|
|
- //调用substring是为了去除之前拼接多出来的一个逗号
|
|
|
- string sql = Sql.Remove(Sql.Length - 1, 1).ToString() + " from " + dt.Rows[0][getTable] + " where " + condition;
|
|
|
- //调用一个新的构造DataTable用来存放返回的数据
|
|
|
- dt1 = (DataTable)ExecuteSql(sql, "select");
|
|
|
- //给DataTable加上列名和描述，列名是中文字段，描述是数据库实际的字段名称
|
|
|
- for (int i = 0; i < field.Length; i++)
|
|
|
- {
|
|
|
- dt1.Columns[i].ColumnName = field[i];
|
|
|
- dt1.Columns[i].Caption = caption[i];
|
|
|
- }
|
|
|
- //返回的第一条数据是SQL，后面的是实际的列名
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- return dt1;
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 查询配置的字段,Type是查询DataList，Form还是DetailGrid
|
|
|
- /// </summary>
|
|
|
- /// <param name="Caller"></param>
|
|
|
- /// <param name="Type"></param>
|
|
|
- /// <returns></returns>
|
|
|
- public DataTable GetConfigureData(string Caller, string Type)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- //用于拼接SQL语句
|
|
|
- StringBuilder Sql = new StringBuilder();
|
|
|
- //用于设置不同Type时设置对应表的字段
|
|
|
- string getField = "";
|
|
|
- string getCaption = "";
|
|
|
- string getTable = "";
|
|
|
- switch (Type.ToUpper())
|
|
|
- {
|
|
|
- case "DATALIST":
|
|
|
- getField = "dld_field"; getCaption = "dld_caption"; getTable = "dld_table";
|
|
|
- Sql.Append("select * from datalistdetail where dld_caller='" + Caller + "'");
|
|
|
- break;
|
|
|
- case "FORM":
|
|
|
- getField = "fd_field"; getCaption = "fd_caption"; getTable = "fd_table";
|
|
|
- Sql.Append("select * from formdetail where fd_foid=( select fo_id from form where fo_caller='" + Caller + "')");
|
|
|
- break;
|
|
|
- case "DETAILGRID":
|
|
|
- getField = "dg_field"; getCaption = "dg_caption"; getTable = "dg_table";
|
|
|
- Sql.Append("select * from detailgrid where dg_caller='" + Caller + "'");
|
|
|
- break;
|
|
|
- }
|
|
|
- command = new OracleCommand(Sql.ToString(), connection);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- ad.Fill(dt);
|
|
|
- //清除掉之前的内容重新拼接
|
|
|
- Sql.Clear();
|
|
|
- Sql.Append("select ");
|
|
|
- //用于记录实际的列名,+1的目的是为了存放SQL
|
|
|
- string[] field = new string[dt.Rows.Count];
|
|
|
- string[] caption = new string[dt.Rows.Count];
|
|
|
- DataTable dt1 = new DataTable();
|
|
|
- foreach (DataRow dr in dt.Rows)
|
|
|
- {
|
|
|
- field[dt.Rows.IndexOf(dr)] = dr[getCaption].ToString();
|
|
|
- caption[dt.Rows.IndexOf(dr)] = dr[getField].ToString();
|
|
|
- Sql.Append(dr[getField] + ",");
|
|
|
- }
|
|
|
- string sql = Sql.Remove(Sql.Length - 1, 1).ToString() + " from " + dt.Rows[0][getTable];
|
|
|
- dt1 = (DataTable)ExecuteSql(sql, "select");
|
|
|
- //设置DataTable的列名和描述
|
|
|
- for (int i = 0; i < field.Length; i++)
|
|
|
- {
|
|
|
- dt1.Columns[i].ColumnName = field[i];
|
|
|
- dt1.Columns[i].Caption = caption[i];
|
|
|
- }
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- return dt1;
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 检测内容是否存在
|
|
|
- /// </summary>
|
|
|
- /// <param name="TableName"></param>
|
|
|
- /// <param name="Condition"></param>
|
|
|
- /// <returns></returns>
|
|
|
- public bool CheckExist(string TableName, string Condition)
|
|
|
- {
|
|
|
- string sql = "select count(1) from " + TableName + " where " + Condition;
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- DataTable dt = new DataTable();
|
|
|
- ad.Fill(dt);
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- return int.Parse(dt.Rows[0][0].ToString()) > 0;
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 直接执行SQL，同时传入SQL的类型
|
|
|
- /// </summary>
|
|
|
- /// <param name="SQL"></param>
|
|
|
- /// <param name="Type"></param>
|
|
|
- /// <returns></returns>
|
|
|
- public object ExecuteSql(string SQL, string Type, params object[] names)
|
|
|
- {
|
|
|
- object result = null;
|
|
|
- command = new OracleCommand(SQL, connection);
|
|
|
- Reconnect(command);
|
|
|
- //用来拼接参数的
|
|
|
- if (names.Length > 0)
|
|
|
- {
|
|
|
- string[] par = SQL.Split(':');
|
|
|
- //用来存参数的数组
|
|
|
- StringBuilder[] addpar = new StringBuilder[par.Length - 1];
|
|
|
- for (int i = 0; i < par.Length - 1; i++)
|
|
|
- {
|
|
|
- //新建一个char类型的数组用来存储每个字节的变量
|
|
|
- char[] c = par[i + 1].ToCharArray();
|
|
|
- addpar[i] = new StringBuilder();
|
|
|
- for (int j = 0; j < c.Length; j++)
|
|
|
- {
|
|
|
- if (c[j] != ' ' && c[j] != ',')
|
|
|
- {
|
|
|
- addpar[i].Append(c[j]);
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- break;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- for (int i = 0; i < addpar.Length; i++)
|
|
|
- command.Parameters.Add(new OracleParameter(addpar[i].ToString(), OracleDbType.Varchar2, names[i], ParameterDirection.Input));
|
|
|
- }
|
|
|
- switch (Type.ToUpper())
|
|
|
- {
|
|
|
- case "SELECT":
|
|
|
- result = new DataTable();
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- ad.Fill((DataTable)result);
|
|
|
- ad.Dispose();
|
|
|
- break;
|
|
|
- case "DELETE":
|
|
|
- result = command.ExecuteNonQuery();
|
|
|
- break;
|
|
|
- case "UPDATE":
|
|
|
- result = command.ExecuteNonQuery();
|
|
|
- break;
|
|
|
- case "INSERT":
|
|
|
- result = command.ExecuteNonQuery();
|
|
|
- break;
|
|
|
- }
|
|
|
- command.Dispose();
|
|
|
- return result;
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 为了同步BS端的条码维护，检测时允许问号的存在，在检测时默认将问号换成:Param参数
|
|
|
- /// </summary>
|
|
|
- /// <param name="SQL"></param>
|
|
|
- public void CheckSQL(string SQL)
|
|
|
- {
|
|
|
- SQL = SQL.Replace("?", ":Param");
|
|
|
- command = new OracleCommand(SQL, connection);
|
|
|
- command.ExecuteNonQuery();
|
|
|
- command.Dispose();
|
|
|
- }
|
|
|
-
|
|
|
- public int GetDistinctRowCount(string TableName, string Field)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- string sql = "select distinct count('" + Field + "') from " + TableName;
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- ad.Fill(dt);
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- return int.Parse(dt.Rows[0][0].ToString());
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 根据Caller获取流水号
|
|
|
- /// </summary>
|
|
|
- /// <param name="Caller"></param>
|
|
|
- /// <returns></returns>
|
|
|
- public string GetSerialNumberByCaller(string Caller)
|
|
|
- {
|
|
|
- string SerialNumber = getFieldDataByCondition("MaxNumbers", "mn_number", "mn_tablename='" + Caller + "'").ToString();
|
|
|
- UpdateByCondition("MaxNumbers", "mn_number=mn_number+1", "mn_tablename='" + Caller + "'");
|
|
|
- return SerialNumber;
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 根据主键ID删除表的数据
|
|
|
- /// </summary>
|
|
|
- /// <param name="TableName">表名</param>
|
|
|
- /// <param name="ID">主键</param>
|
|
|
- /// <param name="DeleteID">需要删除主键ID的数组</param>
|
|
|
- public void DeleteDataByID(string TableName, string ID, string[] DeleteID)
|
|
|
- {
|
|
|
- string sql = "delete from " + TableName + " where " + ID + " =:DeleteID";
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- command.ArrayBindCount = DeleteID.Length;
|
|
|
- command.Parameters.Add(new OracleParameter("DeleteID", OracleDbType.Long, DeleteID, ParameterDirection.Input));
|
|
|
- command.ExecuteNonQuery();
|
|
|
- command.Dispose();
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 通过序列的名称获取序列
|
|
|
- /// </summary>
|
|
|
- /// <param name="SeqName"></param>
|
|
|
- /// <returns></returns>
|
|
|
- public string GetSEQ(string SeqName)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- dt = (DataTable)ExecuteSql("SELECT " + SeqName + ".NEXTVAL FROM DUAL", "select");
|
|
|
- return dt.Rows[0][0].ToString();
|
|
|
- }
|
|
|
-
|
|
|
- public void SaveDataTable(DataTable dt, string TableName, string ID, params string[] sql)
|
|
|
- {
|
|
|
- if (dt == null)
|
|
|
- {
|
|
|
- return;
|
|
|
- }
|
|
|
- StringBuilder sb = new StringBuilder();
|
|
|
- //预防插入的DataTable中存在不属于该表的列，在进行下一步操作之前全部剔除
|
|
|
- DataTable data = (DataTable)ExecuteSql("select Column_Name,Data_Type from cols where TABLE_name=upper('" + TableName + "')", "select");
|
|
|
- //将所有的字段拼接起来
|
|
|
- for (int i = 0; i < data.Rows.Count; i++)
|
|
|
- {
|
|
|
- sb.Append("#" + data.Rows[i]["Column_Name"].ToString());
|
|
|
- }
|
|
|
- //移除掉所有不属于该表的列
|
|
|
- for (int i = dt.Columns.Count - 1; i >= 0; i--)
|
|
|
- {
|
|
|
- if (!sb.ToString().Contains(dt.Columns[i].ColumnName.ToUpper()))
|
|
|
- {
|
|
|
- dt.Columns.RemoveAt(i);
|
|
|
- }
|
|
|
- }
|
|
|
- sb.Clear();
|
|
|
- //计算有多少个是新加的行,根据主键为空来进行判断
|
|
|
- int NewRowCount = 0;
|
|
|
- for (int i = 0; i < dt.Rows.Count; i++)
|
|
|
- {
|
|
|
- if (dt.Rows[i][ID] == null || dt.Rows[i][ID].ToString() == "")
|
|
|
- {
|
|
|
- NewRowCount = NewRowCount + 1;
|
|
|
- }
|
|
|
- }
|
|
|
- if (sql.Length > 0)
|
|
|
- {
|
|
|
- if (NewRowCount > 0)
|
|
|
- {
|
|
|
- //获取参数的个数
|
|
|
- int paramsNum = sql[0].Split(':').Length - 1;
|
|
|
- //解析参数的数据
|
|
|
- string[] param = GetParamFromSQL(sql[0]);
|
|
|
- //新建一个二维数组去
|
|
|
- string[][] param_array = new string[paramsNum][];
|
|
|
- //实例化每个一维数组
|
|
|
- for (int i = 0; i < paramsNum; i++)
|
|
|
- {
|
|
|
- param_array[i] = new string[NewRowCount];
|
|
|
- }
|
|
|
- //设置每列参数的索引
|
|
|
- int num = 0;
|
|
|
- //变量所有的行，如果有主键为空的则移除，不为空的进行参数的拼接
|
|
|
- for (int i = dt.Rows.Count - 1; i >= 0; i--)
|
|
|
- {
|
|
|
- if (dt.Rows[i][ID] == null || dt.Rows[i][ID].ToString() == "")
|
|
|
- {
|
|
|
- //当为新添加行的时候才去设置参数，设置过后索引+1
|
|
|
- for (int j = 0; j < paramsNum; j++)
|
|
|
- {
|
|
|
- param_array[j][num] = dt.Rows[i][param[j]].ToString();
|
|
|
- }
|
|
|
- dt.Rows.RemoveAt(i);
|
|
|
- num++;
|
|
|
- }
|
|
|
- }
|
|
|
- BatchInsertDataTable(sql[0], param, param_array);
|
|
|
- }
|
|
|
- }
|
|
|
- sb.Clear();
|
|
|
- sb.Append("update " + TableName + " set ");
|
|
|
- int ColumnCount = dt.Columns.Count;
|
|
|
- int RowCount = dt.Rows.Count;
|
|
|
- //存数据的参数
|
|
|
- List<string[]> Parameter = new List<string[]>();
|
|
|
- //存参数名的参数
|
|
|
- string[] ParName = new string[ColumnCount];
|
|
|
- for (int i = 0; i < ColumnCount; i++)
|
|
|
- {
|
|
|
- ParName[i] = dt.Columns[i].ColumnName;
|
|
|
- if (i == dt.Columns.Count - 1)
|
|
|
- sb.Append(dt.Columns[i].ColumnName + "=:" + dt.Columns[i].ColumnName);
|
|
|
- else
|
|
|
- sb.Append(dt.Columns[i].ColumnName + "=:" + dt.Columns[i].ColumnName + ",");
|
|
|
- }
|
|
|
- sb.Append(" where " + ID + " =:" + ID);
|
|
|
- //先添加参数
|
|
|
- Parameter.Add(ParName);
|
|
|
- //添加参数的具体内容
|
|
|
- for (int i = 0; i < ColumnCount; i++)
|
|
|
- {
|
|
|
- string[] par = new string[RowCount];
|
|
|
- for (int j = 0; j < RowCount; j++)
|
|
|
- {
|
|
|
- par[j] = dt.Rows[j][i].ToString();
|
|
|
- }
|
|
|
- Parameter.Add(par);
|
|
|
- }
|
|
|
- BatchInsert(sb.ToString(), Parameter.ToArray());
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 批量通过SQL来执行插入操作 ，参数的第一个数一个string[]数组，用来传递需要添加的参数的名称
|
|
|
- /// 之后的是名称参数数组对应的 ，所有的插入参数数据长度必须是一致的
|
|
|
- /// </summary>
|
|
|
- /// <param name="sql"></param>
|
|
|
- /// <param name="names"></param>
|
|
|
- public void BatchInsert(string sql, params object[][] names)
|
|
|
- {
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- command.ArrayBindCount = names[1].Length;
|
|
|
- //因为第一个数组保存的是参数的名称，所以循环从1而不是0开始
|
|
|
- //将第一个数组的下标固定为0作为循环添加的参数的名称
|
|
|
- for (int i = 1; i <= names[0].Length; i++)
|
|
|
- {
|
|
|
- command.Parameters.Add(new OracleParameter(names[0][i - 1].ToString(), OracleDbType.Varchar2, names[i], ParameterDirection.Input));
|
|
|
- }
|
|
|
- command.ExecuteNonQuery();
|
|
|
- command.Dispose();
|
|
|
- }
|
|
|
-
|
|
|
- public void BatchInsertDataTable(string sql, string[] param, params object[][] param1)
|
|
|
- {
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- command.ArrayBindCount = param1[0].Length;
|
|
|
- //因为第一个数组保存的是参数的名称，所以循环从1而不是0开始
|
|
|
- //将第一个数组的下标固定为0作为循环添加的参数的名称
|
|
|
- for (int i = 0; i < param.Length; i++)
|
|
|
- {
|
|
|
- command.Parameters.Add(new OracleParameter(param[i].ToString(), OracleDbType.Varchar2, param1[i], ParameterDirection.Input));
|
|
|
- }
|
|
|
- command.ExecuteNonQuery();
|
|
|
- command.Dispose();
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 查询DataList配置的字段
|
|
|
- /// </summary>
|
|
|
- /// <param name="TableName"></param>
|
|
|
- /// <param name="Caller"></param>
|
|
|
- /// <returns></returns>
|
|
|
- public string GetDataList(string TableName, string Caller)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- string SQL = " select listagg(dld_field,',') within group (order by dld_id) from datalistdetail where dld_caller='" + Caller + "'";
|
|
|
- command = new OracleCommand(SQL, connection);
|
|
|
- Reconnect(command);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter(command);
|
|
|
- ad.Fill(dt);
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- return dt.Rows[0][0].ToString();
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 取Configs表中的配置，进行该客户是否执行某个操作
|
|
|
- /// </summary>
|
|
|
- /// <param name="Code"></param>
|
|
|
- /// <param name="Caller"></param>
|
|
|
- /// <returns></returns>
|
|
|
- public object GetConfig(string Code, string Caller)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- string sql = "select Data from configs where code='" + Code + "' and caller='" + Caller + "'";
|
|
|
- dt = (DataTable)ExecuteSql(sql, "select");
|
|
|
- if (dt.Rows.Count == 0)
|
|
|
- {
|
|
|
- return "";
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- return dt.Rows[0]["Data"];
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- //将数据类型的列类型转换为DataTable
|
|
|
- public DataTable DataTypeColumnToDataTable(DataTable dt)
|
|
|
- {
|
|
|
- DataTable dt1 = new DataTable();
|
|
|
- dt1.Rows.Add();
|
|
|
- foreach (DataRow dr in dt.Rows)
|
|
|
- {
|
|
|
- dt1.Columns.Add(dr[0].ToString());
|
|
|
- int index = dt.Rows.IndexOf(dr);
|
|
|
- if (dr[1].ToString() == "NUMBER")
|
|
|
- {
|
|
|
- dt1.Rows[0][index] = 0;
|
|
|
- }
|
|
|
- if (dr[1].ToString() == "VARCHAR2")
|
|
|
- {
|
|
|
- dt1.Rows[0][index] = "这是一段文字";
|
|
|
- }
|
|
|
- if (dr[1].ToString() == "DATE")
|
|
|
- {
|
|
|
- dt1.Rows[0][index] = DateTime.Now.ToString("yyyy-MM-dd");
|
|
|
- }
|
|
|
- if (dr[1].ToString() == "FLOAT")
|
|
|
- {
|
|
|
- dt1.Rows[0][index] = 1.0;
|
|
|
- }
|
|
|
- if (dr[1].ToString() == "CLOB")
|
|
|
- {
|
|
|
- dt1.Rows[0][index] = "一段长文字";
|
|
|
- }
|
|
|
- }
|
|
|
- return dt1;
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 通过条件更新
|
|
|
- /// </summary>
|
|
|
- /// <param name="TableName"></param>
|
|
|
- /// <param name="update"></param>
|
|
|
- /// <param name="condition"></param>
|
|
|
- public string UpdateByCondition(string TableName, string update, string condition)
|
|
|
- {
|
|
|
- string sql = "update " + TableName + " set " + update + " where " + condition;
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- command.ExecuteNonQuery();
|
|
|
- command.Dispose();
|
|
|
- return sql;
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 调用存储过程
|
|
|
- /// </summary>
|
|
|
- /// <param name="ProcedureName"></param>
|
|
|
- /// <param name="param"></param>
|
|
|
- public void CallProcedure(string ProcedureName, ref string[] param)
|
|
|
- {
|
|
|
- command = new OracleCommand(ProcedureName);
|
|
|
- command.Connection = connection;
|
|
|
- Reconnect(command);
|
|
|
- command.CommandText = ProcedureName;
|
|
|
- command.CommandType = CommandType.StoredProcedure;
|
|
|
- for (int i = 0; i < param.Length; i++)
|
|
|
- command.Parameters.Add(new OracleParameter(param[i].ToString(), OracleDbType.Varchar2, 200, param[i], ParameterDirection.InputOutput));
|
|
|
- command.ExecuteNonQuery();
|
|
|
- for (int i = 0; i < command.Parameters.Count; i++)
|
|
|
- param[i] = command.Parameters[i].Value.ToString();
|
|
|
- command.Dispose();
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 出现异常进行回滚的执行方法
|
|
|
- /// </summary>
|
|
|
- /// <param name="SQL"></param>
|
|
|
- public void ExecuteSQLTran(params string[] SQL)
|
|
|
- {
|
|
|
- OracleTransaction tx = connection.BeginTransaction();
|
|
|
- command = new OracleCommand();
|
|
|
- command.Connection = connection;
|
|
|
- command.Transaction = tx;
|
|
|
- try
|
|
|
- {
|
|
|
- foreach (string sql in SQL)
|
|
|
- {
|
|
|
- if (!string.IsNullOrEmpty(sql))
|
|
|
- {
|
|
|
- command.CommandText = sql;
|
|
|
- command.ExecuteNonQuery();
|
|
|
- }
|
|
|
- }
|
|
|
- tx.Commit();
|
|
|
- }
|
|
|
- catch (System.Data.OracleClient.OracleException E)
|
|
|
- {
|
|
|
- tx.Rollback();
|
|
|
- throw new Exception(E.Message);
|
|
|
- }
|
|
|
- command.Dispose();
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 用于将string 的数组转换成SQL的查询内容
|
|
|
- /// </summary>
|
|
|
- /// <param name="Fields"></param>
|
|
|
- /// <returns></returns>
|
|
|
- private string AddField(string[] Fields)
|
|
|
- {
|
|
|
- string sql = " ";
|
|
|
- foreach (string field in Fields)
|
|
|
- {
|
|
|
- sql += field + ",";
|
|
|
- }
|
|
|
- return sql.Substring(0, sql.Length - 1);
|
|
|
- }
|
|
|
- /// <summary>
|
|
|
- /// 通过查询的内容获取到字段的描述
|
|
|
- /// </summary>
|
|
|
- /// <param name="field"></param>
|
|
|
- /// <returns></returns>
|
|
|
- private static string[] GetCaptionFromField(string field)
|
|
|
- {
|
|
|
- string[] caption = field.Split(',');
|
|
|
- for (int i = 0; i < caption.Length; i++)
|
|
|
- {
|
|
|
- caption[i] = caption[i].Substring(0, caption[i].LastIndexOf("as")).Trim();
|
|
|
- }
|
|
|
- return caption;
|
|
|
- }
|
|
|
-
|
|
|
- /// <summary>
|
|
|
- /// 通过查询的语句获取查询的字段
|
|
|
- /// </summary>
|
|
|
- /// <param name="field"></param>
|
|
|
- /// <returns></returns>
|
|
|
- private static string[] GetField(string field)
|
|
|
- {
|
|
|
- string[] fields = field.Split(',');
|
|
|
- for (int i = 0; i < fields.Length; i++)
|
|
|
- {
|
|
|
- fields[i] = fields[i].Substring(fields[i].LastIndexOf("as") + 2, fields[i].Length - fields[i].LastIndexOf("as") - 2).Trim();
|
|
|
- }
|
|
|
- return fields;
|
|
|
- }
|
|
|
-
|
|
|
- public object GetLabelParam(string sql)
|
|
|
- {
|
|
|
- DataTable dt = new DataTable();
|
|
|
- command = new OracleCommand(sql, connection);
|
|
|
- Reconnect(command);
|
|
|
- OracleDataAdapter ad = new OracleDataAdapter();
|
|
|
- ad.SelectCommand = command;
|
|
|
- ad.Fill(dt);
|
|
|
- if (dt.Rows.Count > 0)
|
|
|
- {
|
|
|
- ad.Dispose();
|
|
|
- command.Dispose();
|
|
|
- return dt.Rows[0][0];
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- command.Dispose();
|
|
|
- return "";
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public static string[] GetParamFromSQL(string SQL)
|
|
|
- {
|
|
|
- string[] par = SQL.Split(':');
|
|
|
- //用来存参数的数组
|
|
|
- StringBuilder[] addpar = new StringBuilder[par.Length - 1];
|
|
|
- string[] param = new string[par.Length - 1];
|
|
|
- for (int i = 0; i < par.Length - 1; i++)
|
|
|
- {
|
|
|
- //新建一个char类型的数组用来存储每个字节的变量
|
|
|
- char[] c = par[i + 1].ToCharArray();
|
|
|
- addpar[i] = new StringBuilder();
|
|
|
- for (int j = 0; j < c.Length; j++)
|
|
|
- {
|
|
|
- if (c[j] != ' ' && c[j] != ',' && c[j] != ')')
|
|
|
- {
|
|
|
- addpar[i].Append(c[j]);
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- break;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- for (int i = 0; i < par.Length - 1; i++)
|
|
|
- {
|
|
|
- param[i] = addpar[i].ToString();
|
|
|
- }
|
|
|
- return param;
|
|
|
- }
|
|
|
-
|
|
|
- private void Reconnect(OracleCommand cmd)
|
|
|
- {
|
|
|
- if (cmd.Connection.State == ConnectionState.Closed)
|
|
|
- {
|
|
|
- cmd.Connection.Open();
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
章政