基于ArcGIS10.0和Oracle10g的空间数据管理平台十四（C#开发）元数据库库管理

我的新浪微博：http://weibo.com/freshairbrucewoo。

欢迎大家相互交流，共同提高技术。

    由于前段时间工作很忙而且出差去了北京一个多月，所以很久没有介绍了关于基于ArcGIS10.0和Oracle10g的空间数据管理平台这个项目的相关功能实现了，今天开始介绍一个新的功能实现，就是元数据库的管理。

    所谓元数据就是描述数据的数据，元数据库就是存放描述数据的数据。元数据主要用于描述数据的特征等的数据，在很多场合下都会遇到元数据，例如文件系统里面有。这里介绍的元数据主要是指描述空间数据特征的元数据，例如属于哪一类数据等。

    今天由于时间关系就简单介绍一下元数据库管理的实现。

1.初始化显示元数据库信息的头部信息

        /// <summary>
        /// 初始化datagridView的头部显示信息
        /// </summary>
        private void InitDataGridView()
        {
            //dataGridViewX1.Rows.Clear();
            SqlHelper sh = new SqlHelper();
            string sql = "select id,name,description from jcsjk_databaseinfo";
            DataSet ds = sh.ReturnDataSet(sql, "jcsjk_databaseinfo");
            dataGridViewX1.DataSource = ds.Tables[0];

            dataGridViewX1.Columns[0].HeaderText = "元数据库ID";
            dataGridViewX1.Columns[0].Width = 200;
            dataGridViewX1.Columns[1].HeaderText = "元数据库名称";
            dataGridViewX1.Columns[1].Width = 200;

            dataGridViewX1.Columns[2].HeaderText = "元数据库描述信息";
            dataGridViewX1.Columns[2].Width = 200;

        }

2.删除元数据库

       /// <summary>
        /// 删除元数据库
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void delMetaDatabaseBtn_Click(object sender, EventArgs e)
        {
            //1.删除所有表
            if (dataGridViewX1.CurrentRow.Index < 0)
            {
                MessageBox.Show("请选择需要删除的数据库那一行");
                return;
            }
            string strDatabaseName = dataGridViewX1.Rows[dataGridViewX1.CurrentRow.Index].Cells[1].Value.ToString();
            SqlHelper sh = new SqlHelper();
            string sql = "select table_name from user_tables where table_name like '" +
                strDatabaseName.ToUpper() + "/_%' ESCAPE '/'";
            OracleDataReader odr = sh.ReturnDataReader(sql);

            while (odr.Read())
            {
                //删除关联外键
                string strTemp = odr[0].ToString().ToUpper();
                strTemp = strTemp.Substring(strDatabaseName.Length + 1);
                sql = "select table_name,constraint_name from user_constraints where constraint_type='R'"
                    + " and constraint_name like '" + strTemp + "%'";
                OracleDataReader odr1 = sh.ReturnDataReader(sql);

                while (odr1.Read())
                {
                    sql = "ALTER TABLE " + odr1[0].ToString().ToUpper() + " DROP CONSTRAINT "
                        + odr1[1].ToString().ToUpper();
                    sh.ExecuteSQL(sql);
                }
                sql = "drop table " + odr[0].ToString().ToUpper();
                sh.ExecuteSQL(sql);
            }
            //2.删除记录
            Hashtable ht = new Hashtable();
            ht.Add("name", strDatabaseName);
            try
            {
                sh.Del("jcsjk_databaseinfo", "name='" + strDatabaseName + "'", ht);
            }
            catch (Exception)
            {
                LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                "删除元数据库<" + strDatabaseName + ">失败!");
                MessageBox.Show("删除元数据库<" + strDatabaseName + ">失败!");
            }

            LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                "删除元数据库<" + strDatabaseName + ">成功!");
            MessageBox.Show("删除元数据库<" + strDatabaseName + ">成功!");
        }

 

3.清空元数据库

       /// <summary>
        /// 清空元数据库中的数据
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void clearMetaDataBtn_Click(object sender, EventArgs e)
        {
            if (dataGridViewX1.CurrentRow.Index < 0)
            {
                MessageBox.Show("选择数据库！");
                return;
            }
            SqlHelper sh = new SqlHelper();
            string strDatabaseName = dataGridViewX1.CurrentRow.Cells[1].Value.ToString();
            //NewDataSet nds = new NewDataSet();
            string sql = string.Empty;
            sql = "select table_name from user_tables where table_name like '" +
                strDatabaseName.ToUpper() + "/_%' ESCAPE '/'";
            OracleDataReader odr = sh.ReturnDataReader(sql);

            while (odr.Read())
            {
                sql = "delete from " + odr[0].ToString().ToUpper();
                try
                {
                    sh.ExecuteSQL(sql);
                }
                catch (Exception)
                {
                    LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                            "清空元数据库<" + strDatabaseName + ">的数据失败!");
                    MessageBox.Show("清空元数据库<" + strDatabaseName + ">的数据失败!");
                    return;
                }
            }
            LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
               "清空元数据库<" + strDatabaseName + ">的数据成功!");
            MessageBox.Show("清空元数据库<" + strDatabaseName + ">的数据成功!");
            /*
            foreach (DataTable dt in nds.Tables)
            {
                    string strTableName = strDatabaseName + "_" + dt.TableName;
                    sql = "select * from " + strTableName;
                    DataSet ds = new DataSet();

                    OracleDataAdapter oda = new OracleDataAdapter(sql,
                        ConfigurationSettings.AppSettings["ConnectionString"]);
                    try
                    {
                        oda.Fill(ds);
                        oda.Update(dt);
                    }
                    catch (Exception ex)
                    {
                        LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                            "清空元数据库<" + strDatabaseName + ">的数据失败!");
                        MessageBox.Show("清空元数据库<" + strDatabaseName + ">的数据失败!");
                    }
            }
            LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
               "清空元数据库<" + strDatabaseName + ">的数据成功!");
            MessageBox.Show("清空元数据库<" + strDatabaseName + ">的数据成功!");
             * */
        }

    清空元数据库与删除元数据库是不同的功能，删除元数据库就是把存放元数据的库都一起删除了，但是清空元数据库只是把库里面的内容删除，库本身存在。

4.创建元数据库

    这是比较复杂的一个功能，因为创建一个元数据库需要根据一定的标准来创建，这些标准都是通过xsd文件描述的，所以首先要解析这个xml的模式描述文件，然后根据解析的内容存放到相应的字段中去，具体实现如下：

        private void createBtn_Click(object sender, EventArgs e)
        {
            SqlHelper sh = new SqlHelper();
            string sql = string.Empty;

            if (databaseIDTxt.Text.Trim() == "" || databaseNameTxt.Text.Trim() == "")
            {
                errTxt.Text = "数据库ID或名称不能为空.";
                return;
            }

            //查看元数据库是否存在
            sql = "select * from jcsjk_databaseinfo where name='" + databaseNameTxt.Text + "'";

            if (sh.GetRecordCount(sql) > 0)
            {
                MessageBox.Show("此元数据库已经存在,请从新命名元数据库!");
                return;
            }

            Hashtable ht = new Hashtable();
            string strContent = string.Empty;
            DataSet ds = new DataSet();
            //从文件标准创建
            if (!checkBoxX1.Checked)
            {
                if (metaFileTxt.Text == "" || Path.GetExtension(metaFileTxt.Text).ToLower() != ".xsd")
                {
                    errTxt.Text = "请选择正确的XSD文件.";
                    return;
                }
                if (metaIDTxt.Text.Trim() == "")
                {
                    errTxt.Text = "元数据标准ID不能为空.";
                    return;
                }

                //1.读入xsd文件
                ds.ReadXmlSchema(metaFileTxt.Text);
                
                //2.create table in tablespace
                try
                {
                    OracleDataSchemaAdapter odsa = new OracleDataSchemaAdapter();
                    odsa.Create(ds, true, databaseNameTxt.Text + "_", "SDE");
                }
                catch (ArgumentException ae)
                {
                    LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                            "创建元数据库<" + databaseNameTxt.Text + ">失败!");
                    MessageBox.Show("-- Error --" + ae.Message + "-- Instructions --");
                }
                catch (FileNotFoundException)
                {
                    LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                            "创建元数据库<" + databaseNameTxt.Text + ">失败!");
                    MessageBox.Show("File not found: " + metaFileTxt.Text);
                }
                catch (Exception)
                {
                    LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                            "创建元数据库<" + databaseNameTxt.Text + ">失败!");
                    MessageBox.Show("创建元数据库<" + databaseNameTxt.Text + ">失败!");
                }

                //写入元数据标准到数据库
                StreamReader sr = new StreamReader(new FileStream(metaFileTxt.Text, FileMode.Open),
                    System.Text.Encoding.GetEncoding("GB2312"));

                while (!sr.EndOfStream)
                {
                    strContent += sr.ReadLine();
                }
                sr.Close();
                string strName = Path.GetFileNameWithoutExtension(metaFileTxt.Text);
                //
                sql = "select * from jcsjk_databaseinfo where name='" + strName + "'";
                if (sh.GetRecordCount(sql) <= 0)
                {
                    XmlDocument xmlDoc = new XmlDocument();
                    xmlDoc.Load(metaFileTxt.Text);
                    XmlNodeList xnl = xmlDoc.GetElementsByTagName("xs:schema");
                    XmlNode xn = xnl[0];
                    //插入元数据标准到数据库中，用参数才能插入，因为content字段内容太大
                    sql = "insert into jcsjk_metastand (id, name, content, org, version) values("
                        + ":id,:name,:content,:org,:version)";
                    OracleParameter[] op = new OracleParameter[5];
                    op[0] = new OracleParameter();
                    op[0].ParameterName = "id";
                    op[0].OracleType = OracleType.NVarChar;
                    op[0].Value = metaIDTxt.Text;
                    op[1] = new OracleParameter();
                    op[1].ParameterName = "name";
                    op[1].OracleType = OracleType.NVarChar;

                    string strValue = xn.ChildNodes[0].ChildNodes[1].InnerText;
                    
                    strValue = strValue.Substring(strValue.IndexOf('：') + 1);
                    op[1].Value = strValue;
                    op[2] = new OracleParameter();
                    op[2].ParameterName = "content";
                    op[2].OracleType = OracleType.Clob;
                    op[2].Value = strContent;
                    strValue = xn.ChildNodes[0].ChildNodes[2].InnerText;
                    strValue = strValue.Substring(strValue.IndexOf('：') + 1);
                    op[3] = new OracleParameter();
                    op[3].ParameterName = "org";
                    op[3].OracleType = OracleType.NVarChar;
                    op[3].Value = strValue;
                    strValue = xn.ChildNodes[0].ChildNodes[0].InnerText;
                    strValue = strValue.Substring(strValue.IndexOf('：') + 1);
                    op[4] = new OracleParameter();
                    op[4].ParameterName = "version";
                    op[4].OracleType = OracleType.NVarChar;
                    op[4].Value = strValue;
                    try
                    {
                        sh.ExecuteNonQuery(sql, op);
                    }
                    catch (Exception ex)
                    {
                        LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                            "写入元数据标准<" + strName + ">到数据库失败!");
                        MessageBox.Show("写入元数据标准<<" + strName + ">到数据库失败!");
                    }
                }
            }
            //从数据库以存储的标准创建
            else
            {
                string strStandName = comboBoxEx1.SelectedItem.ToString();

                sql = "select content from jcsjk_metastand where name='" + strStandName + "'";
                OracleDataReader odr = sh.ReturnDataReader(sql);
                if (odr.Read())
                {
                    StreamWriter bw = new StreamWriter(new FileStream("temp.xsd", FileMode.Create),
                        System.Text.Encoding.GetEncoding("GB2312"));

                    bw.Write(odr[0].ToString());

                    bw.Close();
                    ds.ReadXmlSchema("temp.xsd");
                    System.IO.File.Delete("temp.xsd");
                    try
                    {
                        OracleDataSchemaAdapter odsa = new OracleDataSchemaAdapter();
                        odsa.Create(ds, true, databaseNameTxt.Text + "_", "SDE");
                    }
                    catch (ArgumentException ae)
                    {
                        LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                                "创建元数据库<" + databaseNameTxt.Text + ">失败!");
                        MessageBox.Show("-- Error --" + ae.Message + "-- Instructions --");
                    }
                    catch (FileNotFoundException)
                    {
                        LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                                "创建元数据库<" + databaseNameTxt.Text + ">失败!");
                        MessageBox.Show("File not found: " + metaFileTxt.Text);
                    }
                    catch (Exception)
                    {
                        LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                                "创建元数据库<" + databaseNameTxt.Text + ">失败!");
                        MessageBox.Show("创建元数据库<" + databaseNameTxt.Text + ">失败!");
                    }
                }
                
            }

            //插入元数据库信息到数据库
            sql = "select * from jcsjk_databaseinfo where name='" + databaseNameTxt.Text + "'";
            if (sh.GetRecordCount(sql) <= 0)
            {
                ht.Clear();
                ht.Add("ID", databaseIDTxt.Text);
                ht.Add("NAME", databaseNameTxt.Text);
                if (descriptionText.Text != "")
                {
                    ht.Add("DESCRIPTION", descriptionText.Text);
                }
                try
                {
                    sh.Insert("jcsjk_databaseinfo", ht);
                }
                catch (Exception)
                {
                    LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                        "插入元数据库<" + databaseNameTxt.Text + ">信息到数据库失败!");
                    MessageBox.Show("插入元数据库<<" + databaseNameTxt.Text + ">信息到数据库失败!");
                }
            }

            LogHelp.writeLog(FrmMain.metaUsername, "元数据库管理",
                       "创建元数据库<" + databaseNameTxt.Text + ">成功!");
            MessageBox.Show("创建元数据库<" + databaseNameTxt.Text + ">成功!");
            Close();
        }

    到此元数据库的管理基本内容已经介绍完毕。