labelmanage.cs

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

            }
            return schema;
        }

        private static DataTable GetOracleTableField(string myConn, string strSql)
        {
            OracleConnection connection = new OracleConnection(myConn);
            if (string.IsNullOrEmpty(strSql))
            {
                return null;
            }
            OracleCommand command = new OracleCommand(strSql, connection);
            DataTable schemaTable = new DataTable();
            try
            {
                connection.Open();
                schemaTable = command.ExecuteReader(CommandBehavior.SchemaOnly).GetSchemaTable();
            }
            catch (OracleException)
            {
                schemaTable = null;
            }
            finally
            {
                connection.Close();
            }
            return schemaTable;
        }

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

        private static DataTable GetOutSqlTableField(string myConn, string strSql)
        {
            SqlConnection connection = new SqlConnection(myConn);
            if (string.IsNullOrEmpty(strSql))
            {
                return null;
            }
            SqlCommand command = new SqlCommand(strSql, connection);
            DataTable schemaTable = new DataTable();
            try
            {
                connection.Open();
                schemaTable = command.ExecuteReader(CommandBehavior.SchemaOnly).GetSchemaTable();
            }
            catch (SqlException)
            {
                schemaTable = null;
            }
            finally
            {
                connection.Close();
            }
            return schemaTable;
        }

        public DataTable GetSchemaDataBase(string dbconn, DataSourceType dataSourceType)
        {
            DataTable table = new DataTable();
            switch (dataSourceType)
            {
                case DataSourceType.Ole:
                    return GetOleSchema(dbconn);

                case DataSourceType.Sql:
                    return GetSqlDatabaseSchema(dbconn);

                case DataSourceType.Odbc:
                    return GetOdbcSchema(dbconn);

                case DataSourceType.Oracle:
                    return GetOracleSchema(dbconn);
            }
            return GetSqlDatabaseSchema(ConfigurationManager.ConnectionStrings["Connection String"].ConnectionString);
        }

        public DataTable GetSchemaTable(string tableName, string dbconn, DataSourceType dataSourceType)
        {
            string str;
            if (!string.IsNullOrEmpty(tableName))
            {
                if (Regex.IsMatch(dbconn, "excel", RegexOptions.IgnoreCase))
                {
                    str = "select top 1 * from [" + tableName + "]";
                }
                else
                {
                    str = "select * from " + tableName + " where 1=0";
                }
            }
            else
            {
                str = null;
            }
            DataTable table = new DataTable();
            switch (dataSourceType)
            {
                case DataSourceType.Ole:
                    return GetOleTableField(dbconn, str);

                case DataSourceType.Sql:
                    return GetOutSqlTableField(dbconn, str);

                case DataSourceType.Odbc:
                    return GetOdbcTableField(dbconn, str);

                case DataSourceType.Oracle:
                    return GetOracleTableField(dbconn, str);
            }
            return DBHelper.ExecuteReaderSql(str).GetSchemaTable();
        }

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

        public bool TestOdbc(string dbconn)
        {
            OdbcConnection connection;
            try
            {
                connection = new OdbcConnection(dbconn);
            }
            catch (OdbcException)
            {
                return false;
            }
            connection.Open();
            if (string.Compare(connection.State.ToString(), "Open", true) == 0)
            {
                connection.Close();
                connection.Dispose();
                return true;
            }
            connection.Close();
            connection.Dispose();
            return false;
        }

        public bool TestOle(string dbconn)
        {
            OleDbConnection connection;
            try
            {
                connection = new OleDbConnection(dbconn);
            }
            catch (OleDbException)
            {
                return false;
            }
            connection.Open();
            if (string.Compare(connection.State.ToString(), "Open", true) == 0)
            {
                connection.Close();
                connection.Dispose();
                return true;
            }
            connection.Close();
            connection.Dispose();
            return false;
        }

        public bool TestOracle(string dbconn)
        {
            OracleConnection connection;
            try
            {
                connection = new OracleConnection(dbconn);
            }
            catch (OracleException)
            {
                return false;
            }
            connection.Open();
            if (string.Compare(connection.State.ToString(), "Open", true) == 0)
            {
                connection.Close();
                connection.Dispose();
                return true;
            }
            connection.Close();
            connection.Dispose();
            return false;
        }

        public bool TestOutSql(string dbconn)
        {
            SqlConnection connection;
            try
            {
                connection = new SqlConnection(dbconn);
            }
            catch (SqlException)
            {
                return false;
            }
            connection.Open();
            if (string.Compare(connection.State.ToString(), "Open", true) == 0)
            {
                connection.Close();
                connection.Dispose();
                return true;
            }
            connection.Close();
            connection.Dispose();
            return false;
        }
    }
}