MrUnknownDE/VRCX
1
0
Fork 0
mirror of https://github.com/MrUnknownDE/VRCX.git synced 2026-04-14 12:23:52 +02:00
Code Issues Packages Projects Releases Wiki Activity

cleanup code

Browse Source
This commit is contained in:
pypy
2020-11-01 23:41:21 +09:00
parent 2cc00465ad
commit c051dccecf
10 changed files with 241 additions and 207 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
SQLite.cs
View File

@@ -10,78 +10,84 @@ namespace VRCX
public class SQLite
{
public static SQLite Instance { get; private set; }
private static readonly ReaderWriterLockSlim m_Lock = new ReaderWriterLockSlim();
private static SQLiteConnection m_Connection;
private readonly ReaderWriterLockSlim m_ConnectionLock;
private readonly SQLiteConnection m_Connection;
static SQLite()
{
Instance = new SQLite();
}
public static void Init()
public SQLite()
{
m_ConnectionLock = new ReaderWriterLockSlim();
var dataSource = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "VRCX.sqlite3");
m_Connection = new SQLiteConnection($"Data Source=\"{dataSource}\";Version=3;PRAGMA locking_mode=NORMAL;PRAGMA busy_timeout=5000", true);
}
internal void Init()
{
var path = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "VRCX.sqlite3");
m_Connection = new SQLiteConnection($"Data Source=\"{path}\";Version=3;PRAGMA locking_mode=NORMAL;PRAGMA busy_timeout=5000", true);
m_Connection.Open();
}
public static void Exit()
internal void Exit()
{
m_Connection.Close();
m_Connection.Dispose();
}
public int ExecuteNonQuery(string sql, IDictionary<string, object> param = null)
public int ExecuteNonQuery(string sql, IDictionary<string, object> args = null)
{
m_Lock.EnterWriteLock();
m_ConnectionLock.EnterWriteLock();
try
{
using (var C = new SQLiteCommand(sql, m_Connection))
using (var command = new SQLiteCommand(sql, m_Connection))
{
if (param != null)
if (args != null)
{
foreach (var prop in param)
foreach (var arg in args)
{
C.Parameters.Add(new SQLiteParameter(prop.Key, prop.Value));
command.Parameters.Add(new SQLiteParameter(arg.Key, arg.Value));
}
}
return C.ExecuteNonQuery();
return command.ExecuteNonQuery();
}
}
finally
{
m_Lock.ExitWriteLock();
m_ConnectionLock.ExitWriteLock();
}
}
public void Execute(IJavascriptCallback callback, string sql, IDictionary<string, object> param = null)
public void Execute(IJavascriptCallback callback, string sql, IDictionary<string, object> args = null)
{
m_Lock.EnterReadLock();
m_ConnectionLock.EnterReadLock();
try
{
using (var C = new SQLiteCommand(sql, m_Connection))
using (var command = new SQLiteCommand(sql, m_Connection))
{
if (param != null)
if (args != null)
{
foreach (var prop in param)
foreach (var arg in args)
{
C.Parameters.Add(new SQLiteParameter(prop.Key, prop.Value));
command.Parameters.Add(new SQLiteParameter(arg.Key, arg.Value));
}
}
using (var R = C.ExecuteReader())
using (var reader = command.ExecuteReader())
{
while (R.Read())
while (reader.Read() == true)
{
var row = new object[R.FieldCount];
R.GetValues(row);
callback.ExecuteAsync(row);
var values = new object[reader.FieldCount];
reader.GetValues(values);
callback.ExecuteAsync(values);
}
}
}
}
finally
{
m_Lock.ExitReadLock();
m_ConnectionLock.ExitReadLock();
}
}
}