package com.github.davidmoten.rx.jdbc;

import java.util.concurrent.Executors;

import com.github.davidmoten.rx.jdbc.connection.ConnectionProvider;
import com.github.davidmoten.rx.jdbc.connection.SingletonManualCommitConnectionProvider;

public class TransactionalQueryContext extends QueryContext {

	TransactionalQueryContext(ConnectionProvider connectionProvider) {
		super(Executors.newSingleThreadExecutor(),
				new SingletonManualCommitConnectionProvider(connectionProvider));
	}

}

@@ -33,16 +33,44 @@
 .jdbc;%0A%0A
+import java.sql.Connection;%0A
 import j
@@ -100,16 +100,16 @@
 cutors;%0A
-
 %0Aimport 
@@ -263,70 +263,280 @@
 r;%0A%0A
-public class TransactionalQueryContext extends QueryContext %7B%0A
+/**%0A * %7B@link QueryContext%7D for a transaction. Returns an executor based on a single%0A * threaded pool and a cached non-auto commit %7B@link Connection%7D.%0A */%0Aclass TransactionalQueryContext extends QueryContext %7B%0A%0A%09/**%0A%09 * Constructor.%0A%09 * %0A%09 * @param connectionProvider%0A%09 */
 %0A%09Tr

add javadoc