OmniSciDB  72c90bc290
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
Public Member Functions | Static Public Member Functions | Static Package Attributes | List of all members
com.mapd.tests.DdlConcurrencyTest Class Reference
+ Inheritance diagram for com.mapd.tests.DdlConcurrencyTest:
+ Collaboration diagram for com.mapd.tests.DdlConcurrencyTest:

Public Member Functions

List< SqlCommandThread[]> createTestThreads ()
 
final SqlCommandThread[] makeTests (final String threadName, final List< String > queries, final List< String > expectedExceptions, final List< String > cleanUpQueries, int numThreads)
 
final SqlCommandThread[] makeTests (final String threadName, final String query)
 
final SqlCommandThread[] makeTests (final String threadName, final String query, final String exception)
 
final SqlCommandThread[] makeTests (final String threadName, final String query, final List< String > exceptions)
 
final SqlCommandThread[] makeTests (final String threadName, final String query, final List< String > exceptions, final String cleanUpQueries)
 
final SqlCommandThread[] makeTests (final String threadName, final String query, final String exceptions, final String cleanUpQueries)
 
void setUpTests () throws Exception
 
void cleanUpTests (final List< SqlCommandThread[]> tests) throws Exception
 
void runTests (final List< SqlCommandThread[]> tests) throws Exception
 
- Public Member Functions inherited from com.mapd.tests.ConcurrencyTest
void testConcurrency () throws Exception
 
HeavyDBTestClient getAdminClient (String db) throws Exception
 
void runAndLog (HeavyDBTestClient client, String sql) throws Exception
 

Static Public Member Functions

static void main (String[] args) throws Exception
 
static void configure ()
 
static Logger getLogger ()
 
static String getTestName ()
 
static List< String > customizeQueriesByThreadId (final List< String > queries, int threadId)
 
- Static Public Member Functions inherited from com.mapd.tests.ConcurrencyTest
static boolean deleteDirectory (File dir)
 
static int[] getPorts ()
 
static int getNumThreads ()
 
static int getNumIterations ()
 
static boolean getEnableHeavyConnect ()
 
static boolean getEnableMonitorThread ()
 
static String getConfig ()
 
static CyclicBarrier createBarrier (int numThreadsToWait)
 
static void printErrors (ArrayList< String > exceptionTexts)
 
static int getRandomPort ()
 

Static Package Attributes

static File scratchDir
 
static String scratchDirPath
 
- Static Package Attributes inherited from com.mapd.tests.ConcurrencyTest
static final String userName = "admin"
 
static final String password = "HyperInteractive"
 
static final String localhost = "localhost"
 
static final String defaultDb = "heavyai"
 
static final int defaultNumThreads = 5
 
static final int defaultNumIterations = 5
 
static final boolean defaultEnableMonitorThread = false
 
static int numIterations = defaultNumIterations
 
static boolean enableMonitorThread = defaultEnableMonitorThread
 
static Random rand = new Random()
 

Additional Inherited Members

- Public Attributes inherited from com.mapd.tests.ConcurrencyTest
CyclicBarrier barrier
 
ArrayList< String > exceptionTexts = new ArrayList<String>()
 
- Static Public Attributes inherited from com.mapd.tests.ConcurrencyTest
static final String db = "TestDB"
 
static final int defaultPort = 6274
 
static final boolean defaultEnableHeavyConnect = true
 
static int numThreads = defaultNumThreads
 
static boolean enableHeavyConnect = defaultEnableHeavyConnect
 
static Logger logger = null
 
static String testName = ""
 
static int[] ports = null
 

Detailed Description

Definition at line 30 of file DdlConcurrencyTest.java.

Member Function Documentation

void com.mapd.tests.DdlConcurrencyTest.cleanUpTests ( final List< SqlCommandThread[]>  tests) throws Exception
inlinevirtual

Implements com.mapd.tests.ConcurrencyTest.

Definition at line 286 of file DdlConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.db, com.mapd.tests.ConcurrencyTest.defaultDb, com.mapd.tests.ConcurrencyTest.deleteDirectory(), com.mapd.tests.ConcurrencyTest.getAdminClient(), com.mapd.tests.ConcurrencyTest.runAndLog(), and com.mapd.tests.DdlConcurrencyTest.scratchDir.

286  {
287  logger.info("Starting cleanup...");
288  HeavyDBTestClient heavyAdmin = getAdminClient(defaultDb);
289  runAndLog(heavyAdmin, "DROP USER test_user;");
290  runAndLog(heavyAdmin, "DROP DATABASE " + db + ";");
291  // Some tests require (and can specify) custom cleanup.
292  for (SqlCommandThread[] testGroup : tests) {
293  for (SqlCommandThread test : testGroup) {
294  for (String query : test.cleanUpQueries) {
295  runAndLog(heavyAdmin, query);
296  }
297  }
298  }
299  deleteDirectory(scratchDir);
300  logger.info("Finished cleanup.");
301  }
com.mapd.tests.ConcurrencyTest.runAndLog
void runAndLog(HeavyDBTestClient client, String sql)
Definition: ConcurrencyTest.java:191
com.mapd.tests.ConcurrencyTest.deleteDirectory
static boolean deleteDirectory(File dir)
Definition: ConcurrencyTest.java:56
com.mapd.tests.ConcurrencyTest.getAdminClient
HeavyDBTestClient getAdminClient(String db)
Definition: ConcurrencyTest.java:187

+ Here is the call graph for this function:

static void com.mapd.tests.DdlConcurrencyTest.configure ( )
inlinestatic

Definition at line 43 of file DdlConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.enableHeavyConnect, com.mapd.tests.ConcurrencyTest.enableMonitorThread, com.mapd.tests.ConcurrencyTest.getConfig(), com.mapd.tests.ConcurrencyTest.getEnableHeavyConnect(), com.mapd.tests.ConcurrencyTest.getEnableMonitorThread(), com.mapd.tests.DdlConcurrencyTest.getLogger(), com.mapd.tests.ConcurrencyTest.getNumIterations(), com.mapd.tests.ConcurrencyTest.getNumThreads(), com.mapd.tests.ConcurrencyTest.getPorts(), com.mapd.tests.DdlConcurrencyTest.getTestName(), com.mapd.tests.ConcurrencyTest.logger, com.mapd.tests.ConcurrencyTest.numIterations, com.mapd.tests.ConcurrencyTest.numThreads, com.mapd.tests.ConcurrencyTest.ports, and com.mapd.tests.ConcurrencyTest.testName.

Referenced by com.mapd.tests.DdlConcurrencyTest.main().

43  {
44  logger = getLogger();
45  testName = getTestName();
46  ports = getPorts();
47  numThreads = getNumThreads();
48  numIterations = getNumIterations();
49  enableHeavyConnect = getEnableHeavyConnect();
50  enableMonitorThread = getEnableMonitorThread();
51  logger.info(getConfig());
52  }

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

List<SqlCommandThread[]> com.mapd.tests.DdlConcurrencyTest.createTestThreads ( )
inlinevirtual

Implements com.mapd.tests.ConcurrencyTest.

Definition at line 63 of file DdlConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.db, com.mapd.tests.ConcurrencyTest.enableHeavyConnect, com.mapd.tests.DdlConcurrencyTest.makeTests(), and com.mapd.tests.DdlConcurrencyTest.scratchDirPath.

63  {
64  logger.info("Initializing test threads...");
65  ArrayList<SqlCommandThread[]> tests = new ArrayList<>();
66  tests.add(makeTests("ShowTable", "SHOW TABLES;"));
67  tests.add(makeTests("ShowTableDetails", "SHOW TABLE DETAILS;"));
68  tests.add(makeTests("ShowCreateTable", "SHOW CREATE TABLE test_table;"));
69  tests.add(makeTests("ShowServers", "SHOW SERVERS;"));
70  tests.add(makeTests("ShowCreateServer", "SHOW CREATE SERVER test_server;"));
71  tests.add(makeTests("ShowFunctions", "SHOW FUNCTIONS;"));
72  tests.add(makeTests("ShowRuntimeFunctions", "SHOW RUNTIME FUNCTIONS;"));
73  tests.add(makeTests("ShowRuntimeTF", "SHOW RUNTIME TABLE FUNCTIONS;"));
74  tests.add(makeTests("AlterDatabase", "ALTER DATABASE " + db + " OWNER TO admin;"));
75  tests.add(makeTests("ShowUserDetails", "SHOW USER DETAILS;"));
76  tests.add(makeTests("ShowRoles", "SHOW ROLES"));
77  tests.add(makeTests("ReassignOwned", "REASSIGN OWNED BY test_user TO admin;"));
78  tests.add(makeTests("CreatePolicy",
79  "CREATE POLICY ON COLUMN test_table.i TO test_user VALUES (1);",
80  "already exists"));
81  tests.add(makeTests("DropPolicy",
82  "DROP POLICY ON COLUMN test_table.i FROM test_user;",
83  "not found"));
84  tests.add(makeTests("ShowPolicy", "SHOW POLICIES test_user;"));
85  tests.add(makeTests("ShowSupportedDataSources", "SHOW POLICIES test_user;"));
86  tests.add(makeTests(
87  "CreateTable", "CREATE TABLE IF NOT EXISTS test_table_<threadId> (i int);"));
88  tests.add(makeTests("DropTable", "DROP TABLE IF EXISTS test_table_<threadId>;"));
89  tests.add(makeTests("InsertTable", "INSERT INTO test_table (i) VALUES (2);"));
90  tests.add(makeTests("UpdateTable", "UPDATE test_table SET i = 3 WHERE i = 2;"));
91  tests.add(makeTests("AddColumn",
92  "ALTER TABLE test_table ADD (x int DEFAULT 1);",
93  "already exists"));
94  tests.add(makeTests(
95  "DropColumn", "ALTER TABLE test_table DROP COLUMN x;", "does not exist"));
96  tests.add(makeTests("RenameTable",
97  "ALTER TABLE test_table_<threadId> RENAME TO altered_table_<threadId>;",
98  Arrays.asList("not exist", "Attempted to overwrite")));
99  tests.add(makeTests("DumpTable",
100  "DUMP TABLE test_table to '" + scratchDirPath + "/dump.gz';",
101  "exists"));
102  tests.add(makeTests("RestoreTable",
103  "RESTORE TABLE restore_table_<threadId> from '" + scratchDirPath
104  + "/dump.gz';",
105  Arrays.asList("does not exist", "exists"),
106  "DROP TABLE IF EXISTS restore_table_<threadId>;"));
107  tests.add(makeTests("TruncateTable", "TRUNCATE TABLE test_table;"));
108  tests.add(makeTests("OptimizeTable", "OPTIMIZE TABLE test_table;"));
109  tests.add(
110  makeTests("CopyFrom", "COPY test_table FROM '../Tests/FsiDataFiles/1.csv';"));
111  tests.add(makeTests("CopyTo",
112  "COPY (SELECT * FROM test_table) TO '" + scratchDirPath + "/copy.csv';",
113  "exists"));
114  tests.add(makeTests("CreateDB",
115  "CREATE DATABASE IF NOT EXISTS test_db_<threadId>;",
116  Collections.emptyList(),
117  "DROP DATABASE IF EXISTS test_db_<threadId>;"));
118  tests.add(makeTests("DropDB", "DROP DATABASE IF EXISTS test_db_<threadId>;"));
119  tests.add(makeTests("CreateUser",
120  "CREATE USER test_user_<threadId> (password = 'pass');",
121  "exists",
122  "DROP USER IF EXISTS test_user_<threadId>;"));
123  tests.add(makeTests("DropUser", "DROP USER IF EXISTS test_user_<threadId>;"));
124  tests.add(makeTests("AlterUser", "ALTER USER test_user (password = 'pass');"));
125  tests.add(makeTests("RenameUser",
126  "ALTER USER test_user_<threadId> RENAME TO altered_user_<threadId>;",
127  Arrays.asList("doesn't exist", "already exists", "does not exist"),
128  "DROP USER IF EXISTS altered_user_<threadId>;"));
129  tests.add(makeTests("CreateRole",
130  "CREATE ROLE test_role_<threadId>;",
131  "already exists",
132  "DROP ROLE IF EXISTS test_role_<threadId>;"));
133  tests.add(makeTests("DropRole", "DROP ROLE IF EXISTS test_role_<threadId>;"));
134  tests.add(makeTests(
135  "GrantRole", "GRANT test_role_<threadId> TO test_user;", "does not exist"));
136  tests.add(makeTests("RevokeRole",
137  "REVOKE test_role_<threadId> FROM test_user;",
138  Arrays.asList("does not exist", "have not been granted")));
139  tests.add(makeTests("ValidateSystem", "Validate"));
140  tests.add(makeTests("CreateView",
141  "CREATE VIEW IF NOT EXISTS test_view_<threadId> AS (SELECT * FROM test_table);"));
142  tests.add(makeTests("DropView", "DROP VIEW IF EXISTS test_view_<threadId>;"));
143  if (enableHeavyConnect) {
144  tests.add(makeTests("CreateServer",
145  "CREATE SERVER IF NOT EXISTS test_server_<threadId> FOREIGN DATA WRAPPER "
146  + "delimited_file WITH (storage_type = 'LOCAL_FILE', base_path = '"
147  + System.getProperty("user.dir") + "');"));
148  tests.add(makeTests("DropServer", "DROP SERVER IF EXISTS test_server_<threadId>;"));
149  tests.add(makeTests("AlterServer",
150  "ALTER SERVER test_server SET (s3_bucket = 'diff_bucket');"));
151  tests.add(makeTests("CreateForeignTable",
152  "CREATE FOREIGN TABLE IF NOT EXISTS test_foreign_table_<threadId> "
153  + "(b BOOLEAN, t TINYINT, s SMALLINT, i INTEGER, bi BIGINT, f FLOAT, "
154  + "dc DECIMAL(10, 5), tm TIME, tp TIMESTAMP, d DATE, txt TEXT, "
155  + "txt_2 TEXT ENCODING NONE) "
156  + "SERVER default_local_delimited WITH "
157  + "(file_path = '../Tests/FsiDataFiles/scalar_types.csv', "
158  + "FRAGMENT_SIZE = 10);"));
159  tests.add(makeTests("DropForeignTable",
160  "DROP FOREIGN TABLE IF EXISTS test_foreign_table_<threadId>;"));
161  tests.add(makeTests("CreateUserMapping",
162  "CREATE USER MAPPING IF NOT EXISTS FOR PUBLIC SERVER test_server WITH "
163  + "(S3_ACCESS_KEY = 'test_key', S3_SECRET_KEY = 'test_key');"));
164  tests.add(makeTests("DropUserMapping",
165  "DROP USER MAPPING IF EXISTS FOR PUBLIC SERVER test_server;"));
166  tests.add(makeTests("AlterForeignTable",
167  "ALTER FOREIGN TABLE test_foreign_table SET (refresh_update_type = 'APPEND');"));
168  tests.add(makeTests("ShowDiskCacheUsage", "SHOW DISK CACHE USAGE;"));
169  tests.add(makeTests("RefreshForeignTable",
170  "REFRESH FOREIGN TABLES test_foreign_table_<threadId>;",
171  "does not exist"));
172  }
173  logger.info("Initialized test threads.");
174  return tests;
175  }
com.mapd.tests.DdlConcurrencyTest.makeTests
final SqlCommandThread[] makeTests(final String threadName, final List< String > queries, final List< String > expectedExceptions, final List< String > cleanUpQueries, int numThreads)
Definition: DdlConcurrencyTest.java:189

+ Here is the call graph for this function:

static List<String> com.mapd.tests.DdlConcurrencyTest.customizeQueriesByThreadId ( final List< String >  queries,
int  threadId 
)
inlinestatic

Definition at line 179 of file DdlConcurrencyTest.java.

Referenced by com.mapd.tests.DdlConcurrencyTest.makeTests().

180  {
181  List<String> customQueries = new ArrayList<String>();
182  for (String query : queries) {
183  customQueries.add(query.replaceAll("<threadId>", Integer.toString(threadId)));
184  }
185  return customQueries;
186  }

+ Here is the caller graph for this function:

static Logger com.mapd.tests.DdlConcurrencyTest.getLogger ( )
inlinestatic

Definition at line 54 of file DdlConcurrencyTest.java.

Referenced by com.mapd.tests.DdlConcurrencyTest.configure().

54  {
55  return LoggerFactory.getLogger(DdlConcurrencyTest.class);
56  }

+ Here is the caller graph for this function:

static String com.mapd.tests.DdlConcurrencyTest.getTestName ( )
inlinestatic

Definition at line 58 of file DdlConcurrencyTest.java.

Referenced by com.mapd.tests.DdlConcurrencyTest.configure().

58  {
59  return "DdlConcurrencyTest";
60  }

+ Here is the caller graph for this function:

static void com.mapd.tests.DdlConcurrencyTest.main ( String[]  args) throws Exception
inlinestatic

Definition at line 34 of file DdlConcurrencyTest.java.

References com.mapd.tests.DdlConcurrencyTest.configure(), com.mapd.tests.DdlConcurrencyTest.scratchDir, and com.mapd.tests.DdlConcurrencyTest.scratchDirPath.

34  {
35  configure();
36  scratchDir = new File("./scratch");
37  scratchDirPath = scratchDir.getCanonicalPath();
38  DdlConcurrencyTest test = new DdlConcurrencyTest();
39  test.testConcurrency();
40  }

+ Here is the call graph for this function:

final SqlCommandThread [] com.mapd.tests.DdlConcurrencyTest.makeTests ( final String  threadName,
final List< String >  queries,
final List< String >  expectedExceptions,
final List< String >  cleanUpQueries,
int  numThreads 
)
inline

Definition at line 189 of file DdlConcurrencyTest.java.

References com.mapd.tests.DdlConcurrencyTest.customizeQueriesByThreadId(), and com.mapd.tests.ConcurrencyTest.numThreads.

Referenced by com.mapd.tests.DdlConcurrencyTest.createTestThreads(), and com.mapd.tests.DdlConcurrencyTest.makeTests().

193  {
194  SqlCommandThread[] threadGroup = new SqlCommandThread[numThreads];
195  for (int threadId = 0; threadId < numThreads; ++threadId) {
196  List<String> customQueries = customizeQueriesByThreadId(queries, threadId);
197  List<String> customCleanUps = customizeQueriesByThreadId(cleanUpQueries, threadId);
198  threadGroup[threadId] = new SqlCommandThread(
199  threadName, customQueries, threadId, expectedExceptions, customCleanUps);
200  }
201  return threadGroup;
202  }
com.mapd.tests.DdlConcurrencyTest.customizeQueriesByThreadId
static List< String > customizeQueriesByThreadId(final List< String > queries, int threadId)
Definition: DdlConcurrencyTest.java:179

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

final SqlCommandThread [] com.mapd.tests.DdlConcurrencyTest.makeTests ( final String  threadName,
final String  query 
)
inline

Definition at line 205 of file DdlConcurrencyTest.java.

References com.mapd.tests.DdlConcurrencyTest.makeTests(), and com.mapd.tests.ConcurrencyTest.numThreads.

205  {
206  return makeTests(threadName,
207  Arrays.asList(query),
208  Collections.emptyList(),
209  Collections.emptyList(),
210  numThreads);
211  }
com.mapd.tests.DdlConcurrencyTest.makeTests
final SqlCommandThread[] makeTests(final String threadName, final List< String > queries, final List< String > expectedExceptions, final List< String > cleanUpQueries, int numThreads)
Definition: DdlConcurrencyTest.java:189

+ Here is the call graph for this function:

final SqlCommandThread [] com.mapd.tests.DdlConcurrencyTest.makeTests ( final String  threadName,
final String  query,
final String  exception 
)
inline

Definition at line 214 of file DdlConcurrencyTest.java.

References com.mapd.tests.DdlConcurrencyTest.makeTests(), and com.mapd.tests.ConcurrencyTest.numThreads.

215  {
216  return makeTests(threadName,
217  Arrays.asList(query),
218  Arrays.asList(exception),
219  Collections.emptyList(),
220  numThreads);
221  }
com.mapd.tests.DdlConcurrencyTest.makeTests
final SqlCommandThread[] makeTests(final String threadName, final List< String > queries, final List< String > expectedExceptions, final List< String > cleanUpQueries, int numThreads)
Definition: DdlConcurrencyTest.java:189

+ Here is the call graph for this function:

final SqlCommandThread [] com.mapd.tests.DdlConcurrencyTest.makeTests ( final String  threadName,
final String  query,
final List< String >  exceptions 
)
inline

Definition at line 224 of file DdlConcurrencyTest.java.

References com.mapd.tests.DdlConcurrencyTest.makeTests(), and com.mapd.tests.ConcurrencyTest.numThreads.

225  {
226  return makeTests(threadName,
227  Arrays.asList(query),
228  exceptions,
229  Collections.emptyList(),
230  numThreads);
231  }
com.mapd.tests.DdlConcurrencyTest.makeTests
final SqlCommandThread[] makeTests(final String threadName, final List< String > queries, final List< String > expectedExceptions, final List< String > cleanUpQueries, int numThreads)
Definition: DdlConcurrencyTest.java:189

+ Here is the call graph for this function:

final SqlCommandThread [] com.mapd.tests.DdlConcurrencyTest.makeTests ( final String  threadName,
final String  query,
final List< String >  exceptions,
final String  cleanUpQueries 
)
inline

Definition at line 234 of file DdlConcurrencyTest.java.

References com.mapd.tests.DdlConcurrencyTest.makeTests(), and com.mapd.tests.ConcurrencyTest.numThreads.

237  {
238  return makeTests(threadName,
239  Arrays.asList(query),
240  exceptions,
241  Arrays.asList(cleanUpQueries),
242  numThreads);
243  }
com.mapd.tests.DdlConcurrencyTest.makeTests
final SqlCommandThread[] makeTests(final String threadName, final List< String > queries, final List< String > expectedExceptions, final List< String > cleanUpQueries, int numThreads)
Definition: DdlConcurrencyTest.java:189

+ Here is the call graph for this function:

final SqlCommandThread [] com.mapd.tests.DdlConcurrencyTest.makeTests ( final String  threadName,
final String  query,
final String  exceptions,
final String  cleanUpQueries 
)
inline

Definition at line 246 of file DdlConcurrencyTest.java.

References com.mapd.tests.DdlConcurrencyTest.makeTests(), and com.mapd.tests.ConcurrencyTest.numThreads.

249  {
250  return makeTests(threadName,
251  Arrays.asList(query),
252  Arrays.asList(exceptions),
253  Arrays.asList(cleanUpQueries),
254  numThreads);
255  }
com.mapd.tests.DdlConcurrencyTest.makeTests
final SqlCommandThread[] makeTests(final String threadName, final List< String > queries, final List< String > expectedExceptions, final List< String > cleanUpQueries, int numThreads)
Definition: DdlConcurrencyTest.java:189

+ Here is the call graph for this function:

void com.mapd.tests.DdlConcurrencyTest.runTests ( final List< SqlCommandThread[]>  tests) throws Exception
inlinevirtual

Implements com.mapd.tests.ConcurrencyTest.

Definition at line 304 of file DdlConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.barrier, com.mapd.tests.ConcurrencyTest.createBarrier(), com.mapd.tests.ConcurrencyTest.enableMonitorThread, com.mapd.tests.ConcurrencyTest.exceptionTexts, com.mapd.tests.ConcurrencyTest.numThreads, and com.mapd.tests.ConcurrencyTest.printErrors().

304  {
305  logger.info("starting runTests.");
306 
307  // Initialize threads, but block them from executing until all threads are ready.
308  int numTests = 0;
309  for (SqlCommandThread threadGroup[] : tests) {
310  numTests += threadGroup.length;
311  }
312  barrier = createBarrier(numTests);
313 
314  for (SqlCommandThread threadGroup[] : tests) {
315  for (SqlCommandThread thread : threadGroup) {
316  thread.start();
317  }
318  }
319 
320  logger.info("Waiting for threads to sync...");
321 
322  if (enableMonitorThread) {
323  new MonitoringThread(tests, numThreads).start();
324  }
325 
326  for (SqlCommandThread threadGroup[] : tests) {
327  for (SqlCommandThread thread : threadGroup) {
328  thread.join();
329  }
330  }
331 
332  printErrors(exceptionTexts);
333 
334  logger.info("Finished runTests.");
335  }
com.mapd.tests.ConcurrencyTest.printErrors
static void printErrors(ArrayList< String > exceptionTexts)
Definition: ConcurrencyTest.java:151
com.mapd.tests.ConcurrencyTest.createBarrier
static CyclicBarrier createBarrier(int numThreadsToWait)
Definition: ConcurrencyTest.java:141
com.mapd.tests.ConcurrencyTest.exceptionTexts
ArrayList< String > exceptionTexts
Definition: ConcurrencyTest.java:54

+ Here is the call graph for this function:

void com.mapd.tests.DdlConcurrencyTest.setUpTests ( ) throws Exception
inlinevirtual

Implements com.mapd.tests.ConcurrencyTest.

Definition at line 258 of file DdlConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.db, com.mapd.tests.ConcurrencyTest.defaultDb, com.mapd.tests.ConcurrencyTest.enableHeavyConnect, com.mapd.tests.ConcurrencyTest.getAdminClient(), and com.mapd.tests.ConcurrencyTest.runAndLog().

258  {
259  logger.info("Starting Setup...");
260  scratchDir.mkdirs();
261  HeavyDBTestClient heavyAdmin = getAdminClient(defaultDb);
262  runAndLog(heavyAdmin, "DROP DATABASE IF EXISTS " + db + ";");
263  runAndLog(heavyAdmin, "CREATE DATABASE " + db + ";");
264  HeavyDBTestClient dbAdmin = getAdminClient(db);
265  runAndLog(dbAdmin, "DROP USER IF EXISTS test_user");
266  runAndLog(dbAdmin, "CREATE USER test_user (password = 'pass');");
267  runAndLog(dbAdmin, "CREATE TABLE test_table (i int);");
268  if (enableHeavyConnect) {
269  runAndLog(dbAdmin,
270  "CREATE SERVER test_server FOREIGN DATA WRAPPER delimited_file "
271  + "WITH (storage_type = 'AWS_S3', s3_bucket = 'test_bucket', "
272  + "aws_region = 'test_region');");
273  runAndLog(dbAdmin,
274  "CREATE FOREIGN TABLE IF NOT EXISTS test_foreign_table"
275  + " (b BOOLEAN, t TINYINT, s SMALLINT, i INTEGER, bi BIGINT, f FLOAT, "
276  + "dc DECIMAL(10, 5), tm TIME, tp TIMESTAMP, d DATE, txt TEXT, "
277  + "txt_2 TEXT ENCODING NONE) "
278  + "SERVER default_local_delimited WITH "
279  + "(file_path = '../Tests/FsiDataFiles/scalar_types.csv', "
280  + "FRAGMENT_SIZE = 10);");
281  }
282  logger.info("Finished Setup.");
283  }
com.mapd.tests.ConcurrencyTest.runAndLog
void runAndLog(HeavyDBTestClient client, String sql)
Definition: ConcurrencyTest.java:191
com.mapd.tests.ConcurrencyTest.getAdminClient
HeavyDBTestClient getAdminClient(String db)
Definition: ConcurrencyTest.java:187

+ Here is the call graph for this function:

Member Data Documentation

File com.mapd.tests.DdlConcurrencyTest.scratchDir
staticpackage

Definition at line 31 of file DdlConcurrencyTest.java.

Referenced by com.mapd.tests.DdlConcurrencyTest.cleanUpTests(), and com.mapd.tests.DdlConcurrencyTest.main().

String com.mapd.tests.DdlConcurrencyTest.scratchDirPath
staticpackage

Definition at line 32 of file DdlConcurrencyTest.java.

Referenced by com.mapd.tests.DdlConcurrencyTest.createTestThreads(), and com.mapd.tests.DdlConcurrencyTest.main().

The documentation for this class was generated from the following file: