|  |  |  | 
|---|
|  |  |  | DataSourceSingle dataSource = method.getAnnotation(DataSourceSingle.class); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (Objects.nonNull(dataSource) && !StringUtils.isNullOrEmpty(dataSource.value())) { | 
|---|
|  |  |  | log.info("数据源指定为" + dataSource.value()); | 
|---|
|  |  |  | //log.info("数据源指定为" + dataSource.value()); | 
|---|
|  |  |  | //强制转成方法上配置的数据源,替换掉DataSourceContext中保存的数据源 | 
|---|
|  |  |  | DataSourceContext.set(dataSource.value()); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | String datasourceName = SpringContextUtil.getApplicationContext().getEnvironment().getProperty("spring.datasource.names") ; | 
|---|
|  |  |  | if(!StringUtils.isNullOrEmpty(datasourceName)){ | 
|---|
|  |  |  | log.info("根据配置数据源为" + datasourceName); | 
|---|
|  |  |  | //log.info("根据配置数据源为" + datasourceName); | 
|---|
|  |  |  | DataSourceContext.set(datasourceName); | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | log.error("数据源未指定"); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | log.info("数据库操作开始" + dataSource.value()); | 
|---|
|  |  |  | //log.info("数据库操作开始" + dataSource.value()); | 
|---|
|  |  |  | return point.proceed(); | 
|---|
|  |  |  | } finally { | 
|---|
|  |  |  | // 销毁数据源 在执行方法之后 | 
|---|
|  |  |  | log.info("数据源操作完毕" + dataSource.value()); | 
|---|
|  |  |  | //log.info("数据源操作完毕" + dataSource.value()); | 
|---|
|  |  |  | DataSourceContext.remove(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|