diff --git a/src/main/java/com/beagle/informix/repository/impl/VccinfoDaoImpl.java b/src/main/java/com/beagle/informix/repository/impl/VccinfoDaoImpl.java index 423431710d6287bcd2339118bc50f901af04f955..59c2fd00edc1ef613a3830969b83f09fbaa9c210 100644 --- a/src/main/java/com/beagle/informix/repository/impl/VccinfoDaoImpl.java +++ b/src/main/java/com/beagle/informix/repository/impl/VccinfoDaoImpl.java @@ -69,14 +69,14 @@ public class VccinfoDaoImpl implements VccinfoDao { // 第二步：设置jpql的参数 Query query = entityManager.createQuery(jpql); - query.setParameter(1, "赵六666999"); - query.setParameter(2, "%jpa%"); + query.setParameter(1, "222"); + query.setParameter(2, 3); // 第三步：执行jpql int rows = query.executeUpdate(); System.out.println("影响的行数：" + rows); - transaction.commit(); +// transaction.commit(); } catch (Exception e) { e.printStackTrace(); // transaction.rollback(); diff --git a/src/main/java/com/beagle/informix/service/impl/InformixHibernateServiceImpl.java b/src/main/java/com/beagle/informix/service/impl/InformixHibernateServiceImpl.java index 95c9ea69c43d49fe3245efb6207ac50faa84bf13..10a0489acd76ce1217e1b7b8a50863a8662246e9 100644 --- a/src/main/java/com/beagle/informix/service/impl/InformixHibernateServiceImpl.java +++ b/src/main/java/com/beagle/informix/service/impl/InformixHibernateServiceImpl.java @@ -35,13 +35,14 @@ public class InformixHibernateServiceImpl implements InformixService { @Override @Transactional public void doConnectJob() throws Exception{ - insert(); -// update(); -// query(); -// delete(); + insert(); + update(10); + query(10); + delete(10); } private void insert() throws Exception{ Vccinfo vccinfo = new Vccinfo(); + // 主键生成策略如果声明了，这里不能再手动指定id // vccinfo.setVId(23); vccinfo.setEffective(1); vccinfo.setVName("hibernate"); @@ -71,7 +72,7 @@ public class InformixHibernateServiceImpl implements InformixService { List vccinfoList = vccinfoDao.getAllVccInfo(); - log.info("queryAll：{}",JSONUtil.toJsonStr(vccinfoDao.getAllVccInfo())); +// log.info("queryAll：{}",JSONUtil.toJsonStr(vccinfoDao.getAllVccInfo())); log.info("queryById：{}",JSONUtil.toJsonStr(vccinfoDao.getVccInfoById(id))); } private void delete(int id) { diff --git a/src/main/java/com/beagle/informix/service/impl/InformixJdbcProxyServiceImpl.java b/src/main/java/com/beagle/informix/service/impl/InformixJdbcProxyServiceImpl.java index 4ab92a91f50820ab005702c8ddc56bf2e7f198f0..ec12146cd02055f1dffeacffc66999882f734511 100644 --- a/src/main/java/com/beagle/informix/service/impl/InformixJdbcProxyServiceImpl.java +++ b/src/main/java/com/beagle/informix/service/impl/InformixJdbcProxyServiceImpl.java @@ -45,9 +45,9 @@ public class InformixJdbcProxyServiceImpl implements InformixService { Driver driver = getDriver(); Connection conn = getConnection(driver); insert(conn); -// update(conn); -// query(conn); -// delete(conn); + update(conn); + query(conn); + delete(conn); closeConnection(conn); deregisterDriver(driver); } @@ -66,23 +66,23 @@ public class InformixJdbcProxyServiceImpl implements InformixService { // 创建testdb数据库、my_test_create_table表 // 现在模拟插入、更新、删除、查询等sql // 插入 - String insertSql = "insert into cti_vccinfo_new (vccid ,vccname, effective, agentmax,ivrmax,updatekey,tclob,tblob) values (?, ? , ?, ?, ? , ?,?,? )"; + String insertSql = "insert into cti_vccinfo_new ( vccname, effective, agentmax,ivrmax,updatekey,tclob,tblob) values ( ? , ?, ?, ? , ?,?,? )"; PreparedStatement stat = conn.prepareStatement(insertSql); - stat.setObject(1, "123456"); - stat.setObject(2, "vname"); - stat.setObject(3, 1); - stat.setObject(4, 2); - stat.setObject(5, 3); - stat.setObject(6, "updatekey"); - String clobContent = "This is a very very long string"; +// stat.setObject(1, "123456"); + stat.setObject(1, "vname"); + stat.setObject(2, 1); + stat.setObject(3, 2); + stat.setObject(4, 3); + stat.setObject(5, "updatekey"); + String clobContent = "This is a very very long string df sdferwerqwsdasdsda"; // 处理clob字段 StringReader reader = new StringReader(clobContent); - stat.setClob(7, reader, clobContent.length()); + stat.setClob(6, reader, clobContent.length()); // 处理blob字段 Resource resource = resourceLoader.getResource("classpath:EnableLoopback.exe"); File inputStream = resource.getFile(); FileInputStream fis = new FileInputStream(inputStream); - stat.setBlob(8, fis); + stat.setBlob(7, fis); stat.executeUpdate(); } private void update(Connection conn) throws Exception{ @@ -125,9 +125,9 @@ public class InformixJdbcProxyServiceImpl implements InformixService { Properties properties = new Properties(); // 组装连接数据库信息 // jdbc:informix-sqli://:/:informixserver= - StringBuilder jdbcBuilder = new StringBuilder("jdbc:mysql://localhost:3307") + StringBuilder jdbcBuilder = new StringBuilder("jdbc:mysql://localhost:23307") .append("/") - .append("testdb").append("?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=Asia/Shanghai&useServerPrepStmts=true"); + .append("postgres").append("?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=Asia/Shanghai&useServerPrepStmts=true"); // useServerPrepStmts=true DriverManager.setLoginTimeout(10); properties.put("user", "root"); properties.put("password", "Apurelove9014"); diff --git a/src/main/java/com/beagle/informix/service/impl/InformixMybatisServiceImpl.java b/src/main/java/com/beagle/informix/service/impl/InformixMybatisServiceImpl.java index 085b5357db29e9ae0100b46d4bb19dd82a890d97..1d06c9ef113d3c97a180aab6081597e8882bc10e 100644 --- a/src/main/java/com/beagle/informix/service/impl/InformixMybatisServiceImpl.java +++ b/src/main/java/com/beagle/informix/service/impl/InformixMybatisServiceImpl.java @@ -42,7 +42,7 @@ public class InformixMybatisServiceImpl extends ServiceImpl