首页 > 数据库> 文章详细

Mysql配置多数据源

2022-06-30 18:06:29 阅读：179 来源： 互联网

标签：QueryWrapper alarmRecord 数据源配置 db Mysql import true public

<dependency>
            <groupId>xin.altitude.cms</groupId>
            <artifactId>ucode-cms-db-datasource</artifactId>
            <version>1.5.5</version>
        </dependency>

spring:
  profiles:
    active: dev
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://192.168.10.200:3306/db_dispathcher_dev_ice?useSSL=false&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&tinyInt1isBit=false&allowMultiQueries=true&serverTimezone=GMT%2B8&allowPublicKeyRetrieval=true
    username: root
    password: Aa123456
    druid:
      slave:
        enabled: true
        url: jdbc:mysql://192.168.10.200:3306/db_dev_alarm_service?useSSL=false&useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&transformedBitIsBoolean=true&tinyInt1isBit=false&allowMultiQueries=true&serverTimezone=GMT%2B8&allowPublicKeyRetrieval=true
        username: root
        password: Aa123456

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hz.icealarm.mapper.AlarmRecordMapper;
import com.hz.icealarm.pojo.AlarmRecordEntity;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import xin.altitude.cms.db.datasource.annotation.Ds;
import xin.altitude.cms.db.datasource.enums.DataSourceType;

import java.util.List;

/**
 * <p>
 * 服务实现类
 * </p>
 *
 * @author astupidcoder
 * @since 2020-05-13
 */
@Service
public class IAlarmRecordServiceImpl extends ServiceImpl<AlarmRecordMapper, AlarmRecordEntity> implements IAlarmRecordService {

    @Autowired
    private AlarmRecordMapper alarmRecordMapper;

    @Override
    @Ds(value = DataSourceType.SLAVE)
    public List<AlarmRecordEntity> findAll() {
        return alarmRecordMapper.findAll();
    }

    @Override
    @Ds(value = DataSourceType.SLAVE)
    public AlarmRecordEntity findOne(Long deviceId, String code) {
        QueryWrapper<AlarmRecordEntity> wrapper = new QueryWrapper<>();
        QueryWrapper<AlarmRecordEntity> queryWrapper = wrapper.eq("device_id", deviceId).eq("alarm_type", code)
                .isNull("alarm_handle_time").orderByDesc("alarm_time");
        List<AlarmRecordEntity> alarmRecord = alarmRecordMapper.selectList(queryWrapper);
        if (CollectionUtils.isEmpty(alarmRecord)) {
            return null;
        }
        return alarmRecord.stream().findFirst().get();
    }

    @Override
    @Ds(value = DataSourceType.SLAVE)
    public boolean save(AlarmRecordEntity alarmRecord) {
        return super.save(alarmRecord);
    }

    @Override
    @Ds(value = DataSourceType.SLAVE)
    public boolean update(AlarmRecordEntity alarmRecord) {
        QueryWrapper<AlarmRecordEntity> wrapper = new QueryWrapper<>();
        QueryWrapper<AlarmRecordEntity> updateWrapper = wrapper.eq("id", alarmRecord.getId());
        return super.update(alarmRecord, updateWrapper);
    }
}

标签：QueryWrapper,alarmRecord,数据源,配置,db,Mysql,import,true,public
来源： https://www.cnblogs.com/charkey/p/16427928.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

Mysql配置多数据源