数据库自动建表

【实例截图】

【核心代码】

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Threading;

namespace 自动建表
{
    public partial class Form1 : Form
    {
        /// <summary>
        /// 委托--设置进度条
        /// </summary>
        /// <param name="value"></param>
        delegate void SetProgressCallback(int value);
        public Form1()
        {
            InitializeComponent();
        }

        private void button_browse_Click(object sender, EventArgs e)
        {
            OpenFileDialog openFile = new OpenFileDialog();//打开文件对话框。  
            openFile.Filter = ("Word 97-2003文档(*.doc)|*.doc|Word 文档(*.docx)|*.docx");//后缀名。  
            openFile.CheckFileExists = true;  //验证文件有效性
            openFile.CheckPathExists = true; //验证路径有效性           
            if (openFile.ShowDialog() == DialogResult.OK)
            {
                textBox1.Text = openFile.FileName;
            }
        }

        private void button_OK_Click(object sender, EventArgs e)
        {
            Thread ThreadCreateTables = new Thread(CreateTables);
            ThreadCreateTables.Start();
        }
        private void CreateTables()
        {
            SetProgress(0);
            //连接oracle数据库
            //string Username = "system";
            //string Datasource = "orcldzy";
            //string Password = "dzy4072";
            //string connstr = "User ID="   Username   ";Password="   Password   ";Data Source=(DESCRIPTION = (ADDRESS_LIST= (ADDRESS = (PROTOCOL = TCP)(HOST = 10.4.146.5)(PORT = 1521))) (CONNECT_DATA =(SERVICE_NAME = orcldzy)))";
            string Username = "system";
            string Datasource = "orclcc";
            string Password = "orclcc";
            string connstr = "User ID="   Username   ";Password="   Password   ";Data Source=(DESCRIPTION = (ADDRESS_LIST= (ADDRESS = (PROTOCOL = TCP)(HOST = 10.4.146.169)(PORT = 1521))) (CONNECT_DATA =(SERVICE_NAME = orclcc)))";
            
            OracleDBOperator OracleDBOperator1 = new OracleDBOperator(connstr);
            OracleDBOperator1.TestDataBase();
            OracleDBOperator1.Close();
            WordOperator.WordTableRead word = new WordOperator.WordTableRead(textBox1.Text);
            // 打开文档,获取设计表
            word.Open();
            DataSet ds=word.getdatatables();
            //word.Close();
            SetProgress(10);
            //创建表
            foreach(DataTable dt in ds.Tables)
            {
                string sql_createtable = "create table " dt.TableName "(";
                foreach(DataRow dr in dt.Rows)
                {
                    if (dr[5].ToString() == "Y")
                    {

                        sql_createtable  = dr[1].ToString()   " "   dr[2].ToString()   " primary key,";
                        continue;
                    }
                    else if (dr[3].ToString() == "N")
                    {
                        sql_createtable  = dr[1].ToString()   " "   dr[2].ToString()   " NOT NULL, ";
                    }
                    else
                    {
                        sql_createtable  = dr[1].ToString()   " "   dr[2].ToString() ", ";//1-字段标识；2-类型长度；3-有无空值；4-计量单位；5-主键
                    }
                   
                }
                string sql_createtable1 = sql_createtable.Remove(sql_createtable.Length - 2,1) ")";
                //sql_createtable1 = "create table RZZ1(DZID VARCHAR2(100) primary key,SNUM CHAR(50), NAME_A CHAR(50), DESC_LOC CHAR(20), DIP_SN NUMBER(5,2), DIPANG_S NUMBER(4,2), L_BO NUMBER(5,1), BOFU NUMBER(5,1), XT_ZZ CHAR(20), YJJ NUMBER(4,2), DIP_Z NUMBER(5,2), DIPANG_Z NUMBER(4,2), DIP_A NUMBER(5,2), DIPANG_A NUMBER(4,2), STRA_A CHAR(20), DIP_B NUMBER(5,2), DIPANG_B NUMBER(4,2), STRA_B CHAR(20), CHANGE_C CHAR(20), DESCRB VARCHAR2(100), RMK VARCHAR2(255) )";
                OracleDBOperator1.ExeSql(sql_createtable1);
            }
            SetProgress(100);
            MessageBox.Show("创建表完成!");
            SetProgress(0);
        }
        private void SetProgress(int val)
        {
            if (val < 0)
            {
                val = 0;
            }

            if (val > 100)
            {
                val = 100;
            }

            if (this.progressBar1.InvokeRequired)
            {
                SetProgressCallback d = new SetProgressCallback(SetProgress);
                this.Invoke(d, new object[] { val });
            }
            else
            {
                this.progressBar1.Value = val;
            }
        }
    }
}