Java 내장형 MySQL 사용 방법

4283 단어 Java삽입식MySQL
이 파일은 주로 자바에 삽입된 MySQL의 사용을 소개하고 일부 응용 프로젝트에 대해 설치 버전을 제공하는 Mysql, Oracle은 필수적인 작업이다.그러나 때로는 작은 도구라면 설치하거나 이식성이 강한 소프트웨어를 설치할 수 있다.다시 데이터베이스를 설치하는 것은 비교적 번거로울 것이다.
사실 MySQL도 삽입식이 있어서 설치할 필요가 없고 사용하는 과정에서 데이터베이스를 자동으로 만들고 코드를 통해 시작하거나 닫습니다.다음은 다운로드 주소를 제공하는 코드 세션을 제공합니다.
이것은 핵심 코드 클래스입니다. 이 클래스는 Mysql의 시작과 정지, 데이터베이스의 시작 상태를 실현했습니다.

package net.simple.mysql;

import java.io.File;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
import java.util.Set;

import com.mysql.management.MysqldResource;

/**
 * 
 * @author  
 * @email [email protected] 
 * 2016 11 2   1:44:55
 *
 */
public final class EmbedMySqlServer {
 private MysqldResource mysqlInstance;
 // 
 public final Properties props;
 // 
 private String port;
 /**
 *  , 
 */
 private String embedMySqlHome;

 public EmbedMySqlServer(final Properties props) {
 this.props = props;
 }

 public EmbedMySqlServer(final Properties props, String embedMySqlHome) {
 this.embedMySqlHome = embedMySqlHome;
 this.props = props;
 }

 public final String getEmbedMySqlHome() {
 return null == embedMySqlHome ? getPlatformBaseDir() : embedMySqlHome;
 }

 /**
 *  
 * @return  .
 */
 public static String getPlatformBaseDir() {
 return System.getProperty("user.dir");
 }

 public static boolean isBlank(final String str) {
 int strLen;
 if (str == null || (strLen = str.length()) == 0) {
  return true;
 }
 for (int i = 0; i < strLen; i++) {
  if (Character.isWhitespace(str.charAt(i)) == false) {
  return false;
  }
 }
 return true;
 }

 public void startup() {
 final File baseDir = new File(getEmbedMySqlHome(), "mysql-em");
 mysqlInstance = new MysqldResource(baseDir);
 port = props.getProperty("port");
 if (isBlank(port))
  props.put("port", port = String.valueOf((int) (Math.random() * 40000)));
 final Set<Object> keys = props.keySet();
 final Map<String, String> options = new HashMap<String, String>(keys.size());
 for (final Object key : keys) {
  final String val = props.getProperty(key.toString());
  if ("".equals(val))
  options.put(key.toString(), null);
  else
  options.put(key.toString(), val.replace("{$contextPath}", getPlatformBaseDir()));
 }
 if (!mysqlInstance.isRunning())
  mysqlInstance.start("Em_MySQL", options, false, keys.contains("defaults-file"));
 }

 public String getPort() {
 return port;
 }

 /**
 *  mysql 
 */
 public boolean isRunning() {
 return null == mysqlInstance ? false : mysqlInstance.isRunning();
 }

 public void shutdown() {
 if (mysqlInstance != null)
  mysqlInstance.shutdown();
 }

 public void cleanup() {
 if (mysqlInstance != null)
  mysqlInstance.cleanup();
 }
}

다음은 시동 데모,

public static void main(String[] args) {
 try {
  Properties pro = new Properties();
  // , 
  pro.load(MysqlTest.class.getResourceAsStream("MySql_medium.properties"));
  new EmbedMySqlServer(pro).startup();
  // 
  //new EmbedMySqlServer(pro,"f:\\").startup();
  Connection conn = getTestConnection();
  System.out.println(conn.isClosed());
  conn.close();
 } catch (Exception e) {
  e.printStackTrace();
 }
 }
MySql_general.properties 일반 기계의 설정 예
MySql_medium.properties 중등 기계의 설정 예
MySql_large.properties 고배기 설정 예
구체적인 매개 변수는 서로 다른 수요에 따라 정의할 수 있다. 예를 들어 포트는 자유롭게 정의할 수 있다.
인용할 mysql 두 개의jar, mysql-connector-mxj-gpl-6-0-11-db-files.jar,mysql-connector-mxj-gpl-6-0-11.jar
코드는 Git에 있습니다. 주소는:https://git.oschina.net/eliyanfei/api_tools.git
이상은 본문의 전체 내용입니다. 여러분의 학습에 도움이 되고 저희를 많이 응원해 주십시오.

좋은 웹페이지 즐겨찾기