Skip to content

Commit ded5767

Browse files
committed
Rename GenericDriver to DriverBase
1 parent 906079a commit ded5767

File tree

8 files changed

+35
-44
lines changed

8 files changed

+35
-44
lines changed

vertx-db2-client/src/main/java/io/vertx/db2client/spi/DB2Driver.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -33,19 +33,18 @@
3333
import io.vertx.sqlclient.impl.pool.PoolImpl;
3434
import io.vertx.sqlclient.internal.SqlConnectionInternal;
3535
import io.vertx.sqlclient.spi.connection.ConnectionFactory;
36-
import io.vertx.sqlclient.spi.GenericDriver;
36+
import io.vertx.sqlclient.spi.DriverBase;
3737

3838
import java.util.function.Supplier;
3939

40-
public class DB2Driver extends GenericDriver<DB2ConnectOptions> {
40+
public class DB2Driver extends DriverBase<DB2ConnectOptions> {
4141

4242
private static final String DISCRIMINANT = "db2client";
4343

4444
public static final DB2Driver INSTANCE = new DB2Driver();
4545

46-
@Override
47-
protected String discriminant() {
48-
return DISCRIMINANT;
46+
public DB2Driver() {
47+
super(DISCRIMINANT);
4948
}
5049

5150
@Override

vertx-mssql-client/src/main/java/io/vertx/mssqlclient/spi/MSSQLDriver.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -28,17 +28,16 @@
2828
import io.vertx.sqlclient.spi.connection.Connection;
2929
import io.vertx.sqlclient.internal.SqlConnectionInternal;
3030
import io.vertx.sqlclient.spi.connection.ConnectionFactory;
31-
import io.vertx.sqlclient.spi.GenericDriver;
31+
import io.vertx.sqlclient.spi.DriverBase;
3232

33-
public class MSSQLDriver extends GenericDriver<MSSQLConnectOptions> {
33+
public class MSSQLDriver extends DriverBase<MSSQLConnectOptions> {
3434

3535
private static final String DISCRIMINANT = "mssqlclient";
3636

3737
public static final MSSQLDriver INSTANCE = new MSSQLDriver();
3838

39-
@Override
40-
protected String discriminant() {
41-
return DISCRIMINANT;
39+
public MSSQLDriver() {
40+
super(DISCRIMINANT);
4241
}
4342

4443
@Override

vertx-mysql-client/src/main/java/io/vertx/mysqlclient/spi/MySQLDriver.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -33,19 +33,18 @@
3333
import io.vertx.sqlclient.impl.pool.PoolImpl;
3434
import io.vertx.sqlclient.internal.SqlConnectionInternal;
3535
import io.vertx.sqlclient.spi.connection.ConnectionFactory;
36-
import io.vertx.sqlclient.spi.GenericDriver;
36+
import io.vertx.sqlclient.spi.DriverBase;
3737

3838
import java.util.function.Supplier;
3939

40-
public class MySQLDriver extends GenericDriver<MySQLConnectOptions> {
40+
public class MySQLDriver extends DriverBase<MySQLConnectOptions> {
4141

4242
private static final String DISCRIMINANT = "mysqlclient";
4343

4444
public static final MySQLDriver INSTANCE = new MySQLDriver();
4545

46-
@Override
47-
protected String discriminant() {
48-
return DISCRIMINANT;
46+
public MySQLDriver() {
47+
super(DISCRIMINANT);
4948
}
5049

5150
@Override

vertx-oracle-client/src/main/java/io/vertx/oracleclient/spi/OracleDriver.java

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -22,11 +22,11 @@
2222
import io.vertx.sqlclient.spi.connection.Connection;
2323
import io.vertx.sqlclient.internal.SqlConnectionInternal;
2424
import io.vertx.sqlclient.spi.connection.ConnectionFactory;
25-
import io.vertx.sqlclient.spi.GenericDriver;
25+
import io.vertx.sqlclient.spi.DriverBase;
2626

2727
import java.util.function.Function;
2828

29-
public class OracleDriver extends GenericDriver<OracleConnectOptions> {
29+
public class OracleDriver extends DriverBase<OracleConnectOptions> {
3030

3131
private static final String DISCRIMINANT = "oracleclient";
3232

@@ -36,12 +36,7 @@ public class OracleDriver extends GenericDriver<OracleConnectOptions> {
3636
public static final OracleDriver INSTANCE = new OracleDriver();
3737

3838
public OracleDriver() {
39-
super(AFTER_ACQUIRE, BEFORE_RECYCLE);
40-
}
41-
42-
@Override
43-
protected String discriminant() {
44-
return DISCRIMINANT;
39+
super(DISCRIMINANT, AFTER_ACQUIRE, BEFORE_RECYCLE);
4540
}
4641

4742
@Override

vertx-pg-client/src/main/java/io/vertx/pgclient/spi/PgDriver.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,19 +21,18 @@
2121
import io.vertx.sqlclient.impl.pool.PoolImpl;
2222
import io.vertx.sqlclient.internal.SqlConnectionInternal;
2323
import io.vertx.sqlclient.spi.connection.ConnectionFactory;
24-
import io.vertx.sqlclient.spi.GenericDriver;
24+
import io.vertx.sqlclient.spi.DriverBase;
2525

2626
import java.util.function.Supplier;
2727

28-
public class PgDriver extends GenericDriver<PgConnectOptions> {
28+
public class PgDriver extends DriverBase<PgConnectOptions> {
2929

3030
private static final String DISCRIMINANT = "pgclient";
3131

3232
public static final PgDriver INSTANCE = new PgDriver();
3333

34-
@Override
35-
protected String discriminant() {
36-
return DISCRIMINANT;
34+
public PgDriver() {
35+
super(DISCRIMINANT);
3736
}
3837

3938
@Override

vertx-sql-client/src/main/java/io/vertx/sqlclient/spi/GenericDriver.java renamed to vertx-sql-client/src/main/java/io/vertx/sqlclient/spi/DriverBase.java

Lines changed: 12 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -21,25 +21,29 @@
2121
import java.util.function.Function;
2222
import java.util.function.Supplier;
2323

24-
public abstract class GenericDriver<O extends SqlConnectOptions> implements Driver<O> {
24+
/**
25+
* A generic driver.
26+
* @param <O>
27+
*/
28+
public abstract class DriverBase<O extends SqlConnectOptions> implements Driver<O> {
2529

2630
private static final String SHARED_CLIENT_KEY_PREFIX = "__vertx.shared.";
2731

28-
private final String sharedClientKey = SHARED_CLIENT_KEY_PREFIX + "." + discriminant();
29-
30-
protected abstract String discriminant();
3132

33+
private final String discriminant;
34+
private final String sharedClientKey;
3235
private final Function<Connection, Future<Void>> afterAcquire;
3336
private final Function<Connection, Future<Void>> beforeRecycle;
3437

35-
public GenericDriver() {
36-
this.afterAcquire = null;
37-
this.beforeRecycle = null;
38+
public DriverBase(String discriminant) {
39+
this(discriminant, null, null);
3840
}
3941

40-
public GenericDriver(Function<Connection, Future<Void>> afterAcquire, Function<Connection, Future<Void>> beforeRecycle) {
42+
public DriverBase(String discriminant, Function<Connection, Future<Void>> afterAcquire, Function<Connection, Future<Void>> beforeRecycle) {
4143
this.afterAcquire = afterAcquire;
4244
this.beforeRecycle = beforeRecycle;
45+
this.discriminant = discriminant;
46+
this.sharedClientKey = SHARED_CLIENT_KEY_PREFIX + "." + discriminant;
4347
}
4448

4549
/**

vertx-sql-client/src/main/java/io/vertx/sqlclient/spi/connection/package-info.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,6 @@
1313
/**
1414
* <p>The Connection Service Provider Interface (SPI).</p>
1515
*
16-
* <p>This SPI is the contract between a {@link io.vertx.sqlclient.spi.GenericDriver} and a database backend.</p>
16+
* <p>This SPI is the contract between a {@link io.vertx.sqlclient.spi.DriverBase} and a database backend.</p>
1717
*/
1818
package io.vertx.sqlclient.spi.connection;
Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
import io.vertx.sqlclient.spi.protocol.SimpleQueryCommand;
2525
import io.vertx.sqlclient.spi.connection.ConnectionFactory;
2626
import io.vertx.sqlclient.spi.DatabaseMetadata;
27-
import io.vertx.sqlclient.spi.GenericDriver;
27+
import io.vertx.sqlclient.spi.DriverBase;
2828
import org.junit.Test;
2929

3030
import java.sql.JDBCType;
@@ -33,7 +33,7 @@
3333

3434
import static org.junit.Assert.*;
3535

36-
public class GenericDriverTest {
36+
public class DriverBaseTest {
3737

3838
private static class VarcharColumnDescriptor implements ColumnDescriptor {
3939

@@ -64,11 +64,7 @@ public JDBCType jdbcType() {
6464
@Test
6565
public void testSimple() {
6666

67-
GenericDriver<SqlConnectOptions> driver = new GenericDriver<SqlConnectOptions>() {
68-
@Override
69-
protected String discriminant() {
70-
return "generic";
71-
}
67+
DriverBase<SqlConnectOptions> driver = new DriverBase<SqlConnectOptions>("generic") {
7268
@Override
7369
public ConnectionFactory<SqlConnectOptions> createConnectionFactory(Vertx vertx, NetClientOptions transportOptions) {
7470
return new ConnectionFactory<>() {

0 commit comments

Comments
 (0)