|
|
@ -16,7 +16,7 @@ |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
package cn.escheduler.dao.upgrade; |
|
|
|
package cn.escheduler.dao.upgrade; |
|
|
|
|
|
|
|
|
|
|
|
import cn.escheduler.common.utils.MysqlUtil; |
|
|
|
import cn.escheduler.common.utils.MysqlUtils; |
|
|
|
import cn.escheduler.common.utils.ScriptRunner; |
|
|
|
import cn.escheduler.common.utils.ScriptRunner; |
|
|
|
import cn.escheduler.dao.AbstractBaseDao; |
|
|
|
import cn.escheduler.dao.AbstractBaseDao; |
|
|
|
import cn.escheduler.dao.datasource.ConnectionFactory; |
|
|
|
import cn.escheduler.dao.datasource.ConnectionFactory; |
|
|
@ -98,7 +98,7 @@ public class UpgradeDao extends AbstractBaseDao { |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
throw new RuntimeException(e.getMessage(),e); |
|
|
|
throw new RuntimeException(e.getMessage(),e); |
|
|
|
} finally { |
|
|
|
} finally { |
|
|
|
MysqlUtil.realeaseResource(null, null, conn); |
|
|
|
MysqlUtils.releaseResource(null, null, conn); |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -126,7 +126,7 @@ public class UpgradeDao extends AbstractBaseDao { |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
throw new RuntimeException(e.getMessage(),e); |
|
|
|
throw new RuntimeException(e.getMessage(),e); |
|
|
|
} finally { |
|
|
|
} finally { |
|
|
|
MysqlUtil.realeaseResource(null, null, conn); |
|
|
|
MysqlUtils.releaseResource(null, null, conn); |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -152,7 +152,7 @@ public class UpgradeDao extends AbstractBaseDao { |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
throw new RuntimeException(e.getMessage(),e); |
|
|
|
throw new RuntimeException(e.getMessage(),e); |
|
|
|
} finally { |
|
|
|
} finally { |
|
|
|
MysqlUtil.realeaseResource(null, null, conn); |
|
|
|
MysqlUtils.releaseResource(null, null, conn); |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -179,7 +179,7 @@ public class UpgradeDao extends AbstractBaseDao { |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
throw new RuntimeException(e.getMessage(),e); |
|
|
|
throw new RuntimeException(e.getMessage(),e); |
|
|
|
} finally { |
|
|
|
} finally { |
|
|
|
MysqlUtil.realeaseResource(null, null, conn); |
|
|
|
MysqlUtils.releaseResource(null, null, conn); |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -207,7 +207,7 @@ public class UpgradeDao extends AbstractBaseDao { |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
throw new RuntimeException("sql: " + sql, e); |
|
|
|
throw new RuntimeException("sql: " + sql, e); |
|
|
|
} finally { |
|
|
|
} finally { |
|
|
|
MysqlUtil.realeaseResource(rs, pstmt, conn); |
|
|
|
MysqlUtils.releaseResource(rs, pstmt, conn); |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
@ -277,7 +277,7 @@ public class UpgradeDao extends AbstractBaseDao { |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
throw new RuntimeException(e.getMessage(),e); |
|
|
|
throw new RuntimeException(e.getMessage(),e); |
|
|
|
} finally { |
|
|
|
} finally { |
|
|
|
MysqlUtil.realeaseResource(null, pstmt, conn); |
|
|
|
MysqlUtils.releaseResource(null, pstmt, conn); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
@ -316,7 +316,7 @@ public class UpgradeDao extends AbstractBaseDao { |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
throw new RuntimeException(e.getMessage(),e); |
|
|
|
throw new RuntimeException(e.getMessage(),e); |
|
|
|
} finally { |
|
|
|
} finally { |
|
|
|
MysqlUtil.realeaseResource(null, pstmt, conn); |
|
|
|
MysqlUtils.releaseResource(null, pstmt, conn); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
@ -338,7 +338,7 @@ public class UpgradeDao extends AbstractBaseDao { |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
logger.error(e.getMessage(),e); |
|
|
|
throw new RuntimeException("sql: " + upgradeSQL, e); |
|
|
|
throw new RuntimeException("sql: " + upgradeSQL, e); |
|
|
|
} finally { |
|
|
|
} finally { |
|
|
|
MysqlUtil.realeaseResource(null, pstmt, conn); |
|
|
|
MysqlUtils.releaseResource(null, pstmt, conn); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|