Many hyperlinks are disabled.
Use anonymous login
to enable hyperlinks.
Overview
| Comment: | Create the metadata item for the xConflict callback. |
|---|---|
| Downloads: | Tarball | ZIP archive |
| Timelines: | family | ancestors | descendants | both | sessions |
| Files: | files | file ages | folders |
| SHA1: |
e3f2fe8d85b01d6e61f54cc248a165ff |
| User & Date: | mistachkin 2017-10-11 21:21:43.955 |
Context
|
2017-10-11
| ||
| 21:22 | Add tests for Apply and CombineWith. check-in: d1def95f7b user: mistachkin tags: sessions | |
| 21:21 | Create the metadata item for the xConflict callback. check-in: e3f2fe8d85 user: mistachkin tags: sessions | |
| 05:18 | Wrap calls to the SessionTableFilterCallback delegate in a try/catch. check-in: 9c4784ee2f user: mistachkin tags: sessions | |
Changes
Changes to System.Data.SQLite/SQLiteSession.cs.
| ︙ | ︙ | |||
398 399 400 401 402 403 404 |
#endregion
}
#endregion
///////////////////////////////////////////////////////////////////////////
#region SQLiteChangeSetIterator Class
| | > > > > | > > | 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 |
#endregion
}
#endregion
///////////////////////////////////////////////////////////////////////////
#region SQLiteChangeSetIterator Class
internal class SQLiteChangeSetIterator : IDisposable
{
#region Private Data
private IntPtr iterator;
///////////////////////////////////////////////////////////////////////
private bool ownHandle;
#endregion
///////////////////////////////////////////////////////////////////////
#region Protected Constructors
protected SQLiteChangeSetIterator(
IntPtr iterator,
bool ownHandle
)
{
this.iterator = iterator;
this.ownHandle = ownHandle;
}
#endregion
///////////////////////////////////////////////////////////////////////
#region Private Methods
internal void CheckHandle()
|
| ︙ | ︙ | |||
468 469 470 471 472 473 474 475 476 477 478 479 480 481 |
}
}
}
#endregion
///////////////////////////////////////////////////////////////////////
#region IDisposable Members
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
#endregion
| > > > > > > > > > > > | 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 |
}
}
}
#endregion
///////////////////////////////////////////////////////////////////////
#region Static "Factory" Methods
public static SQLiteChangeSetIterator Attach(
IntPtr iterator
)
{
return new SQLiteChangeSetIterator(iterator, false);
}
#endregion
///////////////////////////////////////////////////////////////////////
#region IDisposable Members
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
#endregion
|
| ︙ | ︙ | |||
511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 |
//}
//////////////////////////////////////
// release unmanaged resources here...
//////////////////////////////////////
if (iterator != IntPtr.Zero)
{
UnsafeNativeMethods.sqlite3changeset_finalize(
iterator);
iterator = IntPtr.Zero;
}
}
}
finally
{
| > > > | 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 |
//}
//////////////////////////////////////
// release unmanaged resources here...
//////////////////////////////////////
if (iterator != IntPtr.Zero)
{
if (ownHandle)
{
UnsafeNativeMethods.sqlite3changeset_finalize(
iterator);
}
iterator = IntPtr.Zero;
}
}
}
finally
{
|
| ︙ | ︙ | |||
555 556 557 558 559 560 561 |
#endregion
///////////////////////////////////////////////////////////////////////
#region Private Constructors
private SQLiteMemoryChangeSetIterator(
IntPtr pData,
| | > | | 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 |
#endregion
///////////////////////////////////////////////////////////////////////
#region Private Constructors
private SQLiteMemoryChangeSetIterator(
IntPtr pData,
IntPtr iterator,
bool ownHandle
)
: base(iterator, ownHandle)
{
this.pData = pData;
}
#endregion
///////////////////////////////////////////////////////////////////////
|
| ︙ | ︙ | |||
591 592 593 594 595 596 597 |
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3changeset_start(
ref iterator, nData, pData);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3changeset_start");
| | > | 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 |
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3changeset_start(
ref iterator, nData, pData);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3changeset_start");
result = new SQLiteMemoryChangeSetIterator(
pData, iterator, true);
}
finally
{
if (result == null)
{
if (iterator != IntPtr.Zero)
{
|
| ︙ | ︙ | |||
685 686 687 688 689 690 691 |
#region SQLiteStreamChangeSetIterator Class
internal sealed class SQLiteStreamChangeSetIterator :
SQLiteChangeSetIterator
{
#region Private Constructors
private SQLiteStreamChangeSetIterator(
| | > | | 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 |
#region SQLiteStreamChangeSetIterator Class
internal sealed class SQLiteStreamChangeSetIterator :
SQLiteChangeSetIterator
{
#region Private Constructors
private SQLiteStreamChangeSetIterator(
IntPtr iterator,
bool ownHandle
)
: base(iterator, ownHandle)
{
// do nothing.
}
#endregion
///////////////////////////////////////////////////////////////////////
|
| ︙ | ︙ | |||
716 717 718 719 720 721 722 |
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3changeset_start_strm(
ref iterator, new SQLiteStreamAdapter(stream, flags).xInput,
IntPtr.Zero);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3changeset_start_strm");
| | | 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 |
SQLiteErrorCode rc = UnsafeNativeMethods.sqlite3changeset_start_strm(
ref iterator, new SQLiteStreamAdapter(stream, flags).xInput,
IntPtr.Zero);
if (rc != SQLiteErrorCode.Ok)
throw new SQLiteException(rc, "sqlite3changeset_start_strm");
result = new SQLiteStreamChangeSetIterator(iterator, true);
}
finally
{
if (result == null)
{
if (iterator != IntPtr.Zero)
{
|
| ︙ | ︙ | |||
1668 1669 1670 1671 1672 1673 1674 1675 1676 1677 1678 1679 1680 1681 |
{
// do nothing.
}
#endregion
///////////////////////////////////////////////////////////////////////
#region Protected Methods
protected UnsafeNativeMethods.xSessionFilter GetDelegate(
SessionTableFilterCallback tableFilterCallback,
object clientData
)
{
if (tableFilterCallback == null)
| > > > > > > > > > > > > | 1691 1692 1693 1694 1695 1696 1697 1698 1699 1700 1701 1702 1703 1704 1705 1706 1707 1708 1709 1710 1711 1712 1713 1714 1715 1716 |
{
// do nothing.
}
#endregion
///////////////////////////////////////////////////////////////////////
#region Private Methods
private ISQLiteChangeSetMetadataItem CreateMetadataItem(
IntPtr iterator
)
{
return new SQLiteChangeSetMetadataItem(
SQLiteChangeSetIterator.Attach(iterator));
}
#endregion
///////////////////////////////////////////////////////////////////////
#region Protected Methods
protected UnsafeNativeMethods.xSessionFilter GetDelegate(
SessionTableFilterCallback tableFilterCallback,
object clientData
)
{
if (tableFilterCallback == null)
|
| ︙ | ︙ | |||
1732 1733 1734 1735 1736 1737 1738 |
UnsafeNativeMethods.xSessionConflict xConflict;
xConflict = new UnsafeNativeMethods.xSessionConflict(
delegate(IntPtr context,
SQLiteChangeSetConflictType type,
IntPtr iterator)
{
| > > | > | > > > > | 1767 1768 1769 1770 1771 1772 1773 1774 1775 1776 1777 1778 1779 1780 1781 1782 1783 1784 1785 1786 1787 1788 1789 1790 1791 |
UnsafeNativeMethods.xSessionConflict xConflict;
xConflict = new UnsafeNativeMethods.xSessionConflict(
delegate(IntPtr context,
SQLiteChangeSetConflictType type,
IntPtr iterator)
{
try
{
ISQLiteChangeSetMetadataItem item = CreateMetadataItem(
iterator);
if (item == null)
{
throw new SQLiteException(
"could not create metadata item");
}
return conflictCallback(clientData, type, item);
}
catch (Exception e)
{
try
{
if (HelperMethods.LogCallbackExceptions(GetFlags()))
|
| ︙ | ︙ |