Skip to content

Commit d15073a

Browse files
committed
MS SQL uses the same parameter mapping than PG
1 parent 8155345 commit d15073a

File tree

2 files changed

+12
-0
lines changed

2 files changed

+12
-0
lines changed

vertx-mssql-client/src/main/java/io/vertx/mssqlclient/impl/MSSQLConnectionImpl.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,12 @@ public MSSQLConnectionImpl(MSSQLConnectionFactory factory, ContextInternal conte
2828
this.factory = factory;
2929
}
3030

31+
@Override
32+
public int appendQueryPlaceholder(StringBuilder queryBuilder, int index, int current) {
33+
queryBuilder.append('@').append(1 + index);
34+
return index;
35+
}
36+
3137
public static Future<MSSQLConnection> connect(Vertx vertx, MSSQLConnectOptions options) {
3238
ContextInternal ctx = (ContextInternal) vertx.getOrCreateContext();
3339
PromiseInternal<MSSQLConnection> promise = ctx.promise();

vertx-mssql-client/src/main/java/io/vertx/mssqlclient/impl/MSSQLPoolImpl.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,12 @@ public MSSQLPoolImpl(ContextInternal context, boolean closeVertx, MSSQLConnectOp
3737
this.pool = new ConnectionPool(connectionFactory, context, poolOptions.getMaxSize(), poolOptions.getMaxWaitQueueSize());
3838
}
3939

40+
@Override
41+
public int appendQueryPlaceholder(StringBuilder queryBuilder, int index, int current) {
42+
queryBuilder.append('@').append(1 + index);
43+
return index;
44+
}
45+
4046
@Override
4147
public void connect(Handler<AsyncResult<Connection>> completionHandler) {
4248
connectionFactory.connect().onComplete(completionHandler);

0 commit comments

Comments
 (0)