|
18 | 18 |
|
19 | 19 | import com.github.mauricio.async.db.Configuration; |
20 | 20 | import com.github.mauricio.async.db.Connection; |
| 21 | +import com.github.mauricio.async.db.SSLConfiguration; |
21 | 22 | import io.netty.buffer.PooledByteBufAllocator; |
22 | 23 | import io.vertx.core.AsyncResult; |
23 | 24 | import io.vertx.core.Future; |
|
28 | 29 | import io.vertx.core.logging.LoggerFactory; |
29 | 30 | import io.vertx.ext.asyncsql.impl.pool.AsyncConnectionPool; |
30 | 31 | import io.vertx.ext.sql.SQLConnection; |
| 32 | +import scala.Enumeration; |
| 33 | +import scala.Function1; |
31 | 34 | import scala.Option; |
| 35 | +import scala.collection.Map; |
| 36 | +import scala.collection.Map$; |
32 | 37 | import scala.concurrent.ExecutionContext; |
33 | 38 | import scala.concurrent.duration.Duration; |
34 | 39 |
|
| 40 | +import java.io.File; |
35 | 41 | import java.nio.charset.Charset; |
36 | 42 | import java.util.concurrent.TimeUnit; |
37 | 43 |
|
@@ -116,7 +122,13 @@ protected Configuration getConfiguration( |
116 | 122 | Option.empty() : Option.apply(Duration.apply(queryTimeout, TimeUnit.MILLISECONDS)); |
117 | 123 |
|
118 | 124 | log.info("Creating configuration for " + host + ":" + port); |
119 | | - return new Configuration(username, host, port, Option.apply(password), Option.apply(database), |
| 125 | + return new Configuration( |
| 126 | + username, |
| 127 | + host, |
| 128 | + port, |
| 129 | + Option.apply(password), |
| 130 | + Option.apply(database), |
| 131 | + SSLConfiguration.apply(Map$.MODULE$.empty()), |
120 | 132 | charset, |
121 | 133 | 16777216, |
122 | 134 | PooledByteBufAllocator.DEFAULT, |
|
0 commit comments