diff --git a/native/src/main/java/io/ballerina/stdlib/sql/nativeimpl/QueryProcessor.java b/native/src/main/java/io/ballerina/stdlib/sql/nativeimpl/QueryProcessor.java index ef05958d..ff4524fd 100644 --- a/native/src/main/java/io/ballerina/stdlib/sql/nativeimpl/QueryProcessor.java +++ b/native/src/main/java/io/ballerina/stdlib/sql/nativeimpl/QueryProcessor.java @@ -77,10 +77,9 @@ private QueryProcessor() { * @param resultParameterProcessor post-processor of the result * @return result stream or error */ - public static BStream nativeQuery( - Environment env, BObject client, BObject paramSQLString, Object recordType, - AbstractStatementParameterProcessor statementParameterProcessor, - AbstractResultParameterProcessor resultParameterProcessor) { + public static BStream nativeQuery(Environment env, BObject client, BObject paramSQLString, Object recordType, + AbstractStatementParameterProcessor statementParameterProcessor, + AbstractResultParameterProcessor resultParameterProcessor) { TransactionResourceManager trxResourceManager = TransactionResourceManager.getInstance(); boolean withinTrxBlock = Utils.isWithinTrxBlock(trxResourceManager); boolean trxManagerEnabled = trxResourceManager.getTransactionManagerEnabled(); @@ -173,7 +172,8 @@ private static Object nativeQueryRowExecutable( BObject client, BObject paramSQLString, BTypedesc ballerinaType, AbstractStatementParameterProcessor statementParameterProcessor, - AbstractResultParameterProcessor resultParameterProcessor, boolean isWithInTrxBlock, TransactionLocalContext currentTrxContext, boolean trxManagerEnabled) { + AbstractResultParameterProcessor resultParameterProcessor, boolean isWithInTrxBlock, + TransactionLocalContext currentTrxContext, boolean trxManagerEnabled) { Type describingType = TypeUtils.getReferredType(ballerinaType.getDescribingType()); Object dbClient = client.getNativeData(Constants.DATABASE_CLIENT); if (dbClient != null) {