public void begin() throws SQLException {
        ConnectionTransaction connectionTransaction = getConnectionTransaction();
        if (TransactionType.isDistributedTransaction(connectionTransaction.getTransactionType())) {
            close();
            connectionTransaction.begin();
        }
        connectionContext.getTransactionContext().beginTransaction(String.valueOf(connectionTransaction.getTransactionType()));
    }
@Test
    void assertBeginTransaction() throws SQLException {
        databaseConnectionManager.begin();
        assertTrue(databaseConnectionManager.getConnectionContext().getTransactionContext().isInTransaction());
    }