package org.jeecg.modules.mdc.util;
|
|
import org.apache.ibatis.session.SqlSession;
|
import org.apache.ibatis.session.SqlSessionFactory;
|
import org.apache.ibatis.jdbc.SqlRunner;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
/**
|
* @author Lius
|
* @date 2025/1/3 13:26
|
*/
|
@Component
|
public class SqlExecutor {
|
|
@Resource
|
private SqlSessionFactory sqlSessionFactory;
|
|
public void execute(String sql) {
|
try (SqlSession sqlSession = sqlSessionFactory.openSession(true)) {
|
SqlRunner runner = new SqlRunner(sqlSession.getConnection());
|
runner.run(sql);
|
} catch (Exception e) {
|
// e.printStackTrace();
|
throw new RuntimeException("Error executing SQL: " + sql, e);
|
}
|
}
|
}
|