[Java] Spring执行sql脚本文件的方法

//schema 处理器
@component
public class schemahandler {
  private final string schema_sql = "classpath:schema.sql";
  @autowired
  private datasource datasource;
  @autowired
  private springcontextgetter springcontextgetter;
 
  public void execute() throws exception {
  resource resource = springcontextgetter.getapplicationcontext().getresource(schema_sql);
  scriptutils.executesqlscript(datasource.getconnection(), resource);
  }
}
 
// 获取 applicationcontext
@component
public class springcontextgetter implements applicationcontextaware {
 
  private applicationcontext applicationcontext;
 
  public applicationcontext getapplicationcontext() {
  return applicationcontext;
  }
 
  @override
  public void setapplicationcontext(applicationcontext applicationcontext) throws beansexception {
  this.applicationcontext = applicationcontext;
  }
}

private void runschemascripts() {
  list<resource> scripts = getscripts("spring.datasource.schema",
    this.properties.getschema(), "schema");
  if (!scripts.isempty()) {
    string username = this.properties.getschemausername();
    string password = this.properties.getschemapassword();
    runscripts(scripts, username, password);
    try {
    this.applicationcontext
      .publishevent(new datasourceinitializedevent(this.datasource));
    // the listener might not be registered yet, so don't rely on it.
    if (!this.initialized) {
      rundatascripts();
      this.initialized = true;
    }
    }
    catch (illegalstateexception ex) {
    logger.warn("could not send event to complete datasource initialization ("
      + ex.getmessage() + ")");
    }
  }
  }
 
/**
 * 默认拿 classpath*:schema-all.sql 和 classpath*:schema.sql
 */
private list<resource> getscripts(string propertyname, list<string> resources,
    string fallback) {
  if (resources != null) {
    return getresources(propertyname, resources, true);
  }
  string platform = this.properties.getplatform();
  list<string> fallbackresources = new arraylist<string>();
  fallbackresources.add("classpath*:" + fallback + "-" + platform + ".sql");
  fallbackresources.add("classpath*:" + fallback + ".sql");
  return getresources(propertyname, fallbackresources, false);
  }