SQLite C#实现操作

远行的心

　　debug command
　　C:\1.db

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.SQLite;
using System.IO;
namespace CSharpConnectionSQLLite
{
class Dao
{
/// <summary>
///
/// </summary>
/// <param name="dbDirectory"></param>
/// <returns></returns>
public SQLiteConnection GetConnection(string dbDirectory)
{
if (!File.Exists(dbDirectory))
{
SQLiteConnection.CreateFile(dbDirectory);
}
SQLiteConnectionStringBuilder connStr = new SQLiteConnectionStringBuilder();
connStr.DataSource = dbDirectory;
connStr.Pooling = true;
connStr.FailIfMissing = true;
SQLiteConnection conn = new SQLiteConnection(connStr.ToString());
return conn;
}
/// <summary>
///
/// </summary>
/// <param name="conn"></param>
public void CloseConnection(SQLiteConnection conn)
{
if(conn!= null)
{
conn.Close();
}
}
/// <summary>
///
/// </summary>
/// <param name="createTableSQL"></param>
/// <param name="conn"></param>
public void CreateTable(string createTableSQL,SQLiteConnection conn)
{
SQLiteCommand cmd = new SQLiteCommand();
cmd.CommandText = createTableSQL;
cmd.Connection = conn;
cmd.ExecuteNonQuery();
}
/// <summary>
///
/// </summary>
/// <param name="insertSQL"></param>
/// <param name="conn"></param>
public void InsertIntoValue(string insertSQL , SQLiteConnection conn)
{
SQLiteCommand cmd = new SQLiteCommand();
cmd.CommandText = insertSQL;
cmd.Connection = conn;
cmd.ExecuteNonQuery();
}
/// <summary>
///
/// </summary>
/// <param name="querySQL"></param>
/// <param name="conn"></param>
/// <returns></returns>
public SQLiteDataReader GetTableValue(string querySQL, SQLiteConnection conn)
{
SQLiteCommand cmd = new SQLiteCommand();
cmd.CommandText = querySQL;
cmd.Connection = conn;
SQLiteDataReader reader = cmd.ExecuteReader();
return reader;
}
}
}

 
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.SQLite;
namespace CSharpConnectionSQLLite
{
class Program
{
private static SQLiteConnection conn = null;
private static string sql = "CREATE TABLE test(username varchar(20),password varchar(20))";
private static string insertintosql = "INSERT INTO test VALUES('myuser','mypassword')";
private static string querySql = "SELECT * FROM test";
static void Main(string[] args)
{
Dao dao = new Dao();
try
{
conn = dao.GetConnection(args[0]);
conn.Open();
conn.CreateCommand();
Console.WriteLine("Success");
//dao.CreateTable(sql, conn);
dao.InsertIntoValue(insertintosql,conn);
SQLiteDataReader reader = dao.GetTableValue(querySql, conn);
while(reader.Read())
{
Console.Write(reader.GetString(0));
Console.Write("\t");
Console.WriteLine(reader.GetString(1));
}
}
catch(Exception)
{
Console.WriteLine("Failed");
}
finally
{
dao.CloseConnection(conn);
}
Console.ReadKey();
}
}
}