| | |
| | | |
| | | import com.core.common.Cools; |
| | | import com.zy.common.properties.ErpDbProperties; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | |
| | | * 简单持久层框架 |
| | | * Created by vincent on 2020/11/26 |
| | | */ |
| | | @Slf4j |
| | | @Service |
| | | public class ErpSqlServer { |
| | | |
| | |
| | | return pstm.executeUpdate(); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | log.error("更新ERP中间表失败===>>" + sql); |
| | | log.error("更新ERP中间表失败===>>" + e); |
| | | return 0; |
| | | } finally { |
| | | release(); |
| | |
| | | return list; |
| | | } |
| | | |
| | | private Connection getConn() { |
| | | if (null == this.conn) { |
| | | public synchronized Connection getConn() throws SQLException { |
| | | if (null == this.conn || this.conn.isClosed()) { |
| | | try { |
| | | Class.forName(erpDbProperties.getDriver_class_name()).newInstance(); |
| | | this.conn = DriverManager.getConnection(erpDbProperties.getUr(), erpDbProperties.getUsername(), erpDbProperties.getPassword()); |
| | | } catch (Exception e) { |
| | | log.error("获取ERP数据库连接失败"); |
| | | e.printStackTrace(); |
| | | throw new RuntimeException("获取ERP数据库连接失败"); |
| | | } |