美文网首页
2.C#操作SQLite数据库

2.C#操作SQLite数据库

作者: 马洪滔 | 来源:发表于2019-03-01 10:07 被阅读0次

    1、SQLite介绍
    SQLite is a software library that implements a self-contained, serverless, zeroconfiguration,
    transactional SQL database engine.
    如果想了解更多关于SQLite的问题,可以访问它的官方网站:https://www.sqlite.org/index.html
    2、C#操作SQLite Database
    我们在开发应用是经常会需要用到一些数据的存储,存储的方式有多种,使用数据库是一种比较受大家欢迎的方式。但是对于一些小型的应用,如一些移动APP,通常的数据库过于庞大,而轻便的SQLite则能解决这一问题。不但操作方便,而且只需要要一个文件即可,在这里我们来说一说使用C#语言操作SQLite数据库。
    3、使用前的准备
    在开始之前我们需要准备必要的开发环境,这次咱们使用的是Visual Studio 2010开发环境,但是我们开发基于SQLite的应用光有VS2010还不够。我需要到SQLite的官方网站下载并安装SQLite。
    在SQLite官网找到下载,有应用于各种环境的SQLite组件及源码,我们选择Precompiled Binaries for .NET,这是应用于.NET开发环境的,点击进入会看到应用于.NET2.0直至4.6以及32位和64位平台的各个版本。我们选择Setups for 32-bit Windows (.NET Framework 4.6)下载安装即可。
    4、C#操作SQLite的封装
    在完成开发环境的准备之后,我们接下来实现对SQLite操作的必要封装,以进一步降低在具体应用中的使用难度。在这里我们只是封装一些常用而且必要的功能。

    public class SQLiteHelper
        {
            //创建数据库文件
            public static void CreateDBFile(string fileName)
            {
                string path = System.Environment.CurrentDirectory + @"/Data/";
                if (!Directory.Exists(path))
                {
                    Directory.CreateDirectory(path);
                }
                string databaseFileName = path + fileName;
                if (!File.Exists(databaseFileName))
                {
                    SQLiteConnection.CreateFile(databaseFileName);
                }
            }
     
            //生成连接字符串
             private static string CreateConnectionString()
            {
                SQLiteConnectionStringBuilder connectionString = new SQLiteConnectionStringBuilder();
                connectionString.DataSource = @"data/ScriptHelper.db";
     
                string conStr = connectionString.ToString();
                return conStr;
            }
     
            /// <summary>
            /// 对插入到数据库中的空值进行处理
            /// </summary>
            /// <param name="value"></param>
            /// <returns></returns>
            public static object ToDbValue(object value)
            {
                if (value == null)
                {
                    return DBNull.Value;
                }
                else
                {
                    return value;
                }
            }
     
            /// <summary>
            /// 对从数据库中读取的空值进行处理
            /// </summary>
            /// <param name="value"></param>
            /// <returns></returns>
            public static object FromDbValue(object value)
            {
                if (value == DBNull.Value)
                {
                    return null;
                }
                else
                {
                    return value;
                }
            }
     
            /// <summary>
            /// 执行非查询的数据库操作
            /// </summary>
            /// <param name="sqlString">要执行的sql语句</param>
            /// <param name="parameters">参数列表</param>
            /// <returns>返回受影响的条数</returns>
            public static int ExecuteNonQuery(string sqlString, params SQLiteParameter[] parameters)
            {
                string connectionString=CreateConnectionString();
                using (SQLiteConnection conn = new SQLiteConnection(connectionString))
                {
                    conn.Open();
                    using (SQLiteCommand cmd = conn.CreateCommand())
                    {
                        cmd.CommandText = sqlString;
                        foreach (SQLiteParameter parameter in parameters)
                        {
                            cmd.Parameters.Add(parameter);
                        }
                        return cmd.ExecuteNonQuery();
                    }
                }
            }
     
            /// <summary>
            /// 执行查询并返回查询结果第一行第一列
            /// </summary>
            /// <param name="sqlString">SQL语句</param>
            /// <param name="sqlparams">参数列表</param>
            /// <returns></returns>
            public static object ExecuteScalar(string sqlString, params SQLiteParameter[] parameters)
            {
                string connectionString = CreateConnectionString();
                using (SQLiteConnection conn = new SQLiteConnection(connectionString))
                {
                    conn.Open();
                    using (SQLiteCommand cmd = conn.CreateCommand())
                    {
                        cmd.CommandText = sqlString;
                        foreach (SQLiteParameter parameter in parameters)
                        {
                            cmd.Parameters.Add(parameter);
                        }
                        return cmd.ExecuteScalar();
                    }
                }
            }
     
            /// <summary>
            /// 查询多条数据
            /// </summary>
            /// <param name="sqlString">SQL语句</param>
            /// <param name="parameters">参数列表</param>
            /// <returns>返回查询的数据表</returns>
            public static DataTable GetDataTable(string sqlString,params SQLiteParameter[] parameters)
            {
                string connectionString = CreateConnectionString();
                using (SQLiteConnection conn = new SQLiteConnection(connectionString))
                {
                    conn.Open();
                    using (SQLiteCommand cmd = conn.CreateCommand())
                    {
                        cmd.CommandText = sqlString;
                        foreach (SQLiteParameter parameter in parameters)
                        {
                            cmd.Parameters.Add(parameter);
                        }
                        DataSet ds = new DataSet();
                        SQLiteDataAdapter adapter = new SQLiteDataAdapter(cmd);
                        adapter.Fill(ds);
                        return ds.Tables[0];
                    }
                }
            }
        }
    

    相关文章

      网友评论

          本文标题:2.C#操作SQLite数据库

          本文链接:https://www.haomeiwen.com/subject/kckkyqtx.html