本文整理汇总了C#中Mono.Data.Sqlite.SqliteConnection类的典型用法代码示例。如果您正苦于以下问题：C# SqliteConnection类的具体用法？C# SqliteConnection怎么用？C# SqliteConnection使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SqliteConnection类属于Mono.Data.Sqlite命名空间，在下文中一共展示了SqliteConnection类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的C#代码示例。
示例1: CreateDatabase
public virtual bool CreateDatabase( string sFile, bool bKeepOpen = false )
{
myDatabase = new SqliteConnection();
try {
if( System.IO.File.Exists(sFile) ) {
if( bKeepOpen == true ) {
myDatabase.ConnectionString = "Data Source=" + sFile + ";";
myDatabase.Open();
}
return false;
}
myDatabase.ConnectionString = "Data Source=" + sFile + ";";
myDatabase.Open();
if( bKeepOpen == false ) {
myDatabase.Close();
myDatabase.Dispose();
}
return true;
} catch {
return false;
}
}
开发者ID:Ellorion，项目名称:ClassCollection，代码行数:27，代码来源:CSqlite.cs
示例2: LibraryDatabaseManager
public LibraryDatabaseManager(String dbFolderPath)
{
DatabaseFile = String.Format(dbFolderPath + "{0}Library.db",
Path.DirectorySeparatorChar);
Connection = new SqliteConnection (
"Data Source = " + LibraryDatabaseManager.DatabaseFile +
"; Version = 3;");
bool exists = File.Exists (LibraryDatabaseManager.DatabaseFile);
if (!exists) {
SqliteConnection.CreateFile (LibraryDatabaseManager.DatabaseFile);
}
Connection.Open ();
if (!exists) {
using (SqliteCommand command = new SqliteCommand (Connection)) {
command.CommandText =
"CREATE TABLE Books (" +
"BookID INTEGER PRIMARY KEY NOT NULL, " +
"BookTitle TEXT, " +
"BookAuthor TEXT, " +
"BookGenre TEXT, " +
"BookPublishedYear INTEGER, " +
"BookPath TEXT);";
command.ExecuteNonQuery();
}
}
}
开发者ID:burtonageo，项目名称:Bookling，代码行数:28，代码来源:LibraryDatabaseManager.cs
示例3: Init
public static void Init()
{
try
{
_cards = new Dictionary<int, CardData>();
string currentPath = Assembly.GetExecutingAssembly().Location;
currentPath = Path.GetDirectoryName(currentPath) ?? "";
string absolutePath = Path.Combine(currentPath, "cards.cdb");
if (!File.Exists(absolutePath))
{
throw new Exception("Could not find the cards database.");
}
using (SqliteConnection connection = new SqliteConnection("Data Source=" + absolutePath))
{
connection.Open();
const string select =
"SELECT datas.id, alias, type, level, race, attribute, atk, def, name, desc " +
"FROM datas INNER JOIN texts ON datas.id = texts.id";
using (SqliteCommand command = new SqliteCommand(select, connection))
using (SqliteDataReader reader = command.ExecuteReader())
InitCards(reader);
}
}
catch (Exception ex)
{
throw new Exception("Could not initialize the cards database. Check the inner exception for more details.", ex);
}
}
开发者ID:Tic-Tac-Toc，项目名称:windbot，代码行数:33，代码来源:CardsManager.cs
示例4: ClearItemsBeforeDate
/// <summary>
/// Clears all items from the database where their PublishDate is before the date provided.
/// </summary>
/// <param name="date"></param>
public void ClearItemsBeforeDate(DateTime date)
{
try
{
using (SqliteConnection connection = new SqliteConnection(ItemsConnectionString))
{
connection.Open();
using (SqliteCommand command = new SqliteCommand(connection))
{
string sql = @"DELETE FROM items WHERE DATETIME(publishdate) <= DATETIME(@date)";
command.CommandText = sql;
SqliteParameter parameter = new SqliteParameter("@date", DbType.String);
parameter.Value = date.ToString("yyyy-MM-dd HH:mm:ss");
command.Parameters.Add(parameter);
int rows = command.ExecuteNonQuery();
Logger.Info("ClearItemsBeforeDate before {0} cleared {1} rows.", date.ToString("yyyy-MM-dd HH:mm:ss"), rows);
}
}
}
catch (SqliteException e)
{
Logger.Warn("SqliteException occured while clearing items before {0}: \n{1}", date, e);
}
}
开发者ID:yetanotherchris，项目名称:really-simple，代码行数:30，代码来源:SqliteRepository.cs
示例5: ComboBoxDataSource
public ComboBoxDataSource (SqliteConnection conn, string tableName, string displayField)
{
// Initialize
this.Conn = conn;
this.TableName = tableName;
this.DisplayField = displayField;
}
开发者ID:RangoLee，项目名称:mac-samples，代码行数:7，代码来源:ComboBoxDataSource.cs
示例6: GetAllCategories
/// <summary>
/// Returns all categories.
/// </summary>
public IEnumerable<Category> GetAllCategories()
{
var categories = new List<Category>();
using (var connection = new SqliteConnection("Data Source=" + dbPath))
using (var query = new SqliteCommand("SELECT * FROM Categories", connection))
{
connection.Open();
var reader = query.ExecuteReader(CommandBehavior.CloseConnection);
while (reader.Read())
{
var category = new Category();
category.Id = int.Parse(reader["id"].ToString());
category.Name = reader ["name"].ToString();
categories.Add(category);
}
reader.Close();
}
return categories;
}
开发者ID:CayasSoftware，项目名称:RSSReader，代码行数:28，代码来源:CategoryRepository.cs
示例7: Start
// Use this for initialization
void Start()
{
string conn = "URI=file:" + Application.dataPath + "/sqlite_userinfo";
IDbConnection dbconn = new SqliteConnection(conn);
dbconn.Open();
IDbCommand dbcmd = dbconn.CreateCommand();
string query = "SELECT idx, name, email FROM userinfo";
dbcmd.CommandText = query;
IDataReader reader = dbcmd.ExecuteReader();
while(reader.Read())
{
int idx = reader.GetInt32(0);
string name = reader.GetString(1);
string email = reader.GetString(2);
Debug.Log("idx : " + idx + ", name : " + name + ", email : " + email);
}
reader.Close();
reader = null;
dbcmd.Dispose();
dbcmd = null;
dbconn.Close();
dbconn = null;
}
开发者ID:jiwon8402，项目名称:UnitySqlite，代码行数:29，代码来源:SqliteTest.cs
示例8: ExcuteTransaction
public bool ExcuteTransaction(string sql)
{
var cmds = sql.Split(';');
using (SqliteConnection conn = new SqliteConnection(this.SqlConfig.ConnectionString))
{
conn.Open();
SqliteCommand cmd = new SqliteCommand(conn);
SqliteTransaction tran = conn.BeginTransaction();
try
{
foreach (var cmdSql in cmds)
{
cmd.CommandText = cmdSql;
cmd.ExecuteNonQuery();
}
tran.Commit();
conn.Close();
return true;
}
catch (Exception e)
{
tran.Rollback();
conn.Close();
throw new Exception(e.Message + " sql:" + sql);
}
finally
{
conn.Close();
}
}
}
开发者ID:Jeremaihloo，项目名称:CSharpProject，代码行数:32，代码来源:SQLiteDriver.cs
示例9: CreateDataBase
public void CreateDataBase(string dbPath, string pwd)
{
if (!File.Exists(dbPath))
{
SqliteConnection.CreateFile(dbPath);
if (string.IsNullOrEmpty(pwd))
{
using (SqliteConnection conn = new SqliteConnection("Data Source=" + dbPath))
{
try
{
conn.SetPassword(pwd);
}
catch
{
conn.Close();
throw;
}
finally
{
conn.Close();
}
}
}
}
else
throw new Exception("已经存在名叫：" + dbPath + "的数据库！");
}
开发者ID:Jeremaihloo，项目名称:CSharpProject，代码行数:28，代码来源:SQLiteDriver.cs
示例10: TestVersion
public static bool TestVersion(string version, SqliteConnection MainSQLiteConnection)
{
try
{
using (var contents = SQLiteUtilities.MainSQLiteConnection.CreateCommand())
{
contents.CommandText = "SELECT Nr FROM [Version]";
var r = contents.ExecuteReader();
while (r.Read())
{
Console.WriteLine("Version: " + r["Nr"]);
if ( r["Nr"].ToString() == version)
return true;
else
return false;
}
}
}
catch (Exception ex)
{
DataAccessLayer.ExceptionWriter.WriteLogFile(ex);
}
return false;
}
开发者ID:MbProg，项目名称:TestApolloAndroid，代码行数:26，代码来源:DAL_Version.cs
示例11: Initialise
public void Initialise(string connectionString)
{
m_connectionString = connectionString;
m_log.Info("[ESTATE DB]: Sqlite - connecting: "+m_connectionString);
m_connection = new SqliteConnection(m_connectionString);
try
{
m_connection.Open();
}
catch (Exception ex)
{
throw new Exception("SQLite has errored out on opening the database. If you are on a 64 bit system, please run OpenSim.32BitLaunch.exe and try again. If this is not a 64 bit error :" + ex);
}
Assembly assem = GetType().Assembly;
Migration m = new Migration(m_connection, assem, "EstateStore");
m.Update();
//m_connection.Close();
// m_connection.Open();
Type t = typeof(EstateSettings);
m_Fields = t.GetFields(BindingFlags.NonPublic |
BindingFlags.Instance |
BindingFlags.DeclaredOnly);
foreach (FieldInfo f in m_Fields)
if (f.Name.Substring(0, 2) == "m_")
m_FieldMap[f.Name.Substring(2)] = f;
}
开发者ID:NickyPerian，项目名称:Aurora，代码行数:32，代码来源:SQLiteEstateData.cs
示例12: CreateDatabase
/// <summary>
/// Creates and opens a database.
/// </summary>
/// <param name="name">Database name.</param>
/// <returns>Created database, or null if cannot be created.</returns>
public override Database CreateDatabase(string name)
{
Database database = null;
try
{
database = new Database(name, DEFAULT_DATABASE_OPTION_NEW, DEFAULT_DATABASE_OPTION_COMPRESS);
string dbPath = Path.Combine(GetBasePath(), name);
// Checks if a file already exists, if not creates the file.
bool exists = File.Exists (dbPath);
if (!exists)
{
SqliteConnection.CreateFile (dbPath);
}
SqliteConnection connection = new SqliteConnection(
"Data Source=" + dbPath +
",version=" + DEFAULT_DATABASE_VERSION);
connection.Open();
StoreConnection(name, connection);
StoreDatabase(name, database);
}
catch (Exception e)
{
SystemLogger.Log(SystemLogger.Module.PLATFORM, "Exception creating database.", e);
database = null;
}
return database;
}
开发者ID:lsp1357，项目名称:appverse-mobile，代码行数:37，代码来源:IPhoneDatabase.cs
示例13: proDataExc
public string proDataExc(string[] strTT)
{
try
{
if (strTT.Length < 1) { return "No SQL"; }
string DatabaseName = "PUB.db3";
string documents = System.Environment.GetFolderPath(System.Environment.SpecialFolder.Personal);
string db = System.IO.Path.Combine(documents, DatabaseName);
var conn = new SqliteConnection("Data Source=" + db);
var sqlitecmd = conn.CreateCommand();
conn.Open();
sqlitecmd.CommandType = CommandType.Text;
for (int j = 0; j < strTT.Length; j++)
{
if (strTT[j] == "") { continue; }
sqlitecmd.CommandText = strTT[j];
sqlitecmd.ExecuteNonQuery();
}
conn.Close();
conn.Dispose();
return "";
}
catch (Exception Ex)
{
return Ex.ToString();
}
}
开发者ID:trloveu，项目名称:che9app，代码行数:27，代码来源:PUBWap.cs
示例14: Start
void Start ()
{
string connectionString = "URI=file:" + Application.dataPath + "/GameMaster"; //Path to database.
IDbConnection dbcon = new SqliteConnection(connectionString) as IDbConnection;
dbcon.Open(); //Open connection to the database.
IDbCommand dbcmd = dbcon.CreateCommand();
dbcmd.CommandText = "SELECT firstname, lastname " + "FROM addressbook";
IDataReader reader = dbcmd.ExecuteReader();
while(reader.Read())
{
string FirstName = reader.GetString (0);
string LastName = reader.GetString (1);
Console.WriteLine("Name: " + FirstName + " " + LastName);
UnityEngine.Debug.LogWarning("Name: " + FirstName + " " + LastName);
}
reader.Close();
reader = null;
dbcmd.Dispose();
dbcmd = null;
dbcon.Close();
dbcon = null;
}
开发者ID:nacho4d，项目名称:W.G.-Unity3D-SQLite，代码行数:26，代码来源:DBAccess.cs
示例15: SqliteVsMonoDSSpeedTests
public SqliteVsMonoDSSpeedTests()
{
// create path and filename to the database file.
var documents = Environment.GetFolderPath (
Environment.SpecialFolder.Personal);
_db = Path.Combine (documents, "mydb.db3");
if (File.Exists (_db))
File.Delete (_db);
SqliteConnection.CreateFile (_db);
var conn = new SqliteConnection("URI=" + _db);
using (var c = conn.CreateCommand()) {
c.CommandText = "CREATE TABLE DataIndex (SearchKey INTEGER NOT NULL,Name TEXT NOT NULL,Email Text NOT NULL)";
conn.Open ();
c.ExecuteNonQuery ();
conn.Close();
}
conn.Dispose();
// create path and filename to the database file.
var documentsPath = Environment.GetFolderPath (Environment.SpecialFolder.MyDocuments);
var libraryPath = Path.Combine (documentsPath, "..", "Library");
_dataDirectory = Path.Combine (libraryPath, "MonoDS");
_entity = "PersonEntity";
_serializer = new Serializer();
}
开发者ID:EdisonLiang，项目名称:MonoDS，代码行数:27，代码来源:SqliteVsMonoDSSpeedTests.cs
示例16: GetCategory
/// <summary>
/// Returns the category for the specified id.
/// </summary>
/// <param name="categoryId">Category identifier.</param>
public Category GetCategory(int categoryId)
{
Category category = null;
using (var connection = new SqliteConnection("Data Source=" + dbPath))
using (var query = new SqliteCommand("SELECT * FROM Categories WHERE id = @categoryId", connection))
{
query.Parameters.AddWithValue("@categoryId", categoryId);
connection.Open();
var reader = query.ExecuteReader(CommandBehavior.CloseConnection);
while (reader.Read())
{
category = new Category();
category.Id = int.Parse(reader["id"].ToString());
category.Name = reader ["name"].ToString();
}
reader.Close();
}
return category;
}
开发者ID:CayasSoftware，项目名称:RSSReader，代码行数:29，代码来源:CategoryRepository.cs
示例17: Open
public static IDbConnection Open(string dbPath, bool create)
{
if (dbPath == null)
throw new ArgumentNullException("dbPath");
if (create) {
if (File.Exists(dbPath))
File.Delete(dbPath);
#if WIN32
SQLiteConnection.CreateFile(dbPath);
#else
SqliteConnection.CreateFile(dbPath);
#endif
} else {
if (!File.Exists(dbPath))
throw new FileNotFoundException(string.Format("Database '{0}' not found", dbPath));
}
IDbConnection conn;
string connStr = string.Format("Data Source={0}", dbPath);
#if WIN32
conn = new SQLiteConnection(connStr);
#else
conn = new SqliteConnection(connStr);
#endif
conn.Open();
return conn;
}
开发者ID:pulb，项目名称:basenji，代码行数:28，代码来源:SqliteDB.cs
示例18: DatabaseHelperCanAccessDatabase
public static bool DatabaseHelperCanAccessDatabase(String overrideConnectionInfo)
{
bool result = false;
SqliteConnection connection;
if (
(overrideConnectionInfo != null)
&& (overrideConnectionInfo.Length > 0)
)
{
connection = new SqliteConnection(overrideConnectionInfo);
}
else
{
connection = new SqliteConnection(GetConnectionString());
}
try
{
connection.Open();
result = (connection.State == ConnectionState.Open);
}
catch { }
finally
{
if (connection.State == ConnectionState.Open)
connection.Close();
}
return result;
}
开发者ID:joedavis01，项目名称:mojoportal，代码行数:33，代码来源:dbPortal.cs
示例19: DateTimeConvert
public void DateTimeConvert ()
{
var dateTime = new DateTime (2016, 9, 15, 12, 1, 53);
var guid = Guid.NewGuid ();
using (var connection = new SqliteConnection ("Data Source=" + _databasePath)) {
connection.Open ();
var sqlCreate = "CREATE TABLE TestTable (ID uniqueidentifier PRIMARY KEY, Modified datetime)";
using (var cmd = new SqliteCommand (sqlCreate, connection)) {
cmd.ExecuteNonQuery ();
}
var sqlInsert = "INSERT INTO TestTable (ID, Modified) VALUES (@id, @mod)";
using (var cmd = new SqliteCommand (sqlInsert, connection)) {
cmd.Parameters.Add (new SqliteParameter ("@id", guid));
cmd.Parameters.Add (new SqliteParameter ("@mod", dateTime));
cmd.ExecuteNonQuery ();
}
}
using (var connection = new SqliteConnection ("Data Source=" + _databasePath)) {
connection.Open ();
var sqlSelect = "SELECT * from TestTable";
using (var cmd = new SqliteCommand (sqlSelect, connection))
using (var reader = cmd.ExecuteReader ()) {
while (reader.Read ()) {
Assert.AreEqual (guid, reader.GetGuid (0), "#1");
Assert.AreEqual (dateTime, reader.GetDateTime (1), "#2");
}
}
}
}
开发者ID:ItsVeryWindy，项目名称:mono，代码行数:34，代码来源:SqliteTests.cs
示例20: DoNonQuery
public static int DoNonQuery (SqliteConnection connection, string command_text, string[] param_names, object[] param_args)
{
int ret = 0;
using (SqliteCommand command = new SqliteCommand ()) {
command.Connection = connection;
command.CommandText = command_text;
if (param_names != null) {
if (param_args == null || param_names.Length != param_args.Length)
throw new ArgumentException ("param_names, param_args", "param_names and param_args should have same number of items");
for (int i = 0; i < param_names.Length; ++i)
command.Parameters.AddWithValue (param_names [i], param_args [i]);
}
while (true) {
try {
ret = command.ExecuteNonQuery ();
break;
} catch (SqliteException e) {
if (e.ErrorCode == SQLiteErrorCode.Busy) {
Thread.Sleep (50);
} else {
throw;
}
} catch (Exception e) {
Log.Error (e, "SQL that caused the exception: {0}", command_text);
throw;
}
}
}
return ret;
}
开发者ID:zweib730，项目名称:beagrep，代码行数:34，代码来源:SqliteUtils.cs
注：本文中的Mono.Data.Sqlite.SqliteConnection类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论