Many hyperlinks are disabled.
Use anonymous login
to enable hyperlinks.
Overview
Comment: | Add stream tests for the CombineWith and Apply methods. |
---|---|
Downloads: | Tarball | ZIP archive |
Timelines: | family | ancestors | descendants | both | sessions |
Files: | files | file ages | folders |
SHA1: |
cce9d5de8345e619164394e11dc78d0b |
User & Date: | mistachkin 2017-10-12 20:04:51.905 |
Context
2017-10-13
| ||
17:47 | Object lifetime fixes for stream adapters and their managed delegates. check-in: aafb14f219 user: mistachkin tags: sessions | |
2017-10-12
| ||
22:27 | Incomplete work in progress on stream adapter object lifetime fixes. check-in: c4fb95f1eb user: mistachkin tags: sessionStreamManager | |
20:04 | Add stream tests for the CombineWith and Apply methods. check-in: cce9d5de83 user: mistachkin tags: sessions | |
19:26 | Cleanup and modularize tests in preparation for stream variants. Initial work on stream tests. check-in: c41edbe55e user: mistachkin tags: sessions | |
Changes
Changes to Tests/session.eagle.
︙ | ︙ | |||
122 123 124 125 126 127 128 | ############################################################################### proc openStreamChangeSetForConnection { connection inputFileName outputFileName {varName ""} } { if {[isObjectHandle $connection] && $connection ne "null"} then { if {[string length $varName] > 0} then { | | | | | | | | | 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 | ############################################################################### proc openStreamChangeSetForConnection { connection inputFileName outputFileName {varName ""} } { if {[isObjectHandle $connection] && $connection ne "null"} then { if {[string length $varName] > 0} then { upvar 1 $varName state } if {[string length $inputFileName] > 0} then { set state(inputStream) [object create -alias \ System.IO.FileStream $inputFileName Open Read] } else { set state(inputStream) null } if {[string length $outputFileName] > 0} then { set state(outputStream) [object create -alias \ System.IO.FileStream $outputFileName Create Write] } else { set state(outputStream) null } set state(changeSet) [$connection -alias \ CreateChangeSet $state(inputStream) $state(outputStream)] return true } return false } |
︙ | ︙ | |||
342 343 344 345 346 347 348 349 350 351 352 353 354 355 | object removeref $rawData return $rawData } ############################################################################### proc getChangeSetFileName { {suffix ""} } { return [file join \ [getTemporaryDirectory] [appendArgs changes $suffix .bin]] } ############################################################################### | > > > > > > > > > > > > > > > > > > > | 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 | object removeref $rawData return $rawData } ############################################################################### proc captureChangeSetFile { connection databaseName tableName script fileName } { if {![isObjectHandle $connection] || $connection eq "null"} then { error "connection is invalid" } set session [$connection -alias CreateSession $databaseName] $session AttachTable $tableName if {![isObjectHandle $session] || $session eq "null"} then { error "cannot create session" } catch {uplevel 1 $script} writeStreamChangeSetForSession $session $fileName } ############################################################################### proc getChangeSetFileName { {suffix ""} } { return [file join \ [getTemporaryDirectory] [appendArgs changes $suffix .bin]] } ############################################################################### |
︙ | ︙ | |||
434 435 436 437 438 439 440 | makeSomeChanges $db t1 [list insert update delete] set rawData [createMemoryChangeSetForSession $session] object removeref $rawData writeRawDataToFile $fileName(1) $rawData writeStreamChangeSetForSession $session $fileName(2) | | | | | 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 | makeSomeChanges $db t1 [list insert update delete] set rawData [createMemoryChangeSetForSession $session] object removeref $rawData writeRawDataToFile $fileName(1) $rawData writeStreamChangeSetForSession $session $fileName(2) openStreamChangeSetForConnection $connection $fileName(2) "" state list [expr {[file size $fileName(1)] > 0}] \ [string equal [readFile $fileName(1)] [readFile $fileName(2)]] \ [changeSetToString $state(changeSet) true] } -cleanup { cleanupSomeText unset -nocomplain state rawData byteArray session freeDbConnection unset -nocomplain connection cleanupFile $fileName(2) cleanupFile $fileName(1) |
︙ | ︙ | |||
472 473 474 475 476 477 478 | NumberOfColumns 2 OperationCode Insert Indirect False PrimaryKeyColumns {[True,\ False]} OldValue 0 <nullObject> NewValue 0 3 ConflictValue 0 <nullObject>\ OldValue 1 <nullObject> NewValue 1 {"inserted: Kilo Lima Mike November Oscar"}\ ConflictValue 1 <nullObject>}}}} ############################################################################### | | | 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 | NumberOfColumns 2 OperationCode Insert Indirect False PrimaryKeyColumns {[True,\ False]} OldValue 0 <nullObject> NewValue 0 3 ConflictValue 0 <nullObject>\ OldValue 1 <nullObject> NewValue 1 {"inserted: Kilo Lima Mike November Oscar"}\ ConflictValue 1 <nullObject>}}}} ############################################################################### runTest {test session-1.2.1 {change set read/write/invert (memory)} -setup { setupDb [set fileName session-1.2.1.db] cleanupSomeText } -body { createTheSchema $db main makeSomeChanges $db t1 [list insert insert insert] |
︙ | ︙ | |||
528 529 530 531 532 533 534 | <nullObject>} {TableName t1 NumberOfColumns 2 OperationCode Delete Indirect\ False PrimaryKeyColumns {[True, False]} OldValue 0 4 NewValue 0 <nullObject>\ ConflictValue 0 <nullObject> OldValue 1 {"inserted: Papa Quebec Romeo Sierra\ Tango"} NewValue 1 <nullObject> ConflictValue 1 <nullObject>}}}} ############################################################################### | | | | | | 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 | <nullObject>} {TableName t1 NumberOfColumns 2 OperationCode Delete Indirect\ False PrimaryKeyColumns {[True, False]} OldValue 0 4 NewValue 0 <nullObject>\ ConflictValue 0 <nullObject> OldValue 1 {"inserted: Papa Quebec Romeo Sierra\ Tango"} NewValue 1 <nullObject> ConflictValue 1 <nullObject>}}}} ############################################################################### runTest {test session-1.2.2 {change set read/write/invert (stream)} -setup { setupDb [set fileName(0) session-1.2.2.db] set fileName(1) [getChangeSetFileName 1] set fileName(2) [getChangeSetFileName 2] cleanupSomeText } -body { createTheSchema $db main makeSomeChanges $db t1 [list insert insert insert] set connection [getDbConnection] set session [$connection -alias CreateSession main] $session AttachTable null makeSomeChanges $db t1 [list insert update delete] writeStreamChangeSetForSession $session $fileName(1) openStreamChangeSetForConnection \ $connection $fileName(1) $fileName(2) state $state(changeSet) -alias Invert; unset state list [changeSetFileToString $connection $fileName(2) true] } -cleanup { cleanupSomeText unset -nocomplain state byteArray session freeDbConnection unset -nocomplain connection cleanupDb $fileName(0) |
︙ | ︙ | |||
778 779 780 781 782 783 784 | System.Data.SQLite SQLiteInterop\ defineConstant.System.Data.SQLite.INTEROP_SESSION_EXTENSION} -result {IsEmpty\ True MatchT2 false IsEmpty False MatchT1 true IsEmpty False MatchT2 true\ IsEmpty False MatchT1 true}} ############################################################################### | | | | 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 | System.Data.SQLite SQLiteInterop\ defineConstant.System.Data.SQLite.INTEROP_SESSION_EXTENSION} -result {IsEmpty\ True MatchT2 false IsEmpty False MatchT1 true IsEmpty False MatchT2 true\ IsEmpty False MatchT1 true}} ############################################################################### runTest {test session-1.6.1 {combine/apply change sets (memory)} -setup { setupDb [set fileName session-1.6.1.db] cleanupSomeText } -body { createTheSchema $db main makeSomeChanges $db t1 [list insert insert] set connection [getDbConnection] |
︙ | ︙ | |||
802 803 804 805 806 807 808 | makeSomeChanges $db t1 [list insert] }]; object removeref $rawData(2) set changeSet(1) [$connection -alias CreateChangeSet $rawData(1)] set changeSet(2) [$connection -alias CreateChangeSet $rawData(2)] set changeSet(3) [$changeSet(1) -alias CombineWith $changeSet(2)] | | > | > | > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > | 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 | makeSomeChanges $db t1 [list insert] }]; object removeref $rawData(2) set changeSet(1) [$connection -alias CreateChangeSet $rawData(1)] set changeSet(2) [$connection -alias CreateChangeSet $rawData(2)] set changeSet(3) [$changeSet(1) -alias CombineWith $changeSet(2)] $changeSet(3) -marshalflags +DynamicCallback \ Apply conflictCallback null list [changeSetToString $changeSet(3) true] Data \ [sql execute -execute reader -format list $db \ {SELECT x, y FROM t1 ORDER BY x;}] } -cleanup { cleanupSomeText unset -nocomplain changeSet rawData freeDbConnection unset -nocomplain connection cleanupDb $fileName catch {object removecallback conflictCallback} catch { foreach callbackResult $callbackResults { catch {object dispose $callbackResult} } } unset -nocomplain callbackResult callbackResults db fileName } -constraints {eagle command.object monoBug28 command.sql compile.DATA SQLite\ System.Data.SQLite SQLiteInterop\ defineConstant.System.Data.SQLite.INTEROP_SESSION_EXTENSION} -result \ {{{TableName t1 NumberOfColumns 2 OperationCode Delete Indirect False\ PrimaryKeyColumns {[True, False]} OldValue 0 1 NewValue 0 <nullObject>\ ConflictValue 0 <nullObject> OldValue 1 {"inserted: Alpha Bravo Charlie Delta\ Echo"} NewValue 1 <nullObject> ConflictValue 1 <nullObject>} {TableName t1\ NumberOfColumns 2 OperationCode Insert Indirect False PrimaryKeyColumns {[True,\ False]} OldValue 0 <nullObject> NewValue 0 3 ConflictValue 0 <nullObject>\ OldValue 1 <nullObject> NewValue 1 {"inserted: Papa Quebec Romeo Sierra Tango"}\ ConflictValue 1 <nullObject>}} Data {1 {inserted: Kilo Lima Mike November\ Oscar} 2 {inserted: Foxtrot Golf Hotel India Juliet} 3 {inserted: Papa Quebec\ Romeo Sierra Tango}}}} ############################################################################### runTest {test session-1.6.2 {combine/apply change sets (stream)} -setup { setupDb [set fileName(0) session-1.6.2.db] set fileName(1) [getChangeSetFileName 1] set fileName(2) [getChangeSetFileName 2] set fileName(3) [getChangeSetFileName 3] cleanupSomeText } -body { createTheSchema $db main makeSomeChanges $db t1 [list insert insert] set connection [getDbConnection] captureChangeSetFile $connection main null { makeSomeChanges $db t1 [list delete] 1 } $fileName(1) makeSomeChanges $db t1 [list insert] 1 captureChangeSetFile $connection main null { makeSomeChanges $db t1 [list insert] } $fileName(2) openStreamChangeSetForConnection \ $connection $fileName(1) $fileName(3) state1 openStreamChangeSetForConnection \ $connection $fileName(2) "" state2 $state1(changeSet) CombineWith $state2(changeSet); unset state1 openStreamChangeSetForConnection \ $connection $fileName(3) "" state3 $state3(changeSet) -marshalflags +DynamicCallback \ Apply conflictCallback null; unset state3 openStreamChangeSetForConnection \ $connection $fileName(3) "" state4 list [changeSetToString $state4(changeSet) true] Data \ [sql execute -execute reader -format list $db \ {SELECT x, y FROM t1 ORDER BY x;}] } -cleanup { cleanupSomeText unset -nocomplain state4 state3 state2 state1 freeDbConnection unset -nocomplain connection cleanupDb $fileName(0) catch {object removecallback conflictCallback} catch { foreach callbackResult $callbackResults { catch {object dispose $callbackResult} } |
︙ | ︙ | |||
894 895 896 897 898 899 900 901 902 903 904 905 906 907 | ############################################################################### rename conflictCallback "" rename tableFilterCallbackT1 "" rename createByteArray "" rename arrayToList "" rename getChangeSetFileName "" rename captureChangeSetRawData "" rename makeSomeChanges "" rename createTheSchema "" rename matchChangeSet "" rename matchSession "" rename changeSetToString "" rename metadataItemToString "" | > | 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 | ############################################################################### rename conflictCallback "" rename tableFilterCallbackT1 "" rename createByteArray "" rename arrayToList "" rename getChangeSetFileName "" rename captureChangeSetFile "" rename captureChangeSetRawData "" rename makeSomeChanges "" rename createTheSchema "" rename matchChangeSet "" rename matchSession "" rename changeSetToString "" rename metadataItemToString "" |
︙ | ︙ |