@@ -22,26 +22,21 @@ func Test1127(t *testing.T) {
22
22
)
23
23
require .NoError (t , err )
24
24
25
- progressTotalRows := uint64 (0 )
26
- profileTotalRows := uint64 (0 )
25
+ progressHasTriggered := false
27
26
ctx := clickhouse .Context (context .Background (), clickhouse .WithProgress (func (p * clickhouse.Progress ) {
28
27
fmt .Println ("progress: " , p )
29
- progressTotalRows += p .Rows
30
- }), clickhouse .WithProfileInfo (func (p * clickhouse.ProfileInfo ) {
31
- fmt .Println ("profile info: " , p )
32
- profileTotalRows += p .Rows
28
+ progressHasTriggered = true
33
29
}), clickhouse .WithLogs (func (log * clickhouse.Log ) {
34
30
fmt .Println ("log info: " , log )
35
31
}))
36
32
37
- rows , err := conn .Query (ctx , "SELECT number from numbers(10000000) LIMIT 10000000 " )
33
+ rows , err := conn .Query (ctx , "select throwIf( number = 1e6) from system. numbers settings max_block_size = 100 " )
38
34
require .NoError (t , err )
39
35
40
36
defer rows .Close ()
41
37
for rows .Next () {
42
38
}
43
39
44
- require .NoError (t , rows .Err ())
45
- assert .Equal (t , uint64 (10000000 ), progressTotalRows )
46
- assert .Equal (t , uint64 (10000000 ), profileTotalRows )
40
+ assert .Error (t , rows .Err ())
41
+ assert .True (t , progressHasTriggered )
47
42
}
0 commit comments