装置结束后关上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@1234filters: 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,为了解决多数据源状况

@Beanpublic 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();}@Beanpublic 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();                    }                }作者:code2roc链接:https://juejin.cn/post/7050740247461625869起源:稀土掘金著作权归作者所有。商业转载请分割作者取得受权,非商业转载请注明出处。