Many hyperlinks are disabled.
Use anonymous login
to enable hyperlinks.
Overview
| Comment: | Further work on the SQLiteStreamChangeSet class. |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | sessions |
| Files: | files | file ages | folders |
| SHA1: |
b1e6a036bbf977b4261a4cd876e475cf |
| User & Date: | mistachkin 2017-10-06 16:04:57 |
Context
|
2017-10-06
| ||
| 16:08 | Remove unused IsPatchSet property from the ISQLiteChangeSet interface. check-in: 54ac954062 user: mistachkin tags: sessions | |
| 16:04 | Further work on the SQLiteStreamChangeSet class. check-in: b1e6a036bb user: mistachkin tags: sessions | |
| 15:51 | Further work on the SQLiteMemoryChangeSet class. check-in: 5dc5e48cb0 user: mistachkin tags: sessions | |
Changes
Changes to System.Data.SQLite/SQLiteConnection.cs.
3047 3048 3049 3050 3051 3052 3053 3054 3055 3056 3057 3058 3059 3060 3061 3062 3063 3064 3065 3066 3067 3068 3069 3070 3071 3072 3073 3074 3075 |
rawData, GetNativeHandle(this), _flags, null);
}
/// <summary>
/// Attempts to create a new <see cref="ISQLiteChangeSet" /> object instance
/// using this connection and the specified stream.
/// </summary>
/// <param name="stream">
/// The stream where the raw data that contains a change set (or patch set)
/// may be read.
/// </param>
/// <returns>
/// The newly created change set -OR- null if it cannot be created.
/// </returns>
public ISQLiteChangeSet CreateChangeSet(
Stream stream
)
{
CheckDisposed();
return new SQLiteStreamChangeSet(
stream, GetNativeHandle(this), _flags, null);
}
#endif
/// <summary>
/// Returns the data source file name without extension or path.
/// </summary>
#if !PLATFORM_COMPACTFRAMEWORK
|
| > > > > | > | |
3047 3048 3049 3050 3051 3052 3053 3054 3055 3056 3057 3058 3059 3060 3061 3062 3063 3064 3065 3066 3067 3068 3069 3070 3071 3072 3073 3074 3075 3076 3077 3078 3079 3080 |
rawData, GetNativeHandle(this), _flags, null);
}
/// <summary>
/// Attempts to create a new <see cref="ISQLiteChangeSet" /> object instance
/// using this connection and the specified stream.
/// </summary>
/// <param name="inputStream">
/// The stream where the raw data that contains a change set (or patch set)
/// may be read.
/// </param>
/// <param name="outputStream">
/// The stream where the raw data that contains a change set (or patch set)
/// may be written.
/// </param>
/// <returns>
/// The newly created change set -OR- null if it cannot be created.
/// </returns>
public ISQLiteChangeSet CreateChangeSet(
Stream inputStream,
Stream outputStream
)
{
CheckDisposed();
return new SQLiteStreamChangeSet(
inputStream, outputStream, GetNativeHandle(this), _flags, null);
}
#endif
/// <summary>
/// Returns the data source file name without extension or path.
/// </summary>
#if !PLATFORM_COMPACTFRAMEWORK
|
Changes to System.Data.SQLite/SQLiteSessions.cs.
1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 .... 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368 1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 .... 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 .... 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 |
#region SQLiteStreamChangeSet Class
public sealed class SQLiteStreamChangeSet :
ISQLiteChangeSet, IEnumerable<ISQLiteChangeSetMetadataItem>,
IDisposable
{
#region Private Data
private Stream stream;
private SQLiteConnectionHandle handle;
private SQLiteConnectionFlags flags;
private bool? isPatchSet;
#endregion
///////////////////////////////////////////////////////////////////////
#region Private Constructors
internal SQLiteStreamChangeSet(
Stream stream,
SQLiteConnectionHandle handle,
SQLiteConnectionFlags flags,
bool? isPatchSet
)
{
this.stream = stream;
this.handle = handle;
this.flags = flags;
this.isPatchSet = isPatchSet;
}
#endregion
///////////////////////////////////////////////////////////////////////
#region ISQLiteChangeSet Members
public bool? IsPatchSet
................................................................................
}
///////////////////////////////////////////////////////////////////////
public ISQLiteChangeSet Invert()
{
CheckDisposed();
throw new NotImplementedException();
}
///////////////////////////////////////////////////////////////////////
public ISQLiteChangeSet CombineWith(
ISQLiteChangeSet changeSet
)
{
CheckDisposed();
throw new NotImplementedException();
}
///////////////////////////////////////////////////////////////////////
public void Apply(
SessionConflictCallback conflictCallback,
object clientData
)
{
CheckDisposed();
throw new NotImplementedException();
}
///////////////////////////////////////////////////////////////////////
public void Apply(
SessionConflictCallback conflictCallback,
SessionTableFilterCallback tableFilterCallback,
object clientData
)
{
CheckDisposed();
UnsafeNativeMethods.xSessionFilter xFilter;
xFilter = new UnsafeNativeMethods.xSessionFilter(
delegate(IntPtr context, byte[] tblName)
{
try
................................................................................
}
}
return SQLiteChangeSetConflictResult.Abort;
});
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3changeset_apply_strm(
handle, new SQLiteStreamAdapter(stream, flags).xInput,
IntPtr.Zero, xFilter, xConflict, IntPtr.Zero);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3changeset_apply_strm");
}
#endregion
///////////////////////////////////////////////////////////////////////
#region IEnumerable<ISQLiteChangeSetMetadataItem> Members
public IEnumerator<ISQLiteChangeSetMetadataItem> GetEnumerator()
{
return new SQLiteChangeSetEnumerator(stream, flags);
}
#endregion
///////////////////////////////////////////////////////////////////////
#region IEnumerable Members
IEnumerator System.Collections.IEnumerable.GetEnumerator()
................................................................................
{
if (disposing)
{
////////////////////////////////////
// dispose managed resources here...
////////////////////////////////////
if (stream != null)
stream = null; /* NOT OWNED */
}
//////////////////////////////////////
// release unmanaged resources here...
//////////////////////////////////////
}
}
|
| > | > | > > > > > > > > > > > > > > > > > > > > > > > > > > > < > > > > > > > > > > < > > > > > > > > > > > > > > > > > > > > > | > | | > > > | | |
1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 .... 1367 1368 1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397 1398 1399 1400 1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 .... 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 .... 1571 1572 1573 1574 1575 1576 1577 1578 1579 1580 1581 1582 1583 1584 1585 1586 1587 1588 1589 |
#region SQLiteStreamChangeSet Class
public sealed class SQLiteStreamChangeSet :
ISQLiteChangeSet, IEnumerable<ISQLiteChangeSetMetadataItem>,
IDisposable
{
#region Private Data
private Stream inputStream;
private Stream outputStream;
private SQLiteConnectionHandle handle;
private SQLiteConnectionFlags flags;
private bool? isPatchSet;
#endregion
///////////////////////////////////////////////////////////////////////
#region Private Constructors
internal SQLiteStreamChangeSet(
Stream inputStream,
Stream outputStream,
SQLiteConnectionHandle handle,
SQLiteConnectionFlags flags,
bool? isPatchSet
)
{
this.inputStream = inputStream;
this.outputStream = outputStream;
this.handle = handle;
this.flags = flags;
this.isPatchSet = isPatchSet;
}
#endregion
///////////////////////////////////////////////////////////////////////
#region Private Methods
private void CheckInputStream()
{
if (inputStream == null)
{
throw new InvalidOperationException(
"input stream unavailable");
}
}
///////////////////////////////////////////////////////////////////////
private void CheckOutputStream()
{
if (outputStream == null)
{
throw new InvalidOperationException(
"output stream unavailable");
}
}
#endregion
///////////////////////////////////////////////////////////////////////
#region ISQLiteChangeSet Members
public bool? IsPatchSet
................................................................................
}
///////////////////////////////////////////////////////////////////////
public ISQLiteChangeSet Invert()
{
CheckDisposed();
CheckInputStream();
CheckOutputStream();
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3changeset_invert_strm(
new SQLiteStreamAdapter(inputStream, flags).xInput, IntPtr.Zero,
new SQLiteStreamAdapter(outputStream, flags).xOutput, IntPtr.Zero);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3changeset_invert_strm");
return null;
}
///////////////////////////////////////////////////////////////////////
public ISQLiteChangeSet CombineWith(
ISQLiteChangeSet changeSet
)
{
CheckDisposed();
CheckInputStream();
CheckOutputStream();
SQLiteStreamChangeSet streamChangeSet =
changeSet as SQLiteStreamChangeSet;
if (streamChangeSet == null)
{
throw new ArgumentException(
"not a stream based change set", "changeSet");
}
streamChangeSet.CheckInputStream();
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3changeset_concat_strm(
new SQLiteStreamAdapter(inputStream, flags).xInput, IntPtr.Zero,
new SQLiteStreamAdapter(streamChangeSet.inputStream,
streamChangeSet.flags).xInput, IntPtr.Zero,
new SQLiteStreamAdapter(outputStream, flags).xOutput, IntPtr.Zero);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3changeset_concat_strm");
return null;
}
///////////////////////////////////////////////////////////////////////
public void Apply(
SessionConflictCallback conflictCallback,
object clientData
)
{
CheckDisposed();
Apply(conflictCallback, null, clientData);
}
///////////////////////////////////////////////////////////////////////
public void Apply(
SessionConflictCallback conflictCallback,
SessionTableFilterCallback tableFilterCallback,
object clientData
)
{
CheckDisposed();
CheckInputStream();
UnsafeNativeMethods.xSessionFilter xFilter;
xFilter = new UnsafeNativeMethods.xSessionFilter(
delegate(IntPtr context, byte[] tblName)
{
try
................................................................................
}
}
return SQLiteChangeSetConflictResult.Abort;
});
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3changeset_apply_strm(
handle, new SQLiteStreamAdapter(inputStream, flags).xInput,
IntPtr.Zero, xFilter, xConflict, IntPtr.Zero);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3changeset_apply_strm");
}
#endregion
///////////////////////////////////////////////////////////////////////
#region IEnumerable<ISQLiteChangeSetMetadataItem> Members
public IEnumerator<ISQLiteChangeSetMetadataItem> GetEnumerator()
{
return new SQLiteChangeSetEnumerator(inputStream, flags);
}
#endregion
///////////////////////////////////////////////////////////////////////
#region IEnumerable Members
IEnumerator System.Collections.IEnumerable.GetEnumerator()
................................................................................
{
if (disposing)
{
////////////////////////////////////
// dispose managed resources here...
////////////////////////////////////
if (outputStream != null)
outputStream = null; /* NOT OWNED */
if (inputStream != null)
inputStream = null; /* NOT OWNED */
}
//////////////////////////////////////
// release unmanaged resources here...
//////////////////////////////////////
}
}
|