sqlcemanage.cs.svn-base

串口通信上位机源程序,可以修改串口,波特率,自动保存接收的数据.方便修改成个性化的串口通信工具

using System;
using System.Data;
using System.IO;
using System.Data.SqlServerCe;
using System.Windows.Forms;

namespace GuangMa
{
	/// <summary>
	/// 该类别的SqlCe数据库管理类，该类别的所有方法都是静态方法。
	/// </summary>
	public class SqlCeManage
	{
		/// <summary>
		/// 创建SQLCE数据库，成功返回 true，失败返回 false。
		/// </summary>
		/// <param name="DatabaseName"></param>
		/// <returns></returns>
		public static bool CreateDatabase(string DatabaseName)
		{
			//判断数据库文件是否已经存在
			if (File.Exists(DatabaseName)) return false;

			try
			{
				SqlCeEngine engine = new SqlCeEngine("data source=" + DatabaseName);	
				engine.CreateDatabase();
			}
			catch
			{
				MessageBox.Show("创建数据库失败！");
				return false;
			}
			return true;
		}
		

		//******************初始化数据库的名称及路径***********//
		public static string DatabaseName = @"采集器数据库.sdf";
		
		//******************初始化数据库**********************//
		public static void InitialDatabase()
		{
			SqlCeConnection conn = new SqlCeConnection ("Data Source=" + SqlCeManage.DatabaseName);
			
			if (SqlCeManage.CreateDatabase(SqlCeManage.DatabaseName))
			{	
				try
				{
					conn.Open();   //打开数据连接
					string sql;
					SqlCeCommand cmd = conn.CreateCommand();

					//************在数据库中建立“基本资料”表*****//
					sql = @"CREATE TABLE 基本资料(资产编号 nvarchar(20)," + 
												 "资产名称 nvarchar(50)," +
												 "规格型号 nvarchar(50)," +
												 "使用部门 nvarchar(20)," +
												 "购置日期 nvarchar(10)," +
												 "安装存放地 nvarchar(20)," +
												 "责任人 nvarchar(10)," +
												 "设备状态 nvarchar(3)," +
												 "使用状况 nvarchar(3))";

					
					cmd.CommandText = sql;
					cmd.ExecuteNonQuery();
					//建立索引字段
					sql = @"CREATE INDEX 资产编号索引 ON 基本资料(资产编号)";
					cmd.CommandText = sql;
					cmd.ExecuteNonQuery();

					//************在数据库中建立“盘查资料表”表*****//
					sql = @"CREATE TABLE 盘查资料表(资产编号 nvarchar(20),盘查日期 nvarchar(10))";
					cmd.CommandText = sql;
					cmd.ExecuteNonQuery();
					//建立索引字段
					sql = @"CREATE INDEX 资产编号索引 ON 盘查资料表(资产编号)";
					cmd.CommandText = sql;
					cmd.ExecuteNonQuery();

					cmd.Dispose();
					conn.Close();  //关闭数据连接
					conn.Dispose();
				}
				catch
				{
					MessageBox.Show("数据库初始化失败！");
					Application.Exit();
				}
			}
		}

	}
}