3 files changed, 90 insertions, 0 deletions
diff --git a/lib/sqlalchemy/testing/plugin/plugin_base.py b/lib/sqlalchemy/testing/plugin/plugin_base.py
index 2590f3b1e..47d297b2e 100644
--- a/lib/sqlalchemy/testing/plugin/plugin_base.py
+++ b/lib/sqlalchemy/testing/plugin/plugin_base.py
@@ -31,6 +31,7 @@ if py3k:
 else:
     import ConfigParser as configparser
 
+FOLLOWER_IDENT = None
 
 # late imports
 fixtures = None
@@ -100,6 +101,11 @@ def setup_options(make_option):
                 help="Write/update profiling data.")
 
 
+def configure_follower(follower_ident):
+    global FOLLOWER_IDENT
+    FOLLOWER_IDENT = "test_%s" % follower_ident
+
+
 def read_config():
     global file_config
     file_config = configparser.ConfigParser()
@@ -135,6 +141,7 @@ def post_begin():
     from sqlalchemy import util
 
 
+
 def _log(opt_str, value, parser):
     global logging
     if not logging:
@@ -176,6 +183,7 @@ def post(fn):
     return fn
 
 
+
 @pre
 def _setup_options(opt, file_config):
     global options
@@ -214,6 +222,10 @@ def _engine_uri(options, file_config):
         db_urls.append(file_config.get('db', 'default'))
 
     for db_url in db_urls:
+        if FOLLOWER_IDENT:
+            from sqlalchemy.engine import url
+            db_url = url.make_url(db_url)
+            db_url.database = FOLLOWER_IDENT
         eng = engines.testing_engine(db_url, db_opts)
         eng.connect().close()
         config.Config.register(eng, db_opts, options, file_config, testing)
diff --git a/lib/sqlalchemy/testing/plugin/provision.py b/lib/sqlalchemy/testing/plugin/provision.py
new file mode 100644
index 000000000..d665727f1
--- /dev/null
+++ b/lib/sqlalchemy/testing/plugin/provision.py
@@ -0,0 +1,62 @@
+from sqlalchemy.engine import url as sa_url
+
+def create_follower_db(follower_ident):
+    from .. import config, engines
+
+    follower_ident = "test_%s" % follower_ident
+
+    hosts = set()
+
+    for cfg in config.Config.all_configs():
+        url = cfg.db.url
+        backend = url.get_backend_name()
+        host_conf = (
+            backend,
+            url.username, url.host, url.database)
+
+        if host_conf not in hosts:
+            if backend.startswith("postgresql"):
+                _pg_create_db(cfg.db, follower_ident)
+            elif backend.startswith("mysql"):
+                _mysql_create_db(cfg.db, follower_ident)
+
+            new_url = sa_url.make_url(str(url))
+
+            new_url.database = follower_ident
+            eng = engines.testing_engine(new_url, cfg.db_opts)
+
+            if backend.startswith("postgresql"):
+                _pg_init_db(eng)
+            elif backend.startswith("mysql"):
+                _mysql_init_db(eng)
+
+            hosts.add(host_conf)
+
+
+def _pg_create_db(eng, ident):
+    with eng.connect().execution_options(
+            isolation_level="AUTOCOMMIT") as conn:
+        try:
+            conn.execute("DROP DATABASE %s" % ident)
+        except:
+            pass
+        conn.execute("CREATE DATABASE %s" % ident)
+
+
+def _pg_init_db(eng):
+    with eng.connect() as conn:
+        conn.execute("CREATE SCHEMA test_schema")
+        conn.execute("CREATE SCHEMA test_schema_2")
+
+
+def _mysql_create_db(eng, ident):
+    with eng.connect() as conn:
+        try:
+            conn.execute("DROP DATABASE %s" % ident)
+        except:
+            pass
+        conn.execute("CREATE DATABASE %s" % ident)
+
+
+def _mysql_init_db(eng):
+    pass
diff --git a/lib/sqlalchemy/testing/plugin/pytestplugin.py b/lib/sqlalchemy/testing/plugin/pytestplugin.py
index 11238bbac..7bef644d9 100644
--- a/lib/sqlalchemy/testing/plugin/pytestplugin.py
+++ b/lib/sqlalchemy/testing/plugin/pytestplugin.py
@@ -3,6 +3,7 @@ import argparse
 import inspect
 from . import plugin_base
 import collections
+import itertools
 
 
 def pytest_addoption(parser):
@@ -24,6 +25,11 @@ def pytest_addoption(parser):
 
 
 def pytest_configure(config):
+    if hasattr(config, "slaveinput"):
+        plugin_base.configure_follower(
+            config.slaveinput["follower_ident"]
+        )
+
     plugin_base.pre_begin(config.option)
 
     plugin_base.set_coverage_flag(bool(getattr(config.option,
@@ -31,6 +37,16 @@ def pytest_configure(config):
 
     plugin_base.post_begin()
 
+_follower_count = itertools.count(1)
+
+
+def pytest_configure_node(node):
+    # the master for each node fills slaveinput dictionary
+    # which pytest-xdist will transfer to the subprocess
+    node.slaveinput["follower_ident"] = next(_follower_count)
+    from . import provision
+    provision.create_follower_db(node.slaveinput["follower_ident"])
+
 
 def pytest_collection_modifyitems(session, config, items):
     # look for all those classes that specify __backend__ and