From bb6e6f7807640debc3c634e6821f1f07d4a69d3c Mon Sep 17 00:00:00 2001 From: lizhenzhen Date: Fri, 4 Aug 2023 17:37:41 +0800 Subject: [PATCH] =?UTF-8?q?polardbx=E7=9A=84curd=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../informix/repository/impl/VccinfoDaoImpl.java | 7 +++---- .../impl/InformixHibernateServiceImpl.java | 8 ++++---- .../impl/InformixJdbcProxyServiceImpl.java | 8 ++++---- .../service/impl/InformixMybatisServiceImpl.java | 16 ++++++++-------- src/main/resources/application.yaml | 4 ++-- 5 files changed, 21 insertions(+), 22 deletions(-) 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 4234317..1631f41 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,13 @@ public class VccinfoDaoImpl implements VccinfoDao { // 第二步：设置jpql的参数 Query query = entityManager.createQuery(jpql); - query.setParameter(1, "赵六666999"); - query.setParameter(2, "%jpa%"); + query.setParameter(1, vccinfo.getVName()); + query.setParameter(2, vccinfo.getVId()); // 第三步：执行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 95c9ea6..edd890d 100644 --- a/src/main/java/com/beagle/informix/service/impl/InformixHibernateServiceImpl.java +++ b/src/main/java/com/beagle/informix/service/impl/InformixHibernateServiceImpl.java @@ -35,10 +35,10 @@ public class InformixHibernateServiceImpl implements InformixService { @Override @Transactional public void doConnectJob() throws Exception{ - insert(); -// update(); -// query(); -// delete(); +// insert(); + update(123458); + query(123458); + delete(123458); } private void insert() throws Exception{ Vccinfo vccinfo = new Vccinfo(); 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 4ab92a9..844d0f1 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); } @@ -125,7 +125,7 @@ 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:13309") .append("/") .append("testdb").append("?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=Asia/Shanghai&useServerPrepStmts=true"); DriverManager.setLoginTimeout(10); 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 085b535..32fde76 100644 --- a/src/main/java/com/beagle/informix/service/impl/InformixMybatisServiceImpl.java +++ b/src/main/java/com/beagle/informix/service/impl/InformixMybatisServiceImpl.java @@ -35,14 +35,14 @@ public class InformixMybatisServiceImpl extends ServiceImpl queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.eq(Vccinfo::getVId, "ibatis"); + queryWrapper.eq(Vccinfo::getVId, "123459"); Vccinfo vccinfo = new Vccinfo(); vccinfo.setVName("mybatis-update"); baseMapper.update(vccinfo, queryWrapper); } private void queryMethod() { - List vccinfoList = vccinfoMapper.queryList(1); + List vccinfoList = vccinfoMapper.queryList(123459); log.info("queryAll：{}", JSONUtil.toJsonStr(vccinfoList)); } private void delete() { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.eq(Vccinfo::getVId, "ibatis"); + queryWrapper.eq(Vccinfo::getVId, "123459"); baseMapper.delete(queryWrapper); } diff --git a/src/main/resources/application.yaml b/src/main/resources/application.yaml index 2b2ede3..3fe5577 100644 --- a/src/main/resources/application.yaml +++ b/src/main/resources/application.yaml @@ -4,7 +4,7 @@ spring: # url: jdbc:informix-sqli://localhost:9088/testdb:INFORMIXSERVER=informix #&useServerPrepStmts=true # url: jdbc:mysql://localhost:3307/testdb?useUnicode=true&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=Asia/Shanghai - url: jdbc:mysql://localhost:3307/testdb?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=Asia/Shanghai + url: jdbc:mysql://localhost:13309/testdb?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=Asia/Shanghai # url: jdbc:mysql://localhost:3307/testdb?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=Asia/Shanghai&useServerPrepStmts=true username: root # username: informix @@ -26,7 +26,7 @@ spring: jpa: properties: hibernate: - dialect: org.hibernate.dialect.InformixDialect + dialect: org.hibernate.dialect.MySQLDialect format_sql: true mybatis-plus: configuration: -- 2.26.0