瀏覽代碼

backtrack on embedded pgsql

tags/2.0.1
Jonathan Cobb 3 年之前
父節點
當前提交
a7e73f4cfb
共有 3 個文件被更改,包括 2 次插入37 次删除
  1. +0
    -6
      wizard-server-test/pom.xml
  2. +2
    -2
      wizard-server-test/src/main/java/org/cobbzilla/wizardtest/RandomUtil.java
  3. +0
    -29
      wizard-server-test/src/main/java/org/cobbzilla/wizardtest/resources/ApiModelTestBase.java

+ 0
- 6
wizard-server-test/pom.xml 查看文件

@@ -35,12 +35,6 @@ This code is available under the Apache License, version 2: http://www.apache.or
<version>0.6</version>
</dependency>

<dependency>
<groupId>ru.yandex.qatools.embed</groupId>
<artifactId>postgresql-embedded</artifactId>
<version>2.10</version>
</dependency>

<dependency>
<groupId>org.cobbzilla</groupId>
<artifactId>restex</artifactId>


+ 2
- 2
wizard-server-test/src/main/java/org/cobbzilla/wizardtest/RandomUtil.java 查看文件

@@ -1,7 +1,7 @@
package org.cobbzilla.wizardtest;

import org.apache.commons.lang.math.RandomUtils;
import org.apache.commons.lang3.RandomStringUtils;
import org.apache.commons.lang3.RandomUtils;

import java.util.List;

@@ -35,7 +35,7 @@ public class RandomUtil {
return now() + (days * 1000 * 60 * 60 * 24);
}

public static boolean randomBoolean() { return RandomUtils.nextInt(0, 2) % 2 == 0; }
public static boolean randomBoolean() { return RandomUtils.nextInt(RANDOM, 2) == 0; }

public static <T> T pickMod(T[] things, int i) {
if (i <= 0 || i > things.length) i = things.length;


+ 0
- 29
wizard-server-test/src/main/java/org/cobbzilla/wizardtest/resources/ApiModelTestBase.java 查看文件

@@ -22,7 +22,6 @@ import org.cobbzilla.wizard.server.config.RestServerConfiguration;
import org.junit.AfterClass;
import org.junit.Before;
import redis.embedded.RedisServer;
import ru.yandex.qatools.embed.postgresql.EmbeddedPostgres;

import java.io.File;
import java.io.IOException;
@@ -38,13 +37,11 @@ import static java.lang.System.identityHashCode;
import static org.apache.commons.lang3.RandomStringUtils.randomAlphanumeric;
import static org.cobbzilla.util.daemon.ZillaRuntime.*;
import static org.cobbzilla.util.io.FileUtil.*;
import static org.cobbzilla.util.network.NetworkUtil.IPv4_LOCALHOST;
import static org.cobbzilla.util.network.PortPicker.pickOrDie;
import static org.cobbzilla.util.reflect.ReflectionUtil.instantiate;
import static org.cobbzilla.util.system.CommandShell.execScript;
import static org.cobbzilla.wizard.model.entityconfig.ModelSetup.modelHash;
import static org.cobbzilla.wizard.model.entityconfig.ModelSetup.setupModel;
import static ru.yandex.qatools.embed.postgresql.distribution.Version.Main.V11;

@Slf4j
public abstract class ApiModelTestBase<C extends PgRestServerConfiguration, S extends RestServer<C>>
@@ -83,10 +80,6 @@ public abstract class ApiModelTestBase<C extends PgRestServerConfiguration, S ex
@Getter private static Integer redisPort = null;
private static RedisServer redisServer = null;

protected boolean enableEmbeddedPostgreSQL () { return true; }
@Getter private static Integer pgPort = null;
private static EmbeddedPostgres pgServer = null;

@Override public void beforeStart(RestServer<C> server) {
if (enableEmbeddedRedis()) {
if (redisPort == null) {
@@ -99,23 +92,6 @@ public abstract class ApiModelTestBase<C extends PgRestServerConfiguration, S ex
}
}
}
if (enableEmbeddedPostgreSQL()) {
if (pgPort == null) {
pgPort = pickOrDie();
pgServer = new EmbeddedPostgres(V11);
try {
final DatabaseConfiguration dbConfig = getDbConfig(getConfiguration());
final String dbName = dbConfig.getDatabaseName();
final String dbUser = dbConfig.getUser();
final String dbPass = dbConfig.getPassword();
final String url = pgServer.start(IPv4_LOCALHOST, pgPort, dbName, dbUser, dbPass);
dbConfig.setUrl(url);

} catch (Exception e) {
die("beforeStart: error creating/starting PostgreSQL on port " + pgPort + ": " + shortError(e), e);
}
}
}
super.beforeStart(server);
}

@@ -136,11 +112,6 @@ public abstract class ApiModelTestBase<C extends PgRestServerConfiguration, S ex
redisServer = null;
redisPort = null;
}
if (pgServer != null) {
pgServer.stop();
pgServer = null;
pgPort = null;
}
}

public boolean doTruncateDb() { return true; }


Loading…
取消
儲存