import com.mysql.management.MysqldResourceI; //导入依赖的package包/类
@Override
public String start() {
  Map<String,String> args = new HashMap<>();
  args.put(MysqldResourceI.PORT, Integer.toString(DB_PORT));
  args.put(MysqldResourceI.INITIALIZE_USER, "true");
  args.put(MysqldResourceI.INITIALIZE_USER_NAME, DB_USER);
  args.put(MysqldResourceI.INITIALIZE_PASSWORD, DB_PASS);
  engine = new MysqldResource(new File(DB_PATH));
  engine.start("jdbdt-mysqld-thread", args);

  if (!engine.isRunning()) {
    throw new RuntimeException("MySQL did not start.");
  }

  return String.format
      (
          "jdbc:mysql://127.0.0.1:%d/jdbdt?user=%s&password=%s&createDatabaseIfNotExist=true", 
          DB_PORT, 
          DB_USER, 
          DB_PASS
          );
}
 

import com.mysql.management.MysqldResourceI; //导入依赖的package包/类
public void setUp() {
    File databaseDir = new File(new File(baseDatabaseDir), databaseName);
    
    PrintStream nps = this.getNullAppender();
    mysqldResource = new MysqldResource(databaseDir, null, null, nps, nps);        
    
    Map<String, String> database_options = new HashMap<String, String>();
    database_options.put(MysqldResourceI.PORT, Integer.toString(port));
    database_options.put(MysqldResourceI.INITIALIZE_USER, "true");
    database_options.put(MysqldResourceI.INITIALIZE_USER_NAME, username);
    database_options.put(MysqldResourceI.INITIALIZE_PASSWORD, password);        
    
    mysqldResource.start("embedded-mysqld-thread-" + System.currentTimeMillis(), database_options);

    if (!mysqldResource.isRunning()) {
        throw new RuntimeException("MySQL did not start.");
    }
}
 

import com.mysql.management.MysqldResourceI; //导入依赖的package包/类
private EmbeddedMySQL() throws InterruptedException
{
    port = AvailablePortFinder.getNextAvailable(internalCounter.getAndIncrement());

    dataDir = Files.createTempDir();

    mysqld = new MysqldResource(dataDir);

    Map<String, String> props = ImmutableMap.of(MysqldResourceI.PORT, Integer.toString(port),
                                                MysqldResourceI.INITIALIZE_USER, "true",
                                                MysqldResourceI.INITIALIZE_USER_NAME, "user",
                                                MysqldResourceI.INITIALIZE_PASSWORD, "pass",
                                                "default-time-zone", "+00:00");
    mysqld.start("mysql-daemon", props);
    if (!mysqld.isRunning()) {
        throw new IllegalStateException("MySQL failed to start");
    }
    while (!mysqld.isReadyForConnections()) { Thread.sleep(100); }
}
 

import com.mysql.management.MysqldResourceI; //导入依赖的package包/类
/**
 * Start the database.
 */
public void startDb() {
  Map<String, String> databaseOptions = new HashMap<>();
  databaseOptions.put(MysqldResourceI.PORT, Integer.toString(port));

  mysqldResource = new MysqldResource(new File(databaseDir, databaseName));
  mysqldResource.start("embedded-mysqld-db-thread-" + System.currentTimeMillis(),
      databaseOptions);

  if (!mysqldResource.isRunning()) {
    throw new RuntimeException("Failed to start embedded MySQL DB!");
  }

  LOG.debug("MySQL started successfully");
}
 

import com.mysql.management.MysqldResourceI; //导入依赖的package包/类
public boolean defaultArchitecture() {
    String guessArchStr = (String) params
            .get(MysqldResourceI.USE_DEFAULT_ARCHITECTURE);
    if (guessArchStr == null) {
        return true;
    }
    return Boolean.valueOf(guessArchStr).booleanValue();
}
 

import com.mysql.management.MysqldResourceI; //导入依赖的package包/类
public void start(String databaseName) {
    String tmpDir = System.getProperty("java.io.tmpdir");
    File baseDir = new File(tmpDir, databaseName);
    FileUtils.deleteQuietly(baseDir);
    int port = getFreePort();

    Map<String, String> databaseOptions = new HashMap<>();
    databaseOptions.put(MysqldResourceI.PORT, Integer.toString(port));

    mysqldResource = new MysqldResource(baseDir);
    mysqldResource.start("mysql", databaseOptions);

    url = "jdbc:mysql://localhost:" + port + "/" + databaseName + "?" + "createDatabaseIfNotExist=true";
}
 

import com.mysql.management.MysqldResourceI; //导入依赖的package包/类
public File getBaseDir() {
    return newFile(MysqldResourceI.BASEDIR);
}
 

import com.mysql.management.MysqldResourceI; //导入依赖的package包/类
public File getDataDir() {
    return newFile(MysqldResourceI.DATADIR);
}
 

import com.mysql.management.MysqldResourceI; //导入依赖的package包/类
public String getVersion() {
    return (String) params.get(MysqldResourceI.MYSQLD_VERSION);
}
 

import com.mysql.management.MysqldResourceI; //导入依赖的package包/类
private void ensureMysqlStarted(int port, Properties props) {
    Map serverOpts = new HashMap();
    for (Enumeration enums = props.propertyNames(); enums.hasMoreElements();) {
        String key = enums.nextElement().toString();
        if (key.startsWith(SERVER_DOT)) {
            String val = replaceNullStringWithNull(props.getProperty(key));
            serverOpts.put(key.substring(SERVER_DOT.length()), val);
        }
    }
    serverOpts.put(MysqldResourceI.PORT, Integer.toString(port));
    Object baseDirStr = serverOpts.get(MysqldResourceI.BASEDIR);
    File baseDir = new Files().newFile(baseDirStr);

    String dataDirString = (String) serverOpts.get(MysqldResourceI.DATADIR);

    File dataDir = null;
    if (dataDirString != null) {
        File ddir = new File(dataDirString);
        dataDir = new Files().validCononicalDir(ddir);
    }

    boolean guessArch = true;
    String guessArchStr = (String) serverOpts
            .get(MysqldResourceI.USE_DEFAULT_ARCHITECTURE);
    if (guessArchStr != null) {
        guessArch = Boolean.valueOf(guessArchStr).booleanValue();
    }

    String mysqldVersion = (String) serverOpts
            .get(MysqldResourceI.MYSQLD_VERSION);

    MysqldResourceI mysqld = resourceFactory.newMysqldResource(baseDir,
            dataDir, mysqldVersion, guessArch);

    if (mysqld.isRunning()) {
        int runningPort = mysqld.getPort();
        if (port != runningPort) {
            String location = mysqld.getBaseDir().getPath();
            if (dataDir != null) {
                location += " with data at " + dataDir;
            }
            String msg = "Mysqld at " + location + " is running on port "
                    + runningPort + " not " + port;
            throw new RuntimeException(msg);
        }
        return;
    }

    launchCount++;
    String threadName = "driver_launched_mysqld_" + launchCount;
    mysqld.start(threadName, serverOpts);
}