装置配置
软件装置
下载地址：https://www.dameng.com/view_6...
本文以x86 win64 DM8为例
装置结束后关上DM数据库配置助手创立数据库，设置字符集utf8，去除字符大小写敏感
创立表空间及用户，最好是一个库对应一个用户一个表空间，创立用户时须要指定对应表空间
须要对用户调配DBA操作权限
数据表迁徙
针对现有我的项目或框架库须要同步迁徙达到梦数据库，本文以mysql5.7为例，关上DM数据迁徙工具，留神放弃对象名大小写，抉择表时全副取出再全选，迁徙的表名和字段名就与原数据库保持一致
maven援用
<dependency> <groupId>com.dameng</groupId> <artifactId>DmJdbcDriver18</artifactId> <version>8.1.1.193</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.2.0</version> </dependency> 数据库配置
应用druid治理连接池，去除wall的配置否则会报错
spring: datasource: type: com.alibaba.druid.pool.DruidDataSource driverClassName: dm.jdbc.driver.DmDriver url: jdbc:dm://localhost:5236/ROOT?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=utf-8 username: ROOT password: abcd@1234 filters: stat,slf4j兼容代码
映射成LinkHashMap
数据会在达梦的数据库驱动中强制大写，这对某些接口的数据返回给前端数据大小写呈现问题，影响范畴较大
JdbcTemplate解决
咱们能够通过混合应用jdbcTemplate进行查问的通用操作，调用query办法，传入自定义的ResultSetExtractor，失去jdbc原生的ResultSet对象，取出ResultSetMetaData转换成DmdbResultSetMetaData，其中的columns对象为公有对象且无办法拜访，通过反射取出即可，通过columns获取到数据库理论的列名
public List<LinkedHashMap<String, Object>> findListByParam(String sqlText, Map<String, Object> map) { List<LinkedHashMap<String, Object>> result = new ArrayList<>(); List<Object> paramList = new ArrayList<>(); //解析sqlText中的占位符#{xxxx} String regex = "\\#\\{(?<RegxName>[\\w.]*)\\}"; String sqlTextCopy = sqlText; Pattern pattern = Pattern.compile(regex); Matcher matcher = pattern.matcher(sqlTextCopy); while (matcher.find()) { String paramNameSymbol = matcher.group(0); sqlText = sqlText.replace(paramNameSymbol, " ? "); } logger.debug("【sqlText】：" + sqlText); //参数赋值 matcher = pattern.matcher(sqlTextCopy); while (matcher.find()) { String paramNameSymbol = matcher.group(0); String paramName = paramNameSymbol.replace("#", "").replace("{", "").replace("}", ""); Object paramValue = map.get(paramName); logger.debug("【paramName】：" + paramName); logger.debug("【paramValue】：" + paramValue); paramList.add(paramValue); } jdbcTemplate.query(sqlText, paramList.toArray(), new ResultSetExtractor<Object>() { @Override public Object extractData(ResultSet rs) throws SQLException, DataAccessException { try { ResultSetMetaData rsMetaData = rs.getMetaData(); Column[] dm_columns = null; if (dataBaseInfoUtil.getUsingDataBaseType() == GlobalEnum.DataBaseType.DM) { ResultSetMetaDataProxyImpl resultSetMetaDataProxy = (ResultSetMetaDataProxyImpl) rsMetaData; DmdbResultSetMetaData dmdbResultSetMetaData = (DmdbResultSetMetaData) resultSetMetaDataProxy.getRawObject(); Class dataClass = DmdbResultSetMetaData.class; Field field = dataClass.getDeclaredField("columns"); field.setAccessible(true); dm_columns = (Column[]) field.get(dmdbResultSetMetaData); } while (rs.next()) { LinkedHashMap<String, Object> resultitem = new LinkedHashMap<>(); for (int i = 1; i <= rsMetaData.getColumnCount(); i++) { String columnName = ""; if (dataBaseInfoUtil.getUsingDataBaseType() == GlobalEnum.DataBaseType.DM) { columnName = dm_columns[i - 1].name; } else { columnName = rsMetaData.getColumnName(i); ; } Object columnValue = rs.getObject(columnName); resultitem.put(columnName, columnValue); } result.add(resultitem); } } catch (Exception e) { e.printStackTrace(); } finally { return null; } } }); return result; }与mybaits对立数据源
在应用事务时，因为查问操作通过jdbcTemplate，更新操作通过myabtis，在某些隔离级别下会查问不到未提交的数据，所以须要对立数据源都为druid治理的datasource，这里的dynamicDataSource为我自定义的数据源解决对象，继承自spring的AbstractRoutingDataSource，为了解决多数据源状况
@Bean public SqlSessionFactory sqlSessionFactory() throws Exception { //SpringBootExecutableJarVFS.addImplClass(SpringBootVFS.class); final PackagesSqlSessionFactoryBean sessionFactory = new PackagesSqlSessionFactoryBean(); sessionFactory.setDataSource(dynamicDataSource()); sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver() .getResources("classpath*:mybatis/**/*Mapper.xml")); //敞开驼峰转换，避免带下划线的字段无奈映射 sessionFactory.getObject().getConfiguration().setMapUnderscoreToCamelCase(false); return sessionFactory.getObject(); } @Bean public JdbcTemplate jdbcTemplate(){ JdbcTemplate jdbcTemplate = null; try{ jdbcTemplate = new JdbcTemplate(dynamicDataSource()); }catch (Exception e){ e.printStackTrace(); } return jdbcTemplate; }映射成实体类
对立将查问操作后果转换成LinkHashMap键值对，再通过BeanMap映射成对应的实体类
clob长文本处理
Object value = map.get(resultkey); if(value instanceof ClobProxyImpl){ try { value = ((ClobProxyImpl) value).getSubString(1,(int)((ClobProxyImpl) value).length()); } catch (Exception e) { e.printStackTrace(); } }blob二进制解决
Object value = map.get(resultkey); if(value instanceof DmdbBlob){ try { DmdbBlob dmdbBlob = (DmdbBlob)value; value = FileUtil.convertStreamToByte(dmdbBlob.getBinaryStream()); } catch (Exception e) { e.printStackTrace(); } }