File tree 3 files changed +2
-5
lines changed
src/test/scala/io/github/mtsongithub/doetl/sparkdialectextensions/clickhouse
3 files changed +2
-5
lines changed Original file line number Diff line number Diff line change 3
3
# ClickHouse
4
4
CH_HOST = localhost
5
5
CH_PORT = 8123
6
- CH_PORT_CLIENT = 9001
7
6
CH_DATABASE = spark
8
7
CH_USER = spark
9
8
CH_PASSWORD = 123UsedForTestOnly@!
Original file line number Diff line number Diff line change 15
15
runs-on : ubuntu-latest
16
16
services :
17
17
clickhouse :
18
- image : clickhouse/clickhouse-server
18
+ image : clickhouse/clickhouse-server:latest-alpine
19
19
env :
20
20
TZ : UTC
21
21
CLICKHOUSE_DB : spark
Original file line number Diff line number Diff line change @@ -11,20 +11,18 @@ trait ClickhouseFixture extends BeforeAndAfterEach { self: Suite =>
11
11
12
12
val jdbcHostname : String = dotenv.get(" CH_HOST" )
13
13
val jdbcPort : String = dotenv.get(" CH_PORT" )
14
- val jdbcPortClient : String = dotenv.get(" CH_PORT_CLIENT" )
15
14
val database : String = dotenv.get(" CH_DATABASE" )
16
15
val jdbcUser : String = dotenv.get(" CH_USER" )
17
16
val jdbcPassword : String = dotenv.get(" CH_PASSWORD" )
18
17
var tableName : String = _
19
18
val jdbcUrl : String = s " jdbc:clickhouse:// $jdbcHostname: ${jdbcPort}/ $database"
20
19
21
- val connectionProps = new java.util.Properties ()
22
20
var connection : Connection = _
23
21
24
22
override def beforeEach (): Unit = {
25
23
super .beforeEach()
26
24
tableName = Random .alphanumeric.take(10 ).mkString
27
- connection = DriverManager .getConnection(jdbcUrl, connectionProps )
25
+ connection = DriverManager .getConnection(jdbcUrl, jdbcUser, jdbcPassword )
28
26
}
29
27
30
28
def setupTable (tableSchema : String , engine : String = " TinyLog" ): Unit = {
You can’t perform that action at this time.
0 commit comments