wince 连接本地数据库(C#)

    技术2022-05-19  20

     using System;        using System.Collections.Generic;        using System.ComponentModel;        using System.Data;        using System.Drawing;        using System.Text;        using System.Windows.Forms;        using System.Data.OleDb;        using System.Data.SqlServerCe;        using System.IO;        namespace ReadSDFFileOnDesktop        {        public partial class MainForm : Form          {            public static string strSQLPath = "DB.sdf";            public static string strConString = "Data Source = " + strSQLPath + "; Password = ";            public static string strAccessString = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=Pub.mdb;";            public MainForm()            {                InitializeComponent();            }            private void buttonCreateDB_Click(object sender, EventArgs e)            {                // 创建数据库                if (File.Exists(strSQLPath))                {                    // 删除数据库                    File.Delete(strSQLPath);                    CreateDataBase();                }                else                {                    // 创建数据库                    CreateDataBase();                }            }            private void CreateDataBase()            {                // 创建数据库文件                SqlCeEngine engine = new SqlCeEngine(strConString);                engine.CreateDatabase();                engine.Dispose();                MessageBox.Show("数据库创建成功!");            }            private void buttonCreateTable_Click(object sender, EventArgs e)            {                if (File.Exists(strSQLPath))                {                    // 创建表                    SqlCeConnection cn = new SqlCeConnection(strConString);                    cn.Open();                    try                    {                        string strSQL = @"CREATE TABLE employee(emp_id nvarchar(9),                        fname nvarchar(20),minit nvarchar(1), lname nvarchar(30),                        job_id nvarchar(8),job_lvl nvarchar(8), pub_id nvarchar(4),                        hire_date datetime)";                        SqlCeCommand SqlCeCmd = new SqlCeCommand(strSQL, cn);                        SqlCeCmd.ExecuteNonQuery();                        MessageBox.Show("数据库中的表创建成功", "提示信息");                    }                    catch (SqlCeException ex)                    {                        MessageBox.Show(ex.Message);                    }                    finally                    {                        cn.Close();                    }                }                else                {                    MessageBox.Show("请先创建数据库!");                }            }            private void buttonImportData_Click(object sender, EventArgs e)            {                // 导入数据                OleDbConnection OleDbCn = new OleDbConnection(strAccessString);                try                {                    OleDbCn.Open();                    OleDbCommand OleDbCmd = new OleDbCommand("SELECT * FROM employee", OleDbCn);                    OleDbDataReader OleDbDr = OleDbCmd.ExecuteReader();                    SqlCeConnection SqlCeCn = new SqlCeConnection(strConString);                    try                    {                        SqlCeCn.Open();                        SqlCeCommand SqlCeCmd = new SqlCeCommand();                        SqlCeCmd.Connection = SqlCeCn;                        while (OleDbDr.Read())                        {                            string strSQL = "";                            strSQL = String.Format("INSERT INTO employee " +                            "(emp_id, fname, minit, lname, job_id, job_lvl, pub_id, hire_date)                            VALUES ('{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}', '{7}')",                            OleDbDr.GetValue(OleDbDr.GetOrdinal("emp_id")),                            OleDbDr.GetValue(OleDbDr.GetOrdinal("fname")),                            OleDbDr.GetValue(OleDbDr.GetOrdinal("minit")),                            OleDbDr.GetValue(OleDbDr.GetOrdinal("lname")),                            OleDbDr.GetValue(OleDbDr.GetOrdinal("job_id")),                            OleDbDr.GetValue(OleDbDr.GetOrdinal("job_lvl")),                            OleDbDr.GetValue(OleDbDr.GetOrdinal("pub_id")),                            OleDbDr.GetValue(OleDbDr.GetOrdinal("hire_date")));                            SqlCeCmd.CommandText = strSQL;                            SqlCeCmd.ExecuteNonQuery();                        }                        MessageBox.Show("数据导入成功!");                    }                    catch (SqlCeException ex)                    {                        MessageBox.Show(ex.Message);                    }                    finally                    {                        SqlCeCn.Close();                    }                }                catch (OleDbException ex)                {                    MessageBox.Show(ex.Message);                }                finally                {                    OleDbCn.Close();                }            }            private void buttonShowData_Click(object sender, EventArgs e)            {                // 显示数据                SqlCeConnection SqlCeCn = new SqlCeConnection(strConString);                try                {                    SqlCeCn.Open();                    string strSQL = "";                    strSQL = String.Format("SELECT * FROM employee ");                    SqlCeCommand SqlCeCmd = new SqlCeCommand(strSQL, SqlCeCn);                    SqlCeDataReader SqlCeDr = SqlCeCmd.ExecuteReader();                    listView1.Items.Clear();                    while (SqlCeDr.Read())                    {                        ListViewItem item;                        item = new ListViewItem(SqlCeDr.GetValue                        (SqlCeDr.GetOrdinal("emp_id")).ToString());                        item.SubItems.Add(SqlCeDr.GetValue(SqlCeDr.                        GetOrdinal("fname")).ToString());                        item.SubItems.Add(SqlCeDr.GetValue(SqlCeDr.                        GetOrdinal("minit")).ToString());                        item.SubItems.Add(SqlCeDr.GetValue(SqlCeDr.                        GetOrdinal("lname")).ToString());                        item.SubItems.Add(SqlCeDr.GetValue(SqlCeDr                        .GetOrdinal("job_id")).ToString());                        item.SubItems.Add(SqlCeDr.GetValue(SqlCeDr.                        GetOrdinal("job_lvl")).ToString());                        item.SubItems.Add(SqlCeDr.GetValue(SqlCeDr.                        GetOrdinal("pub_id")).ToString());                        item.SubItems.Add(SqlCeDr.GetValue(SqlCeDr.                        GetOrdinal("hire_date")).ToString());                        listView1.Items.Add(item);                    }                }                catch (SqlCeException ex)                {                    MessageBox.Show(ex.Message);                }                finally                {                    SqlCeCn.Close();                }            }          }        }


    最新回复(0)