Skip to content

Navigation Menu

Sign in

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit ceab13b

Browse filesBrowse files
PhilippSalvisbergPhilippSalvisberg
committed
add test to ensure events are reported immediately (based on fetch size)
1 parent f4da0f4 commit ceab13b
Copy full SHA for ceab13b

File tree

2 files changed

+181
-0
lines changed
Filter options

2 files changed

+181
-0
lines changed

‎sqldev/src/test/java/org/utplsql/sqldev/test/dal/RealtimeReporterFetchSizeTest.xtend

Copy file name to clipboard
+144Lines changed: 144 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,144 @@
1+
/*
2+
* Copyright 2019 Philipp Salvisberg <philipp.salvisberg@trivadis.com>
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
package org.utplsql.sqldev.test.dal
17+
18+
import java.util.UUID
19+
import java.util.logging.Logger
20+
import org.junit.AfterClass
21+
import org.junit.Assert
22+
import org.junit.BeforeClass
23+
import org.junit.Test
24+
import org.springframework.jdbc.BadSqlGrammarException
25+
import org.springframework.jdbc.datasource.SingleConnectionDataSource
26+
import org.utplsql.sqldev.dal.RealtimeReporterDao
27+
import org.utplsql.sqldev.test.AbstractJdbcTest
28+
29+
class RealtimeReporterFetchSizeTest extends AbstractJdbcTest {
30+
31+
static val Logger logger = Logger.getLogger(RealtimeReporterFetchSizeTest.name);
32+
33+
@BeforeClass
34+
def static void setup() {
35+
36+
jdbcTemplate.execute('''
37+
CREATE OR REPLACE PACKAGE junit_utplsql_fetch_size_pkg is
38+
--%suite(JUnit testing)
39+
40+
--%test(test 1 - 0 seconds)
41+
PROCEDURE test_1_0;
42+
43+
--%test(test 2 - 1 seconds)
44+
PROCEDURE test_2_1;
45+
46+
--%test(test 3 - 2 seconds)
47+
PROCEDURE test_3_2;
48+
49+
--%test(test 4 - 0 seconds)
50+
PROCEDURE test_4_0;
51+
52+
--%test(test 5 - 0 seconds)
53+
PROCEDURE test_5_0;
54+
END;
55+
''')
56+
jdbcTemplate.execute('''
57+
CREATE OR REPLACE PACKAGE BODY junit_utplsql_fetch_size_pkg is
58+
PROCEDURE test_1_0 IS
59+
BEGIN
60+
NULL;
61+
END;
62+
63+
PROCEDURE test_2_1 IS
64+
BEGIN
65+
dbms_session.sleep(1);
66+
END;
67+
68+
PROCEDURE test_3_2 IS
69+
BEGIN
70+
dbms_session.sleep(2);
71+
END;
72+
73+
PROCEDURE test_4_0 IS
74+
BEGIN
75+
NULL;
76+
END;
77+
78+
PROCEDURE test_5_0 IS
79+
BEGIN
80+
NULL;
81+
END;
82+
END;
83+
''')
84+
}
85+
86+
@AfterClass
87+
def static void teardown() {
88+
try {
89+
jdbcTemplate.execute("DROP PACKAGE junit_utplsql_fetch_size_pkg")
90+
} catch (BadSqlGrammarException e) {
91+
// ignore
92+
}
93+
}
94+
95+
private def delayFreeStreamingConsumtionProducer(String reporterId) {
96+
var ds = new SingleConnectionDataSource()
97+
ds.driverClassName = "oracle.jdbc.OracleDriver"
98+
ds.url = dataSource.url
99+
ds.username = dataSource.username
100+
ds.password = dataSource.password
101+
val dao = new RealtimeReporterDao(ds.connection)
102+
dao.produceReport(reporterId, #["junit_utplsql_fetch_size_pkg"])
103+
}
104+
105+
@Test
106+
def void delayFreeStreamingConsumtion() {
107+
val long TOLERANCE_MS = 400
108+
var ds = new SingleConnectionDataSource()
109+
ds.driverClassName = "oracle.jdbc.OracleDriver"
110+
ds.url = dataSource.url
111+
ds.username = dataSource.username
112+
ds.password = dataSource.password
113+
val consumer = new TestRealtimerReporterEventTimedConsumer
114+
val reporterId = UUID.randomUUID().toString.replace("-", "");
115+
val dao = new RealtimeReporterDao(ds.connection)
116+
val Runnable runnable = [|delayFreeStreamingConsumtionProducer(reporterId)]
117+
val thread = new Thread(runnable)
118+
thread.name = "utPLSQL run test"
119+
thread.start
120+
dao.consumeReport(reporterId, consumer)
121+
logger.fine(consumer.postTestEvents.toString)
122+
Assert.assertEquals(5, consumer.postTestEvents.entrySet.size)
123+
val test_1_0 = consumer.postTestEvents.get("junit_utplsql_fetch_size_pkg.test_1_0")
124+
val test_2_1 = consumer.postTestEvents.get("junit_utplsql_fetch_size_pkg.test_2_1")
125+
val test_3_2 = consumer.postTestEvents.get("junit_utplsql_fetch_size_pkg.test_3_2")
126+
val test_4_0 = consumer.postTestEvents.get("junit_utplsql_fetch_size_pkg.test_4_0")
127+
val test_5_0 = consumer.postTestEvents.get("junit_utplsql_fetch_size_pkg.test_5_0")
128+
val test_2_1_time = test_2_1 - test_1_0
129+
logger.fine("test_2_1 time [ms]: " + test_2_1_time)
130+
Assert.assertTrue("test_2_1 runtime was too long", test_2_1_time < 1000 + TOLERANCE_MS)
131+
Assert.assertTrue("test_2_1 runtime was too short", test_2_1_time > 1000 - TOLERANCE_MS)
132+
val test_3_2_time = test_3_2 - test_2_1
133+
logger.fine("test_3_2 time [ms]: " + test_3_2_time)
134+
Assert.assertTrue("test_3_2 runtime was too long", test_3_2_time < 2000 + TOLERANCE_MS)
135+
Assert.assertTrue("test_3_2 runtime was too short", test_3_2_time > 2000 - TOLERANCE_MS)
136+
val test_4_0_time = test_4_0 - test_3_2
137+
logger.fine("test_4_0 time [ms]: " + test_4_0_time)
138+
Assert.assertTrue("test_4_0 runtime was too long", test_4_0_time < TOLERANCE_MS)
139+
val test_5_0_time = test_5_0 - test_4_0
140+
logger.fine("test_5_0 time [ms]: " + test_5_0_time)
141+
Assert.assertTrue("test_5_0 runtime was too long", test_5_0_time < TOLERANCE_MS)
142+
}
143+
144+
}

‎sqldev/src/test/java/org/utplsql/sqldev/test/dal/TestRealtimerReporterEventTimedConsumer.xtend

Copy file name to clipboard
+37Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
/*
2+
* Copyright 2019 Philipp Salvisberg <philipp.salvisberg@trivadis.com>
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
package org.utplsql.sqldev.test.dal
17+
18+
import java.util.HashMap
19+
import org.utplsql.sqldev.dal.RealtimeReporterEventConsumer
20+
import org.utplsql.sqldev.model.runner.RealtimeReporterEvent
21+
import org.utplsql.sqldev.model.runner.PostTestEvent
22+
23+
class TestRealtimerReporterEventTimedConsumer implements RealtimeReporterEventConsumer {
24+
25+
val postTestEvents = new HashMap<String, Long>
26+
27+
def getPostTestEvents() {
28+
return postTestEvents
29+
}
30+
31+
override void process(RealtimeReporterEvent event) {
32+
if (event instanceof PostTestEvent) {
33+
postTestEvents.put(event.id, System.currentTimeMillis)
34+
}
35+
}
36+
37+
}

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.