Mybatisæ¹éæ§è¡SQLæä»¶ä¸çè¯å¥(å¨Springç¯å¢ä¸)ï¼
@Autowired
private SqlSession sqlSession;
InputStreamReader reader = file2Reader(file);
//æ¹éæ§è¡æä»¶ä¸çSQLè¯å¥
batchExecuteSqlFromFile(reader);
* æä»¶è½¬æReader
* @param file
* @return
private InputStreamReader file2Reader(MultipartFile file)
InputStreamReader reader = null;
InputStream inputStream = file.getInputStream();
// result = IOUtils.toString(inputStream,"UTF-8");
reader = new InputStreamReader(inputStream, "utf-8");
logger.info("------------------------------" + reader);
catch (IOException e)
e.printStackTrace();
return reader;
* è·åå½åMybatisçè¿æ¥ä¿¡æ¯
* @return
public Connection getConnection()
Connection conn = null;
conn = sqlSession.getConfiguration().getEnvironment().getDataSource().getConnection();
logger.info("===This Connection isClosed ? " + conn.isClosed());
catch (Exception e)
e.printStackTrace();
return conn;
* æ¹éæ´æ°æä»¶ä¸çSQL
* @param reader
private void batchExecuteSqlFromFile(InputStreamReader reader)
Connection connection = getConnection();
ScriptRunner scriptRunner = new ScriptRunner(connection);
scriptRunner.setLogWriter(null);
scriptRunner.setErrorLogWriter(null);
scriptRunner.setSendFullScript(true);// trueæ§è¡ææä»£ç ï¼å¦åæè¡è¯å«ä»£ç
scriptRunner.setAutoCommit(true);
scriptRunner.runScript(reader);
scriptRunner.closeConnection();
connection.close();
catch (SQLException e)