国产一级a片免费看高清,亚洲熟女中文字幕在线视频,黄三级高清在线播放,免费黄色视频在线看

CREATE DATABASE /*!32312 IF NOT EXISTS*/`bank1` /*!40100 DEFAULT CHARACTER SET utf8 */;USE `bank1`;/*Table structure for table `account_info` */DROP TABLE IF EXISTS `account_info`;CREATE TABLE `account_info` (  `id` bigint(20) NOT NULL AUTO_INCREMENT,  `account_name` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT '戶主姓名',  `account_no` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT '銀行卡號(hào)',  `account_password` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT '帳戶密碼',  `account_balance` double DEFAULT NULL COMMENT '帳戶余額',  PRIMARY KEY (`id`) USING BTREE) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8 COLLATE=utf8_bin ROW_FORMAT=DYNAMIC;/*Data for the table `account_info` */insert  into `account_info`(`id`,`account_name`,`account_no`,`account_password`,`account_balance`) values (2,'張三','1',NULL,1000);/*Table structure for table `de_duplication` */DROP TABLE IF EXISTS `de_duplication`;CREATE TABLE `de_duplication` (  `tx_no` varchar(64) COLLATE utf8_bin NOT NULL,  `create_time` datetime DEFAULT NULL,  PRIMARY KEY (`tx_no`) USING BTREE) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin ROW_FORMAT=DYNAMIC;/*Data for the table `de_duplication` *//*Table structure for table `local_cancel_log` */DROP TABLE IF EXISTS `local_cancel_log`;CREATE TABLE `local_cancel_log` (  `tx_no` varchar(64) NOT NULL COMMENT '事務(wù)id',  `create_time` datetime DEFAULT NULL,  PRIMARY KEY (`tx_no`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;/*Data for the table `local_cancel_log` *//*Table structure for table `local_confirm_log` */DROP TABLE IF EXISTS `local_confirm_log`;CREATE TABLE `local_confirm_log` (  `tx_no` varchar(64) NOT NULL COMMENT '事務(wù)id',  `create_time` datetime DEFAULT NULL,  PRIMARY KEY (`tx_no`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;/*Data for the table `local_confirm_log` *//*Table structure for table `local_trade_log` */DROP TABLE IF EXISTS `local_trade_log`;CREATE TABLE `local_trade_log` (  `tx_no` bigint(20) NOT NULL,  `create_time` datetime DEFAULT NULL,  PRIMARY KEY (`tx_no`) USING BTREE) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin ROW_FORMAT=DYNAMIC;DROP TABLE IF EXISTS `local_try_log`;CREATE TABLE `local_try_log` (  `tx_no` varchar(64) NOT NULL COMMENT '事務(wù)id',  `create_time` datetime DEFAULT NULL,  PRIMARY KEY (`tx_no`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;/*Data for the table `local_try_log` *//*Table structure for table `undo_log` */DROP TABLE IF EXISTS `undo_log`;CREATE TABLE `undo_log` (  `id` bigint(20) NOT NULL AUTO_INCREMENT,  `branch_id` bigint(20) NOT NULL,  `xid` varchar(100) NOT NULL,  `context` varchar(128) NOT NULL,  `rollback_info` longblob NOT NULL,  `log_status` int(11) NOT NULL,  `log_created` datetime NOT NULL,  `log_modified` datetime NOT NULL,  `ext` varchar(100) DEFAULT NULL,  PRIMARY KEY (`id`),  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)) ENGINE=InnoDB AUTO_INCREMENT=167 DEFAULT CHARSET=utf8;/*Data for the table `undo_log` */insert  into `undo_log`(`id`,`branch_id`,`xid`,`context`,`rollback_info`,`log_status`,`log_created`,`log_modified`,`ext`) values (166,2019228885,'192.168.1.101:8888:2019228047','serializer=jackson','{}',1,'2019-08-11 15:16:43','2019-08-11 15:16:43',NULL);

CREATE DATABASE /*!32312 IF NOT EXISTS*/`bank2` /*!40100 DEFAULT CHARACTER SET utf8 */;USE `bank2`;/*Table structure for table `account_info` */DROP TABLE IF EXISTS `account_info`;CREATE TABLE `account_info` (  `id` bigint(20) NOT NULL AUTO_INCREMENT,  `account_name` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT '戶主姓名',  `account_no` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT '銀行卡號(hào)',  `account_password` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT '帳戶密碼',  `account_balance` double DEFAULT NULL COMMENT '帳戶余額',  PRIMARY KEY (`id`) USING BTREE) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8 COLLATE=utf8_bin ROW_FORMAT=DYNAMIC;/*Data for the table `account_info` */insert  into `account_info`(`id`,`account_name`,`account_no`,`account_password`,`account_balance`) values (3,'李四的賬戶','2',NULL,0);/*Table structure for table `de_duplication` */DROP TABLE IF EXISTS `de_duplication`;CREATE TABLE `de_duplication` (  `tx_no` varchar(64) COLLATE utf8_bin NOT NULL,  `create_time` datetime DEFAULT NULL,  PRIMARY KEY (`tx_no`) USING BTREE) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin ROW_FORMAT=DYNAMIC;/*Data for the table `de_duplication` *//*Table structure for table `local_cancel_log` */DROP TABLE IF EXISTS `local_cancel_log`;CREATE TABLE `local_cancel_log` (  `tx_no` varchar(64) NOT NULL COMMENT '事務(wù)id',  `create_time` datetime DEFAULT NULL,  PRIMARY KEY (`tx_no`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;/*Data for the table `local_cancel_log` *//*Table structure for table `local_confirm_log` */DROP TABLE IF EXISTS `local_confirm_log`;CREATE TABLE `local_confirm_log` (  `tx_no` varchar(64) NOT NULL COMMENT '事務(wù)id',  `create_time` datetime DEFAULT NULL) ENGINE=InnoDB DEFAULT CHARSET=utf8;/*Data for the table `local_confirm_log` *//*Table structure for table `local_trade_log` */DROP TABLE IF EXISTS `local_trade_log`;CREATE TABLE `local_trade_log` (  `tx_no` bigint(20) NOT NULL,  `create_time` datetime DEFAULT NULL,  PRIMARY KEY (`tx_no`) USING BTREE) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin ROW_FORMAT=DYNAMIC;DROP TABLE IF EXISTS `local_try_log`;CREATE TABLE `local_try_log` (  `tx_no` varchar(64) NOT NULL COMMENT '事務(wù)id',  `create_time` datetime DEFAULT NULL,  PRIMARY KEY (`tx_no`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;/*Data for the table `local_try_log` *//*Table structure for table `undo_log` */DROP TABLE IF EXISTS `undo_log`;CREATE TABLE `undo_log` (  `id` bigint(20) NOT NULL AUTO_INCREMENT,  `branch_id` bigint(20) NOT NULL,  `xid` varchar(100) NOT NULL,  `context` varchar(128) NOT NULL,  `rollback_info` longblob NOT NULL,  `log_status` int(11) NOT NULL,  `log_created` datetime NOT NULL,  `log_modified` datetime NOT NULL,  `ext` varchar(100) DEFAULT NULL,  PRIMARY KEY (`id`),  UNIQUE KEY `ux_undo_log` (`xid`,`branch_id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;

@Configurationpublic class DatabaseConfiguration {     @Bean    @ConfigurationProperties(prefix = "spring.datasource.ds0")     public  DruidDataSource ds0() {    DruidDataSource druidDataSource = new DruidDataSource();     return      druidDataSource;}    @Primary    @Bean    public DataSource dataSource(DruidDataSource ds0) {    DataSourceProxy pds0 = new DataSourceProxy(ds0);    return pds0;     }}

@Mapper@Componentpublic interface AccountInfoDao {    //更新賬戶金額@Update("update account_info set account_balance = account_balance + #{amount} where account_no = #{accountNo}")int updateAccountBalance(@Param("accountNo") String accountNo, @Param("amount") Double amount);}

 @FeignClient(value = "seata‐demo‐bank2",fallback = Bank2ClientFallback.class) public interface Bank2Client {@GetMapping("/bank2/transfer")String transfer(@RequestParam("amount") Double amount); }@Componentpublic class Bank2ClientFallback implements Bank2Client{@Overridepublic String transfer(Double amount) {return "fallback"; }}

@Servicepublic class AccountInfoServiceImpl implements AccountInfoService {private Logger logger = LoggerFactory.getLogger(AccountInfoServiceImpl.class);@AutowiredAccountInfoDao accountInfoDao;@AutowiredBank2Client bank2Client;//張三轉(zhuǎn)賬@Override@GlobalTransactional@Transactionalpublic void updateAccountBalance(String accountNo, Double amount) {    logger.info("******** Bank1 Service Begin ... xid: {}" , RootContext.getXID()); //張三扣減金額    accountInfoDao.updateAccountBalance(accountNo,amount*‐1);    //向李四轉(zhuǎn)賬    String remoteRst = bank2Client.transfer(amount); //遠(yuǎn)程調(diào)用失敗    if(remoteRst.equals("fallback")){    throw new RuntimeException("bank1 下游服務(wù)異常"); }    //人為制造錯(cuò)誤 if(amount==3){    throw new RuntimeException("bank1 make exception 3"); }    } }

@RestControllerpublic class Bank1Controller {@AutowiredAccountInfoService accountInfoService;//轉(zhuǎn)賬@GetMapping("/transfer")public String transfer(Double amount){accountInfoService.updateAccountBalance("1",amount);return "bank1"+amount; }}

 @Mapper@Componentpublic interface AccountInfoDao {//向李四轉(zhuǎn)賬@Update("UPDATE account_info SET account_balance = account_balance + #{amount} WHERE account_no = #{accountNo}")int updateAccountBalance(@Param("accountNo") String accountNo, @Param("amount") Double amount);}

@Servicepublic class AccountInfoServiceImpl implements AccountInfoService {private Logger logger = LoggerFactory.getLogger(AccountInfoServiceImpl.class);@AutowiredAccountInfoDao accountInfoDao;@Override @Transactionalpublic void updateAccountBalance(String accountNo, Double amount) { logger.info("******** Bank2 Service Begin ... xid: {}" , RootContext.getXID()); //李四增加金額accountInfoDao.updateAccountBalance(accountNo,amount);//制造異常if(amount==2){throw new RuntimeException("bank1 make exception 2"); }} }

 @RestControllerpublic class Bank2Controller {@AutowiredAccountInfoService accountInfoService;@GetMapping("/transfer")public String transfer(Double amount){accountInfoService.updateAccountBalance("2",amount);return "bank2"+amount; }}