labelmanage.cs

动易SiteFactory&#8482 网上商店系统1.0源代码

namespace PowerEasy.SqlServerDal.TemplateProc
{
    using Microsoft.Practices.EnterpriseLibrary.Data;
    using PowerEasy.Enumerations;
    using PowerEasy.IDal.TemplateProc;
    using PowerEasy.SqlServerDal;
    using System;
    using System.Configuration;
    using System.Data;
    using System.Data.Common;
    using System.Data.Odbc;
    using System.Data.OleDb;
    using System.Data.OracleClient;
    using System.Data.SqlClient;
    using System.Text.RegularExpressions;
    using System.Xml;

    public sealed class LabelManage : ILabelManage
    {
        public string GetMainDBQuery(string sqlstr, XmlNodeList attrib, bool dbtype)
        {
            Database database = DatabaseFactory.CreateDatabase();
            try
            {
                DbCommand storedProcCommand;
                if (dbtype)
                {
                    storedProcCommand = database.GetStoredProcCommand(sqlstr);
                    foreach (XmlNode node in attrib)
                    {
                        string[] strArray = node.SelectSingleNode("default").InnerText.Split(new string[] { "|||" }, StringSplitOptions.None);
                        if (strArray.Length > 1)
                        {
                            database.AddInParameter(storedProcCommand, "@" + node.SelectSingleNode("name").InnerText, DbType.String, strArray[0]);
                            continue;
                        }
                        database.AddInParameter(storedProcCommand, "@" + node.SelectSingleNode("name").InnerText, DbType.String, node.SelectSingleNode("default").InnerText);
                    }
                }
                else
                {
                    storedProcCommand = database.GetSqlStringCommand(sqlstr);
                }
                using (DataSet set = database.ExecuteDataSet(storedProcCommand))
                {
                    if (set == null)
                    {
                        return null;
                    }
                    return set.GetXml();
                }
            }
            catch (SqlException)
            {
            }
            return "queryerr";
        }

        public string GetOdbcDBQuery(string dbconn, string sqlstr)
        {
            string xml = string.Empty;
            try
            {
                OdbcConnection selectConnection = new OdbcConnection(dbconn);
                selectConnection.Open();
                if (string.Compare(selectConnection.State.ToString(), "Open", true) == 0)
                {
                    OdbcDataAdapter adapter = new OdbcDataAdapter(sqlstr, selectConnection);
                    DataSet dataSet = new DataSet();
                    adapter.Fill(dataSet);
                    if (dataSet != null)
                    {
                        xml = dataSet.GetXml();
                    }
                    adapter.Dispose();
                }
                selectConnection.Dispose();
            }
            catch (OdbcException)
            {
                xml = "queryerr";
            }
            catch (SystemException)
            {
                xml = "queryerr";
            }
            return xml;
        }

        private static DataTable GetOdbcSchema(string strConn)
        {
            OdbcConnection connection = new OdbcConnection(strConn);
            DataTable schema = new DataTable();
            try
            {
                connection.Open();
                schema = connection.GetSchema("TABLES");
            }
            catch
            {
                schema = null;
            }
            finally
            {
                connection.Close();
            }
            return schema;
        }

        private static DataTable GetOdbcTableField(string myConn, string strSql)
        {
            OdbcConnection connection = new OdbcConnection(myConn);
            if (string.IsNullOrEmpty(strSql))
            {
                return null;
            }
            OdbcCommand command = new OdbcCommand(strSql, connection);
            DataTable schemaTable = new DataTable();
            try
            {
                connection.Open();
                schemaTable = command.ExecuteReader(CommandBehavior.SchemaOnly).GetSchemaTable();
            }
            catch (OdbcException)
            {
                schemaTable = null;
            }
            finally
            {
                connection.Close();
            }
            return schemaTable;
        }

        public string GetOleDBQuery(string dbconn, string sqlstr)
        {
            string xml = string.Empty;
            try
            {
                OleDbConnection selectConnection = new OleDbConnection(dbconn);
                selectConnection.Open();
                if (string.Compare(selectConnection.State.ToString(), "Open", true) == 0)
                {
                    OleDbDataAdapter adapter = new OleDbDataAdapter(sqlstr, selectConnection);
                    DataSet dataSet = new DataSet();
                    adapter.Fill(dataSet);
                    if (dataSet != null)
                    {
                        xml = dataSet.GetXml();
                    }
                    adapter.Dispose();
                }
                selectConnection.Dispose();
            }
            catch (OleDbException)
            {
                xml = "queryerr";
            }
            catch (SystemException)
            {
                xml = "queryerr";
            }
            return xml;
        }

        private static DataTable GetOleSchema(string strConn)
        {
            OleDbConnection connection = new OleDbConnection(strConn);
            DataTable schema = new DataTable();
            try
            {
                connection.Open();
                schema = connection.GetSchema("TABLES");
            }
            catch
            {
                schema = null;
            }
            finally
            {
                connection.Close();
            }
            return schema;
        }

        private static DataTable GetOleTableField(string myConn, string strSql)
        {
            OleDbConnection connection = new OleDbConnection(myConn);
            if (string.IsNullOrEmpty(strSql))
            {
                return null;
            }
            OleDbCommand command = new OleDbCommand(strSql, connection);
            DataTable schemaTable = new DataTable();
            try
            {
                connection.Open();
                schemaTable = command.ExecuteReader(CommandBehavior.SchemaOnly).GetSchemaTable();
            }
            catch (OleDbException)
            {
                schemaTable = null;
            }
            finally
            {
                connection.Close();
            }
            return schemaTable;
        }

        public string GetOracleDBQuery(string dbconn, string sqlstr)
        {
            string xml = string.Empty;
            try
            {
                OracleConnection selectConnection = new OracleConnection(dbconn);
                selectConnection.Open();
                if (string.Compare(selectConnection.State.ToString(), "Open", true) == 0)
                {
                    OracleDataAdapter adapter = new OracleDataAdapter(sqlstr, selectConnection);
                    DataSet dataSet = new DataSet();
                    adapter.Fill(dataSet);
                    if (dataSet != null)
                    {
                        xml = dataSet.GetXml();
                    }
                    adapter.Dispose();
                }
                selectConnection.Dispose();
            }
            catch (OracleException)
            {
                xml = "queryerr";
            }
            catch (SystemException)
            {
                xml = "queryerr";
            }
            return xml;
        }

        private static DataTable GetOracleSchema(string strConn)
        {
            OracleConnection connection = new OracleConnection(strConn);
            DataTable schema = new DataTable();
            try
            {
                connection.Open();
                schema = connection.GetSchema("TABLES");
            }
            catch
            {
                schema = null;
            }
            finally
            {
                connection.Close();