File tree Expand file tree Collapse file tree 15 files changed +121
-167
lines changed
src/test/kotlin/org/neo4j/connectors/kafka/data
src/test/kotlin/org/neo4j/connectors/kafka/sink
src/test/kotlin/org/neo4j/connectors/kafka/source
main/kotlin/org/neo4j/connectors/kafka/testing
test/kotlin/org/neo4j/connectors/kafka/testing/source Expand file tree Collapse file tree 15 files changed +121
-167
lines changed Original file line number Diff line number Diff line change 11<?xml version =" 1.0" encoding =" UTF-8" ?>
22<project xmlns =" http://maven.apache.org/POM/4.0.0" xmlns : xsi =" http://www.w3.org/2001/XMLSchema-instance"
3- xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
3+ xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
44 <modelVersion >4.0.0</modelVersion >
55 <parent >
66 <groupId >org.neo4j.connectors.kafka</groupId >
Original file line number Diff line number Diff line change @@ -47,7 +47,7 @@ import org.neo4j.connectors.kafka.data.ChangeEventExtensions.toConnectValue
4747import org.neo4j.driver.AuthTokens
4848import org.neo4j.driver.Driver
4949import org.neo4j.driver.GraphDatabase
50- import org.neo4j.driver.Session
50+ import org.neo4j.driver.SessionConfig
5151import org.neo4j.driver.Values
5252import org.testcontainers.containers.Neo4jContainer
5353import org.testcontainers.junit.jupiter.Container
@@ -63,26 +63,25 @@ class TypesTest {
6363 .withoutAuthentication()
6464
6565 private lateinit var driver: Driver
66- private lateinit var session: Session
6766
6867 @BeforeAll
6968 @JvmStatic
7069 fun setUpContainer () {
7170 driver = GraphDatabase .driver(neo4j.boltUrl, AuthTokens .none())
72- session = driver.session()
7371 }
7472
7573 @AfterAll
7674 @JvmStatic
7775 fun tearDownContainer () {
78- session.close()
7976 driver.close()
8077 }
8178 }
8279
8380 @BeforeEach
8481 fun `start with an empty database` () {
85- driver.session().use { it.run (" CREATE OR REPLACE DATABASE neo4j WAIT" ).consume() }
82+ driver.session(SessionConfig .forDatabase(" system" )).use {
83+ it.run (" CREATE OR REPLACE DATABASE neo4j WAIT" ).consume()
84+ }
8685 }
8786
8887 @ParameterizedTest(name = " {0}" )
Original file line number Diff line number Diff line change 11<?xml version =" 1.0" encoding =" UTF-8" ?>
22<project xmlns =" http://maven.apache.org/POM/4.0.0" xmlns : xsi =" http://www.w3.org/2001/XMLSchema-instance"
3- xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
3+ xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
44 <modelVersion >4.0.0</modelVersion >
55 <parent >
66 <groupId >org.neo4j.connectors.kafka</groupId >
Original file line number Diff line number Diff line change 11<?xml version =" 1.0" encoding =" UTF-8" ?>
22<project xmlns =" http://maven.apache.org/POM/4.0.0" xmlns : xsi =" http://www.w3.org/2001/XMLSchema-instance"
3- xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
3+ xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
44 <modelVersion >4.0.0</modelVersion >
55 <parent >
66 <groupId >org.neo4j.connectors.kafka</groupId >
Original file line number Diff line number Diff line change 11<?xml version =" 1.0" encoding =" UTF-8" ?>
22<project xmlns =" http://maven.apache.org/POM/4.0.0" xmlns : xsi =" http://www.w3.org/2001/XMLSchema-instance"
3- xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
3+ xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
44 <modelVersion >4.0.0</modelVersion >
55 <groupId >org.neo4j.connectors.kafka</groupId >
66 <artifactId >parent</artifactId >
Original file line number Diff line number Diff line change 11<?xml version =" 1.0" encoding =" UTF-8" ?>
22<project xmlns =" http://maven.apache.org/POM/4.0.0" xmlns : xsi =" http://www.w3.org/2001/XMLSchema-instance"
3- xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
3+ xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
44 <modelVersion >4.0.0</modelVersion >
55 <parent >
66 <groupId >org.neo4j.connectors.kafka</groupId >
Original file line number Diff line number Diff line change 11<?xml version =" 1.0" encoding =" UTF-8" ?>
22<project xmlns =" http://maven.apache.org/POM/4.0.0" xmlns : xsi =" http://www.w3.org/2001/XMLSchema-instance"
3- xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
3+ xsi : schemaLocation =" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >
44 <modelVersion >4.0.0</modelVersion >
55 <parent >
66 <groupId >org.neo4j.connectors.kafka</groupId >
You can’t perform that action at this time.
0 commit comments