DyeingComputer/UserClass/SqliteHelper.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Data;
using System.IO;
using Microsoft.Data.Sqlite;
using System.Data.Common;
using System.Windows.Media.Animation;
using System.Data.SQLite;
using System.Windows.Shapes;

namespace DyeingComputer.UserClass
{
    public class SqliteHelper
    {

        /// <summary>
        /// 事务的基类
        /// </summary>
        private DbTransaction DBtrans;

        /// <summary>
        /// 数据库地址
        /// </summary>
        private static string dbFile = Environment.CurrentDirectory + "\\DataBase\\800COMPUTER.db";
        /// <summary>
        /// 数据库密码
        /// </summary>
        private readonly string mPassWord;
        private readonly string LockName = null;
        /// <summary>  
        /// 打开一个SQLite数据库文件，如果文件不存在，则创建（无密码）
        /// </summary>  
        /// <param name="dataFile"></param>  
        /// <returns>SQLiteConnection 类</returns>  
        public static SQLiteConnection OpenConnection(string dataFile)
        {
            if (dataFile == null)
            {
                throw new ArgumentNullException("dataFiledataFile=null");
            }
            if (!File.Exists(dataFile))
            {
                SQLiteConnection.CreateFile(dataFile);
                ///工艺程序名
                NewTable(dataFile, "ProgramName","(ProgramName varchar, ProgramID int, Step int, Time varchar, Notes varchar)");
                ///工艺步骤细节
                NewTable(dataFile, "ProgramSteps", 
                    "(Program varchar, Step int, StepID int, StepName varchar, ParameterName varchar, " +
                    "Parameter1 int, Parameter2 int, Parameter3 int, Parameter4 int, Parameter5 int)");
                ///历史
                ///
                ///曲线
                ///
                ///计划
                ///
                ///参数
                ///
                ///输入输出

            }

            SQLiteConnection conn = new SQLiteConnection();
            SQLiteConnectionStringBuilder conStr = new SQLiteConnectionStringBuilder
            {
                DataSource = dataFile
            };
            conn.ConnectionString = conStr.ToString();
            conn.Open();
            return conn;
        }





        public static void Strat()
        {
            OpenConnection(dbFile);
        }


        
          /// <summary>
          /// 创建表
          /// </summary>
          /// <param name="dbPath">指定数据库文件</param>
          /// <param name="tableName">表名称</param>
        static public void NewTable(string dbPath, string tableName ,string dat)
        {
            SQLiteConnection sqliteConn = new SQLiteConnection("data source=" + dbPath);
            if (sqliteConn.State != System.Data.ConnectionState.Open)             
            {
                 sqliteConn.Open();
                 SQLiteCommand cmd = new SQLiteCommand();
                 cmd.Connection = sqliteConn;
                cmd.CommandText = "CREATE TABLE " + tableName + dat;//"(Name varchar,Team varchar, Number varchar)";
                 cmd.ExecuteNonQuery();
             }
             sqliteConn.Close();
         }
    }
}