Many hyperlinks are disabled.
Use anonymous login
to enable hyperlinks.
Overview
| Comment: | Refactoring: Only the SQLiteConnectionLock class is allowed to hold onto the native connection handle and its associated flags. |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | sessions |
| Files: | files | file ages | folders |
| SHA1: |
43624d7096a451cce09d908327556d20 |
| User & Date: | mistachkin 2017-10-10 21:52:23 |
Context
|
2017-10-10
| ||
| 21:58 | Remove unused string constant. check-in: a9cc684e27 user: mistachkin tags: sessions | |
| 21:52 | Refactoring: Only the SQLiteConnectionLock class is allowed to hold onto the native connection handle and its associated flags. check-in: 43624d7096 user: mistachkin tags: sessions | |
| 21:46 | Merge trunk. check-in: 9a31f08683 user: mistachkin tags: sessions | |
Changes
Changes to System.Data.SQLite/SQLiteSession.cs.
1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 .... 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 .... 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 1267 1268 1269 .... 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 .... 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 |
///////////////////////////////////////////////////////////////////////////
#region SQLiteSession Class
internal sealed class SQLiteSession : SQLiteConnectionLock, ISQLiteSession
{
#region Private Data
private SQLiteConnectionHandle handle;
private SQLiteConnectionFlags flags;
private string databaseName;
///////////////////////////////////////////////////////////////////////
private IntPtr session;
///////////////////////////////////////////////////////////////////////
................................................................................
public SQLiteSession(
SQLiteConnectionHandle handle,
SQLiteConnectionFlags flags,
string databaseName
)
: base(handle, flags)
{
this.handle = handle;
this.flags = flags;
this.databaseName = databaseName;
Initialize();
}
#endregion
///////////////////////////////////////////////////////////////////////
................................................................................
private void Initialize()
{
if (session != IntPtr.Zero)
return;
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3session_create(
handle, SQLiteString.GetUtf8BytesFromString(databaseName),
ref session);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3session_create");
}
///////////////////////////////////////////////////////////////////////
................................................................................
)
{
CheckDisposed();
CheckHandle();
if (stream == null)
throw new ArgumentNullException("stream");
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3session_changeset_strm(
session, new SQLiteStreamAdapter(stream, flags).xOutput,
IntPtr.Zero);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3session_changeset_strm");
................................................................................
)
{
CheckDisposed();
CheckHandle();
if (stream == null)
throw new ArgumentNullException("stream");
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3session_patchset_strm(
session, new SQLiteStreamAdapter(stream, flags).xOutput,
IntPtr.Zero);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3session_patchset_strm");
|
< < < < | > > > > |
1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219 .... 1228 1229 1230 1231 1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 .... 1251 1252 1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263 1264 1265 .... 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 .... 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 |
///////////////////////////////////////////////////////////////////////////
#region SQLiteSession Class
internal sealed class SQLiteSession : SQLiteConnectionLock, ISQLiteSession
{
#region Private Data
private string databaseName;
///////////////////////////////////////////////////////////////////////
private IntPtr session;
///////////////////////////////////////////////////////////////////////
................................................................................
public SQLiteSession(
SQLiteConnectionHandle handle,
SQLiteConnectionFlags flags,
string databaseName
)
: base(handle, flags)
{
this.databaseName = databaseName;
Initialize();
}
#endregion
///////////////////////////////////////////////////////////////////////
................................................................................
private void Initialize()
{
if (session != IntPtr.Zero)
return;
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3session_create(
GetIntPtr(), SQLiteString.GetUtf8BytesFromString(databaseName),
ref session);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3session_create");
}
///////////////////////////////////////////////////////////////////////
................................................................................
)
{
CheckDisposed();
CheckHandle();
if (stream == null)
throw new ArgumentNullException("stream");
SQLiteConnectionFlags flags = GetFlags();
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3session_changeset_strm(
session, new SQLiteStreamAdapter(stream, flags).xOutput,
IntPtr.Zero);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3session_changeset_strm");
................................................................................
)
{
CheckDisposed();
CheckHandle();
if (stream == null)
throw new ArgumentNullException("stream");
SQLiteConnectionFlags flags = GetFlags();
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3session_patchset_strm(
session, new SQLiteStreamAdapter(stream, flags).xOutput,
IntPtr.Zero);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3session_patchset_strm");
|