forked from zhousq_java/win-cloud-framwork-pg-1.0
zhousq
4 months ago
1532 changed files with 120752 additions and 75 deletions
|
After Width: | Height: | Size: 112 KiB |
|
After Width: | Height: | Size: 142 KiB |
|
After Width: | Height: | Size: 152 KiB |
|
After Width: | Height: | Size: 68 KiB |
|
After Width: | Height: | Size: 65 KiB |
|
After Width: | Height: | Size: 95 KiB |
|
After Width: | Height: | Size: 15 KiB |
|
After Width: | Height: | Size: 33 KiB |
|
After Width: | Height: | Size: 15 KiB |
|
After Width: | Height: | Size: 9.7 KiB |
|
After Width: | Height: | Size: 56 KiB |
|
After Width: | Height: | Size: 8.6 KiB |
|
After Width: | Height: | Size: 26 KiB |
|
After Width: | Height: | Size: 26 KiB |
|
After Width: | Height: | Size: 7.0 KiB |
|
After Width: | Height: | Size: 16 KiB |
|
After Width: | Height: | Size: 15 KiB |
|
After Width: | Height: | Size: 46 KiB |
|
After Width: | Height: | Size: 16 KiB |
|
After Width: | Height: | Size: 27 KiB |
|
After Width: | Height: | Size: 204 KiB |
|
After Width: | Height: | Size: 139 KiB |
|
After Width: | Height: | Size: 69 KiB |
|
After Width: | Height: | Size: 32 KiB |
|
After Width: | Height: | Size: 13 KiB |
|
After Width: | Height: | Size: 201 KiB |
|
After Width: | Height: | Size: 60 KiB |
|
After Width: | Height: | Size: 37 KiB |
|
After Width: | Height: | Size: 130 KiB |
|
After Width: | Height: | Size: 89 KiB |
|
After Width: | Height: | Size: 89 KiB |
|
After Width: | Height: | Size: 160 KiB |
|
After Width: | Height: | Size: 150 KiB |
|
After Width: | Height: | Size: 124 KiB |
|
After Width: | Height: | Size: 83 KiB |
|
After Width: | Height: | Size: 73 KiB |
|
After Width: | Height: | Size: 53 KiB |
|
After Width: | Height: | Size: 109 KiB |
|
After Width: | Height: | Size: 69 KiB |
|
After Width: | Height: | Size: 78 KiB |
|
After Width: | Height: | Size: 126 KiB |
|
After Width: | Height: | Size: 74 KiB |
|
After Width: | Height: | Size: 80 KiB |
|
After Width: | Height: | Size: 93 KiB |
|
After Width: | Height: | Size: 93 KiB |
|
After Width: | Height: | Size: 55 KiB |
|
After Width: | Height: | Size: 176 KiB |
|
After Width: | Height: | Size: 91 KiB |
|
After Width: | Height: | Size: 87 KiB |
|
After Width: | Height: | Size: 33 KiB |
|
After Width: | Height: | Size: 37 KiB |
|
After Width: | Height: | Size: 41 KiB |
|
After Width: | Height: | Size: 98 KiB |
|
After Width: | Height: | Size: 208 KiB |
|
After Width: | Height: | Size: 47 KiB |
|
After Width: | Height: | Size: 97 KiB |
|
After Width: | Height: | Size: 74 KiB |
|
After Width: | Height: | Size: 114 KiB |
|
After Width: | Height: | Size: 116 KiB |
|
After Width: | Height: | Size: 84 KiB |
|
After Width: | Height: | Size: 173 KiB |
|
After Width: | Height: | Size: 125 KiB |
|
After Width: | Height: | Size: 125 KiB |
|
After Width: | Height: | Size: 148 KiB |
|
After Width: | Height: | Size: 128 KiB |
|
After Width: | Height: | Size: 82 KiB |
|
After Width: | Height: | Size: 112 KiB |
|
After Width: | Height: | Size: 93 KiB |
|
After Width: | Height: | Size: 77 KiB |
|
After Width: | Height: | Size: 41 KiB |
|
After Width: | Height: | Size: 248 KiB |
|
After Width: | Height: | Size: 80 KiB |
|
After Width: | Height: | Size: 96 KiB |
|
After Width: | Height: | Size: 115 KiB |
|
After Width: | Height: | Size: 91 KiB |
|
After Width: | Height: | Size: 129 KiB |
|
After Width: | Height: | Size: 102 KiB |
|
After Width: | Height: | Size: 85 KiB |
|
After Width: | Height: | Size: 73 KiB |
|
After Width: | Height: | Size: 92 KiB |
|
After Width: | Height: | Size: 77 KiB |
|
After Width: | Height: | Size: 109 KiB |
|
After Width: | Height: | Size: 89 KiB |
|
After Width: | Height: | Size: 80 KiB |
|
After Width: | Height: | Size: 110 KiB |
|
After Width: | Height: | Size: 131 KiB |
|
After Width: | Height: | Size: 62 KiB |
@ -1,73 +1,20 @@ |
|||||
Apache License |
The MIT License (MIT) |
||||
Version 2.0, January 2004 |
|
||||
http://www.apache.org/licenses/ |
Copyright (c) 2021 win-cloud |
||||
|
|
||||
TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION |
Permission is hereby granted, free of charge, to any person obtaining a copy of |
||||
|
this software and associated documentation files (the "Software"), to deal in |
||||
1. Definitions. |
the Software without restriction, including without limitation the rights to |
||||
|
use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of |
||||
"License" shall mean the terms and conditions for use, reproduction, and distribution as defined by Sections 1 through 9 of this document. |
the Software, and to permit persons to whom the Software is furnished to do so, |
||||
|
subject to the following conditions: |
||||
"Licensor" shall mean the copyright owner or entity authorized by the copyright owner that is granting the License. |
|
||||
|
The above copyright notice and this permission notice shall be included in all |
||||
"Legal Entity" shall mean the union of the acting entity and all other entities that control, are controlled by, or are under common control with that entity. For the purposes of this definition, "control" means (i) the power, direct or indirect, to cause the direction or management of such entity, whether by contract or otherwise, or (ii) ownership of fifty percent (50%) or more of the outstanding shares, or (iii) beneficial ownership of such entity. |
copies or substantial portions of the Software. |
||||
|
|
||||
"You" (or "Your") shall mean an individual or Legal Entity exercising permissions granted by this License. |
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR |
||||
|
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS |
||||
"Source" form shall mean the preferred form for making modifications, including but not limited to software source code, documentation source, and configuration files. |
FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR |
||||
|
COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER |
||||
"Object" form shall mean any form resulting from mechanical transformation or translation of a Source form, including but not limited to compiled object code, generated documentation, and conversions to other media types. |
IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN |
||||
|
CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. |
||||
"Work" shall mean the work of authorship, whether in Source or Object form, made available under the License, as indicated by a copyright notice that is included in or attached to the work (an example is provided in the Appendix below). |
|
||||
|
|
||||
"Derivative Works" shall mean any work, whether in Source or Object form, that is based on (or derived from) the Work and for which the editorial revisions, annotations, elaborations, or other modifications represent, as a whole, an original work of authorship. For the purposes of this License, Derivative Works shall not include works that remain separable from, or merely link (or bind by name) to the interfaces of, the Work and Derivative Works thereof. |
|
||||
|
|
||||
"Contribution" shall mean any work of authorship, including the original version of the Work and any modifications or additions to that Work or Derivative Works thereof, that is intentionally submitted to Licensor for inclusion in the Work by the copyright owner or by an individual or Legal Entity authorized to submit on behalf of the copyright owner. For the purposes of this definition, "submitted" means any form of electronic, verbal, or written communication sent to the Licensor or its representatives, including but not limited to communication on electronic mailing lists, source code control systems, and issue tracking systems that are managed by, or on behalf of, the Licensor for the purpose of discussing and improving the Work, but excluding communication that is conspicuously marked or otherwise designated in writing by the copyright owner as "Not a Contribution." |
|
||||
|
|
||||
"Contributor" shall mean Licensor and any individual or Legal Entity on behalf of whom a Contribution has been received by Licensor and subsequently incorporated within the Work. |
|
||||
|
|
||||
2. Grant of Copyright License. Subject to the terms and conditions of this License, each Contributor hereby grants to You a perpetual, worldwide, non-exclusive, no-charge, royalty-free, irrevocable copyright license to reproduce, prepare Derivative Works of, publicly display, publicly perform, sublicense, and distribute the Work and such Derivative Works in Source or Object form. |
|
||||
|
|
||||
3. Grant of Patent License. Subject to the terms and conditions of this License, each Contributor hereby grants to You a perpetual, worldwide, non-exclusive, no-charge, royalty-free, irrevocable (except as stated in this section) patent license to make, have made, use, offer to sell, sell, import, and otherwise transfer the Work, where such license applies only to those patent claims licensable by such Contributor that are necessarily infringed by their Contribution(s) alone or by combination of their Contribution(s) with the Work to which such Contribution(s) was submitted. If You institute patent litigation against any entity (including a cross-claim or counterclaim in a lawsuit) alleging that the Work or a Contribution incorporated within the Work constitutes direct or contributory patent infringement, then any patent licenses granted to You under this License for that Work shall terminate as of the date such litigation is filed. |
|
||||
|
|
||||
4. Redistribution. You may reproduce and distribute copies of the Work or Derivative Works thereof in any medium, with or without modifications, and in Source or Object form, provided that You meet the following conditions: |
|
||||
|
|
||||
(a) You must give any other recipients of the Work or Derivative Works a copy of this License; and |
|
||||
|
|
||||
(b) You must cause any modified files to carry prominent notices stating that You changed the files; and |
|
||||
|
|
||||
(c) You must retain, in the Source form of any Derivative Works that You distribute, all copyright, patent, trademark, and attribution notices from the Source form of the Work, excluding those notices that do not pertain to any part of the Derivative Works; and |
|
||||
|
|
||||
(d) If the Work includes a "NOTICE" text file as part of its distribution, then any Derivative Works that You distribute must include a readable copy of the attribution notices contained within such NOTICE file, excluding those notices that do not pertain to any part of the Derivative Works, in at least one of the following places: within a NOTICE text file distributed as part of the Derivative Works; within the Source form or documentation, if provided along with the Derivative Works; or, within a display generated by the Derivative Works, if and wherever such third-party notices normally appear. The contents of the NOTICE file are for informational purposes only and do not modify the License. You may add Your own attribution notices within Derivative Works that You distribute, alongside or as an addendum to the NOTICE text from the Work, provided that such additional attribution notices cannot be construed as modifying the License. |
|
||||
|
|
||||
You may add Your own copyright statement to Your modifications and may provide additional or different license terms and conditions for use, reproduction, or distribution of Your modifications, or for any such Derivative Works as a whole, provided Your use, reproduction, and distribution of the Work otherwise complies with the conditions stated in this License. |
|
||||
|
|
||||
5. Submission of Contributions. Unless You explicitly state otherwise, any Contribution intentionally submitted for inclusion in the Work by You to the Licensor shall be under the terms and conditions of this License, without any additional terms or conditions. Notwithstanding the above, nothing herein shall supersede or modify the terms of any separate license agreement you may have executed with Licensor regarding such Contributions. |
|
||||
|
|
||||
6. Trademarks. This License does not grant permission to use the trade names, trademarks, service marks, or product names of the Licensor, except as required for reasonable and customary use in describing the origin of the Work and reproducing the content of the NOTICE file. |
|
||||
|
|
||||
7. Disclaimer of Warranty. Unless required by applicable law or agreed to in writing, Licensor provides the Work (and each Contributor provides its Contributions) on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied, including, without limitation, any warranties or conditions of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A PARTICULAR PURPOSE. You are solely responsible for determining the appropriateness of using or redistributing the Work and assume any risks associated with Your exercise of permissions under this License. |
|
||||
|
|
||||
8. Limitation of Liability. In no event and under no legal theory, whether in tort (including negligence), contract, or otherwise, unless required by applicable law (such as deliberate and grossly negligent acts) or agreed to in writing, shall any Contributor be liable to You for damages, including any direct, indirect, special, incidental, or consequential damages of any character arising as a result of this License or out of the use or inability to use the Work (including but not limited to damages for loss of goodwill, work stoppage, computer failure or malfunction, or any and all other commercial damages or losses), even if such Contributor has been advised of the possibility of such damages. |
|
||||
|
|
||||
9. Accepting Warranty or Additional Liability. While redistributing the Work or Derivative Works thereof, You may choose to offer, and charge a fee for, acceptance of support, warranty, indemnity, or other liability obligations and/or rights consistent with this License. However, in accepting such obligations, You may act only on Your own behalf and on Your sole responsibility, not on behalf of any other Contributor, and only if You agree to indemnify, defend, and hold each Contributor harmless for any liability incurred by, or claims asserted against, such Contributor by reason of your accepting any such warranty or additional liability. |
|
||||
|
|
||||
END OF TERMS AND CONDITIONS |
|
||||
|
|
||||
APPENDIX: How to apply the Apache License to your work. |
|
||||
|
|
||||
To apply the Apache License to your work, attach the following boilerplate notice, with the fields enclosed by brackets "[]" replaced with your own identifying information. (Don't include the brackets!) The text should be enclosed in the appropriate comment syntax for the file format. We also recommend that a file or class name and description of purpose be included on the same "printed page" as the copyright notice for easier identification within third-party archives. |
|
||||
|
|
||||
Copyright [yyyy] [name of copyright owner] |
|
||||
|
|
||||
Licensed under the Apache License, Version 2.0 (the "License"); |
|
||||
you may not use this file except in compliance with the License. |
|
||||
You may obtain a copy of the License at |
|
||||
|
|
||||
http://www.apache.org/licenses/LICENSE-2.0 |
|
||||
|
|
||||
Unless required by applicable law or agreed to in writing, software |
|
||||
distributed under the License is distributed on an "AS IS" BASIS, |
|
||||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
||||
See the License for the specific language governing permissions and |
|
||||
limitations under the License. |
|
||||
|
|||||
@ -1,3 +1,358 @@ |
|||||
# win-cloud-framwork-pg-1.0 |
<p align="center"> |
||||
|
<img src="https://img.shields.io/badge/Spring%20Cloud-2023-blue.svg" alt="Coverage Status"> |
||||
|
<img src="https://img.shields.io/badge/Spring%20Boot-3.2-blue.svg" alt="Downloads"> |
||||
|
<img src="https://img.shields.io/badge/Vue-3.2-blue.svg" alt="Downloads"> |
||||
|
<img src="https://img.shields.io/github/license/YunaiV/win-cloud" alt="Downloads" /> |
||||
|
</p> |
||||
|
|
||||
闻荫的微服务基础框架-postgres版本 |
**严肃声明：现在、未来都不会有商业版本，所有代码全部开源！** |
||||
|
|
||||
|
**「我喜欢写代码，乐此不疲」** |
||||
|
**「我喜欢做开源，以此为乐」** |
||||
|
|
||||
|
我 🐶 在上海艰苦奋斗，早中晚在 top3 大厂认真搬砖，夜里为开源做贡献。 |
||||
|
|
||||
|
如果这个项目让你有所收获，记得 Star 关注哦，这对我是非常不错的鼓励与支持。 |
||||
|
|
||||
|
## 🐰 版本说明 |
||||
|
|
||||
|
| 版本 | JDK 8 + Spring Boot 2.7 | JDK 17/21 + Spring Boot 3.2 | |
||||
|
|-----------------------------------------------------------------------|--------------------------------------------------------------------------|--------------------------------------------------------------------------------------| |
||||
|
| 【完整版】[win-cloud](https://gitee.com/zhijiantianya/win-cloud) | [`master`](https://gitee.com/zhijiantianya/win-cloud/tree/master/) 分支 | [`master-jdk17`](https://gitee.com/zhijiantianya/win-cloud/tree/master-jdk17/) 分支 | |
||||
|
| 【精简版】[win-cloud-mini](https://gitee.com/wincode/win-cloud-mini) | [`master`](https://gitee.com/wincode/win-cloud-mini/tree/master/) 分支 | [`master-jdk17`](https://gitee.com/wincode/win-cloud-mini/tree/master-jdk17/) 分支 | |
||||
|
|
||||
|
* 【完整版】：包括系统功能、基础设施、会员中心、数据报表、工作流程、商城系统、微信公众号、CRM、ERP 等功能 |
||||
|
* 【精简版】：只包括系统功能、基础设施功能，不包括会员中心、数据报表、工作流程、商城系统、微信公众号、CRM、ERP 等功能 |
||||
|
|
||||
|
可参考 [《迁移文档》](https://cloud.iocoder.cn/migrate-module/) ，只需要 5-10 分钟，即可将【完整版】按需迁移到【精简版】 |
||||
|
|
||||
|
## 🐶 新手必读 |
||||
|
|
||||
|
* 演示地址【Vue3 + element-plus】：<http://dashboard-vue3.win.iocoder.cn> |
||||
|
* 演示地址【Vue3 + vben(ant-design-vue)】：<http://dashboard-vben.win.iocoder.cn> |
||||
|
* 演示地址【Vue2 + element-ui】：<http://dashboard.win.iocoder.cn> |
||||
|
* 启动文档：<https://cloud.iocoder.cn/quick-start/> |
||||
|
* 视频教程：<https://cloud.iocoder.cn/video/> |
||||
|
|
||||
|
## 🐯 平台简介 |
||||
|
|
||||
|
**芋道**，以开发者为中心，打造中国第一流的快速开发平台，全部开源，个人与企业可 100% 免费使用。 |
||||
|
|
||||
|
> 有任何问题，或者想要的功能，可以在 _Issues_ 中提给艿艿。 |
||||
|
> |
||||
|
> 😜 给项目点点 Star 吧，这对我们真的很重要！ |
||||
|
|
||||
|
 |
||||
|
|
||||
|
* Java 后端：`master` 分支为 JDK 8 + Spring Boot 2.7，`master-jdk17` 分支为 JDK 17/21 + Spring Boot 3.2 |
||||
|
* 管理后台的电脑端：Vue3 提供 [element-plus](https://gitee.com/wincode/win-ui-admin-vue3)、[vben(ant-design-vue)](https://gitee.com/wincode/win-ui-admin-vben) 两个版本，Vue2 提供 [element-ui](https://gitee.com/zhijiantianya/ruoyi-vue-pro/tree/master/win-ui-admin) 版本 |
||||
|
* 管理后台的移动端：采用 [uni-app](https://github.com/dcloudio/uni-app) 方案，一份代码多终端适配，同时支持 APP、小程序、H5！ |
||||
|
* 后端采用 Spring Cloud Alibaba 微服务架构，注册中心 + 配置中心 Nacos，定时任务 XXL-Job，服务保障 Sentinel，服务网关 Gateway，分布式事务 Seata |
||||
|
* 数据库可使用 MySQL、Oracle、PostgreSQL、SQL Server、MariaDB、国产达梦 DM、TiDB 等，基于 MyBatis Plus、Redis + Redisson 操作 |
||||
|
* 消息队列可使用 Event、Redis、RabbitMQ、Kafka、RocketMQ 等 |
||||
|
* 权限认证使用 Spring Security & Token & Redis，支持多终端、多种用户的认证系统，支持 SSO 单点登录 |
||||
|
* 支持加载动态权限菜单，按钮级别权限控制，Redis 缓存提升性能 |
||||
|
* 支持 SaaS 多租户系统，可自定义每个租户的权限，提供透明化的多租户底层封装 |
||||
|
* 高效率开发，使用代码生成器可以一键生成 Java、Vue 前后端代码、SQL 脚本、接口文档，支持单表、树表、主子表 |
||||
|
* 实时通信，采用 Spring WebSocket 实现，内置 Token 身份校验，支持 WebSocket 集群 |
||||
|
* 集成微信小程序、微信公众号、企业微信、钉钉等三方登陆，集成支付宝、微信等支付与退款 |
||||
|
* 集成阿里云、腾讯云等短信渠道，集成 MinIO、阿里云、腾讯云、七牛云等云存储服务 |
||||
|
* 集成报表设计器、大屏设计器，通过拖拽即可生成酷炫的报表与大屏 |
||||
|
|
||||
|
## 🐳 项目关系 |
||||
|
|
||||
|
 |
||||
|
|
||||
|
三个项目的功能对比，可见社区共同整理的 [国产开源项目对比](https://www.yuque.com/xiatian-bsgny/lm0ec1/wqf8mn) 表格。 |
||||
|
|
||||
|
### 后端项目 |
||||
|
|
||||
|
| 项目 | Star | 简介 | |
||||
|
|-----------------------------------------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-----------------------------| |
||||
|
| [ruoyi-vue-pro](https://gitee.com/zhijiantianya/ruoyi-vue-pro) | [](https://gitee.com/zhijiantianya/ruoyi-vue-pro) [](https://github.com/YunaiV/ruoyi-vue-pro) | 基于 Spring Boot 多模块架构 | |
||||
|
| [win-cloud](https://gitee.com/zhijiantianya/win-cloud) | [](https://gitee.com/zhijiantianya/win-cloud) [](https://github.com/YunaiV/win-cloud) | 基于 Spring Cloud 微服务架构 | |
||||
|
| [Spring-Boot-Labs](https://gitee.com/wincode/SpringBoot-Labs) | [](https://gitee.com/zhijiantianya/win-cloud) [](https://github.com/wincode/SpringBoot-Labs) | 系统学习 Spring Boot & Cloud 专栏 | |
||||
|
|
||||
|
### 前端项目 |
||||
|
|
||||
|
| 项目 | Star | 简介 | |
||||
|
|----------------------------------------------------------------------------|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------------| |
||||
|
| [win-ui-admin-vue3](https://gitee.com/wincode/win-ui-admin-vue3) | [](https://gitee.com/wincode/win-ui-admin-vue3) [](https://github.com/wincode/win-ui-admin-vue3) | 基于 Vue3 + element-plus 实现的管理后台 | |
||||
|
| [win-ui-admin-vben](https://gitee.com/wincode/win-ui-admin-vben) | [](https://gitee.com/wincode/win-ui-admin-vben) [](https://github.com/wincode/win-ui-admin-vben) | 基于 Vue3 + vben(ant-design-vue) 实现的管理后台 | |
||||
|
| [win-mall-uniapp](https://gitee.com/wincode/win-mall-uniapp) | [](https://gitee.com/wincode/win-mall-uniapp) [](https://github.com/wincode/win-mall-uniapp) | 基于 uni-app 实现的商城小程序 | |
||||
|
| [win-ui-admin-vue2](https://gitee.com/wincode/win-ui-admin-vue2) | [](https://gitee.com/wincode/win-ui-admin-vue2) [](https://github.com/wincode/win-ui-admin-vue2) | 基于 Vue2 + element-ui 实现的管理后台 | |
||||
|
| [win-ui-admin-uniapp](https://gitee.com/wincode/win-ui-admin-uniapp) | [](https://gitee.com/wincode/win-ui-admin-uniapp) [](https://github.com/wincode/win-ui-admin-uniapp) | 基于 Vue2 + element-ui 实现的管理后台 | |
||||
|
| [win-ui-go-view](https://gitee.com/wincode/win-ui-go-view) | [](https://gitee.com/wincode/win-ui-go-view) [](https://github.com/wincode/win-ui-go-view) | 基于 Vue3 + naive-ui 实现的大屏报表 | |
||||
|
|
||||
|
## 😎 开源协议 |
||||
|
|
||||
|
**为什么推荐使用本项目？** |
||||
|
|
||||
|
① 本项目采用比 Apache 2.0 更宽松的 [MIT License](https://gitee.com/zhijiantianya/ruoyi-vue-pro/blob/master/LICENSE) 开源协议，个人与企业可 100% 免费使用，不用保留类作者、Copyright 信息。 |
||||
|
|
||||
|
② 代码全部开源，不会像其他项目一样，只开源部分代码，让你无法了解整个项目的架构设计。[国产开源项目对比](https://www.yuque.com/xiatian-bsgny/lm0ec1/wqf8mn) |
||||
|
|
||||
|
 |
||||
|
|
||||
|
③ 代码整洁、架构整洁，遵循《阿里巴巴 Java 开发手册》规范，代码注释详细，57000 行 Java 代码，22000 行代码注释。 |
||||
|
|
||||
|
## 🤝 项目外包 |
||||
|
|
||||
|
我们也是接外包滴，如果你有项目想要外包，可以微信联系【**Aix9975**】。 |
||||
|
|
||||
|
团队包含专业的项目经理、架构师、前端工程师、后端工程师、测试工程师、运维工程师，可以提供全流程的外包服务。 |
||||
|
|
||||
|
项目可以是商城、SCRM 系统、OA 系统、物流系统、ERP 系统、CMS 系统、HIS 系统、支付系统、IM 聊天、微信公众号、微信小程序等等。 |
||||
|
|
||||
|
## 🐼 内置功能 |
||||
|
|
||||
|
系统内置多种多种业务功能，可以用于快速你的业务系统： |
||||
|
|
||||
|
 |
||||
|
|
||||
|
* 通用模块（必选）：系统功能、基础设施 |
||||
|
* 通用模块（可选）：工作流程、支付系统、数据报表、会员中心 |
||||
|
* 业务系统（按需）：ERP 系统、CRM 系统、商城系统、微信公众号 |
||||
|
|
||||
|
> 友情提示：本项目基于 RuoYi-Vue 修改，**重构优化**后端的代码，**美化**前端的界面。 |
||||
|
> |
||||
|
> * 额外新增的功能，我们使用 🚀 标记。 |
||||
|
> * 重新实现的功能，我们使用 ⭐️ 标记。 |
||||
|
|
||||
|
🙂 所有功能，都通过 **单元测试** 保证高质量。 |
||||
|
|
||||
|
### 系统功能 |
||||
|
|
||||
|
| | 功能 | 描述 | |
||||
|
|-----|-------|---------------------------------| |
||||
|
| | 用户管理 | 用户是系统操作者，该功能主要完成系统用户配置 | |
||||
|
| ⭐️ | 在线用户 | 当前系统中活跃用户状态监控，支持手动踢下线 | |
||||
|
| | 角色管理 | 角色菜单权限分配、设置角色按机构进行数据范围权限划分 | |
||||
|
| | 菜单管理 | 配置系统菜单、操作权限、按钮权限标识等，本地缓存提供性能 | |
||||
|
| | 部门管理 | 配置系统组织机构（公司、部门、小组），树结构展现支持数据权限 | |
||||
|
| | 岗位管理 | 配置系统用户所属担任职务 | |
||||
|
| 🚀 | 租户管理 | 配置系统租户，支持 SaaS 场景下的多租户功能 | |
||||
|
| 🚀 | 租户套餐 | 配置租户套餐，自定每个租户的菜单、操作、按钮的权限 | |
||||
|
| | 字典管理 | 对系统中经常使用的一些较为固定的数据进行维护 | |
||||
|
| 🚀 | 短信管理 | 短信渠道、短息模板、短信日志，对接阿里云、腾讯云等主流短信平台 | |
||||
|
| 🚀 | 邮件管理 | 邮箱账号、邮件模版、邮件发送日志，支持所有邮件平台 | |
||||
|
| 🚀 | 站内信 | 系统内的消息通知，提供站内信模版、站内信消息 | |
||||
|
| 🚀 | 操作日志 | 系统正常操作日志记录和查询，集成 Swagger 生成日志内容 | |
||||
|
| ⭐️ | 登录日志 | 系统登录日志记录查询，包含登录异常 | |
||||
|
| 🚀 | 错误码管理 | 系统所有错误码的管理，可在线修改错误提示，无需重启服务 | |
||||
|
| | 通知公告 | 系统通知公告信息发布维护 | |
||||
|
| 🚀 | 敏感词 | 配置系统敏感词，支持标签分组 | |
||||
|
| 🚀 | 应用管理 | 管理 SSO 单点登录的应用，支持多种 OAuth2 授权方式 | |
||||
|
| 🚀 | 地区管理 | 展示省份、城市、区镇等城市信息，支持 IP 对应城市 | |
||||
|
|
||||
|
 |
||||
|
|
||||
|
### 工作流程 |
||||
|
|
||||
|
| | 功能 | 描述 | |
||||
|
|-----|-------|----------------------------------------| |
||||
|
| 🚀 | 流程模型 | 配置工作流的流程模型，支持文件导入与在线设计流程图，提供 7 种任务分配规则 | |
||||
|
| 🚀 | 流程表单 | 拖动表单元素生成相应的工作流表单，覆盖 Element UI 所有的表单组件 | |
||||
|
| 🚀 | 用户分组 | 自定义用户分组，可用于工作流的审批分组 | |
||||
|
| 🚀 | 我的流程 | 查看我发起的工作流程，支持新建、取消流程等操作，高亮流程图、审批时间线 | |
||||
|
| 🚀 | 待办任务 | 查看自己【未】审批的工作任务，支持通过、不通过、转发、委派、退回等操作 | |
||||
|
| 🚀 | 已办任务 | 查看自己【已】审批的工作任务，未来会支持回退操作 | |
||||
|
| 🚀 | OA 请假 | 作为业务自定义接入工作流的使用示例，只需创建请求对应的工作流程，即可进行审批 | |
||||
|
|
||||
|
 |
||||
|
|
||||
|
### 支付系统 |
||||
|
|
||||
|
| | 功能 | 描述 | |
||||
|
|-----|------|---------------------------| |
||||
|
| 🚀 | 应用信息 | 配置商户的应用信息，对接支付宝、微信等多个支付渠道 | |
||||
|
| 🚀 | 支付订单 | 查看用户发起的支付宝、微信等的【支付】订单 | |
||||
|
| 🚀 | 退款订单 | 查看用户发起的支付宝、微信等的【退款】订单 | |
||||
|
| 🚀 | 回调通知 | 查看支付回调业务的【支付】【退款】的通知结果 | |
||||
|
| 🚀 | 接入示例 | 提供接入支付系统的【支付】【退款】的功能实战 | |
||||
|
|
||||
|
### 基础设施 |
||||
|
|
||||
|
| | 功能 | 描述 | |
||||
|
|----|-----------|----------------------------------------------| |
||||
|
| 🚀 | 代码生成 | 前后端代码的生成（Java、Vue、SQL、单元测试），支持 CRUD 下载 | |
||||
|
| 🚀 | 系统接口 | 基于 Swagger 自动生成相关的 RESTful API 接口文档 | |
||||
|
| 🚀 | 数据库文档 | 基于 Screw 自动生成数据库文档，支持导出 Word、HTML、MD 格式 | |
||||
|
| | 表单构建 | 拖动表单元素生成相应的 HTML 代码，支持导出 JSON、Vue 文件 | |
||||
|
| 🚀 | 配置管理 | 对系统动态配置常用参数，支持 SpringBoot 加载 | |
||||
|
| ⭐️ | 定时任务 | 在线（添加、修改、删除)任务调度包含执行结果日志 | |
||||
|
| 🚀 | 文件服务 | 支持将文件存储到 S3（MinIO、阿里云、腾讯云、七牛云）、本地、FTP、数据库等 | |
||||
|
| 🚀 | WebSocket | 提供 WebSocket 接入示例，支持一对一、一对多发送方式 | |
||||
|
| 🚀 | API 日志 | 包括 RESTful API 访问日志、异常日志两部分，方便排查 API 相关的问题 | |
||||
|
| | MySQL 监控 | 监视当前系统数据库连接池状态，可进行分析SQL找出系统性能瓶颈 | |
||||
|
| | Redis 监控 | 监控 Redis 数据库的使用情况，使用的 Redis Key 管理 | |
||||
|
| 🚀 | 消息队列 | 基于 Redis 实现消息队列，Stream 提供集群消费，Pub/Sub 提供广播消费 | |
||||
|
| 🚀 | Java 监控 | 基于 Spring Boot Admin 实现 Java 应用的监控 | |
||||
|
| 🚀 | 链路追踪 | 接入 SkyWalking 组件，实现链路追踪 | |
||||
|
| 🚀 | 日志中心 | 接入 SkyWalking 组件，实现日志中心 | |
||||
|
| 🚀 | 服务保障 | 基于 Redis 实现分布式锁、幂等、限流功能，满足高并发场景 | |
||||
|
| 🚀 | 日志服务 | 轻量级日志中心，查看远程服务器的日志 | |
||||
|
| 🚀 | 单元测试 | 基于 JUnit + Mockito 实现单元测试，保证功能的正确性、代码的质量等 | |
||||
|
|
||||
|
 |
||||
|
|
||||
|
### 数据报表 |
||||
|
|
||||
|
| | 功能 | 描述 | |
||||
|
|-----|-------|--------------------| |
||||
|
| 🚀 | 报表设计器 | 支持数据报表、图形报表、打印设计等 | |
||||
|
| 🚀 | 大屏设计器 | 拖拽生成数据大屏，内置几十种图表组件 | |
||||
|
|
||||
|
### 微信公众号 |
||||
|
|
||||
|
| | 功能 | 描述 | |
||||
|
|-----|--------|-------------------------------| |
||||
|
| 🚀 | 账号管理 | 配置接入的微信公众号，可支持多个公众号 | |
||||
|
| 🚀 | 数据统计 | 统计公众号的用户增减、累计用户、消息概况、接口分析等数据 | |
||||
|
| 🚀 | 粉丝管理 | 查看已关注、取关的粉丝列表，可对粉丝进行同步、打标签等操作 | |
||||
|
| 🚀 | 消息管理 | 查看粉丝发送的消息列表，可主动回复粉丝消息 | |
||||
|
| 🚀 | 自动回复 | 自动回复粉丝发送的消息，支持关注回复、消息回复、关键字回复 | |
||||
|
| 🚀 | 标签管理 | 对公众号的标签进行创建、查询、修改、删除等操作 | |
||||
|
| 🚀 | 菜单管理 | 自定义公众号的菜单，也可以从公众号同步菜单 | |
||||
|
| 🚀 | 素材管理 | 管理公众号的图片、语音、视频等素材，支持在线播放语音、视频 | |
||||
|
| 🚀 | 图文草稿箱 | 新增常用的图文素材到草稿箱，可发布到公众号 | |
||||
|
| 🚀 | 图文发表记录 | 查看已发布成功的图文素材，支持删除操作 | |
||||
|
|
||||
|
### 商城系统 |
||||
|
|
||||
|
 |
||||
|
|
||||
|
 |
||||
|
|
||||
|
演示地址：<https://cloud.iocoder.cn/mall-preview/> |
||||
|
|
||||
|
### 会员中心 |
||||
|
|
||||
|
| | 功能 | 描述 | |
||||
|
|-----|------|----------------------------------| |
||||
|
| 🚀 | 会员管理 | 会员是 C 端的消费者，该功能用于会员的搜索与管理 | |
||||
|
| 🚀 | 会员标签 | 对会员的标签进行创建、查询、修改、删除等操作 | |
||||
|
| 🚀 | 会员等级 | 对会员的等级、成长值进行管理，可用于订单折扣等会员权益 | |
||||
|
| 🚀 | 会员分组 | 对会员进行分组，用于用户画像、内容推送等运营手段 | |
||||
|
| 🚀 | 积分签到 | 回馈给签到、消费等行为的积分，会员可订单抵现、积分兑换等途径消耗 | |
||||
|
|
||||
|
### ERP 系统 |
||||
|
|
||||
|
 |
||||
|
|
||||
|
演示地址：<https://cloud.iocoder.cn/erp-preview/> |
||||
|
|
||||
|
### ERP 系统 |
||||
|
|
||||
|
 |
||||
|
|
||||
|
演示地址：<https://cloud.iocoder.cn/crm-preview/> |
||||
|
|
||||
|
## 🐨 技术栈 |
||||
|
|
||||
|
### 微服务 |
||||
|
|
||||
|
| 项目 | 说明 | |
||||
|
|--------------------------------------------------------------------------|--------------------| |
||||
|
| `win-dependencies` | Maven 依赖版本管理 | |
||||
|
| `win-framework` | Java 框架拓展 | |
||||
|
| `win-server` | 管理后台 + 用户 APP 的服务端 | |
||||
|
| `win-module-system` | 系统功能的 Module 模块 | |
||||
|
| `win-module-member` | 会员中心的 Module 模块 | |
||||
|
| `win-module-infra` | 基础设施的 Module 模块 | |
||||
|
| `win-module-bpm` | 工作流程的 Module 模块 | |
||||
|
| `win-module-pay` | 支付系统的 Module 模块 | |
||||
|
| `win-module-mall` | 商城系统的 Module 模块 | |
||||
|
| `win-module-mp` | 微信公众号的 Module 模块 | |
||||
|
| `win-module-report` | 大屏报表 Module 模块 | |
||||
|
|
||||
|
### 框架 |
||||
|
|
||||
|
| 框架 | 说明 | 版本 | 学习指南 | |
||||
|
|---------------------------------------------------------------------------------------------|------------------|-------------|---------------------------------------------------------------------| |
||||
|
| [Spring Cloud Alibaba](https://github.com/alibaba/spring-cloud-alibaba) | 微服务框架 | 2022.0.0.0 | [文档](https://github.com/YunaiV/SpringBoot-Labs) | |
||||
|
| [Nacos](https://github.com/alibaba/nacos) | 配置中心 & 注册中心 | 2.2.1 | [文档](https://www.iocoder.cn/categories/Nacos/?win) | |
||||
|
| [RocketMQ](https://github.com/apache/rocketmq) | 消息队列 | 4.9.4 | [文档](https://www.iocoder.cn/categories/RocketMQ/?win) | |
||||
|
| [Sentinel](https://github.com/alibaba/sentinel) | 服务保障 | 1.8.6 | [文档](https://www.iocoder.cn/categories/Sentinel/?win) | |
||||
|
| [XXL Job](https://github.com/xuxueli/xxl-job) | 定时任务 | 2.4.0 | [文档](https://www.iocoder.cn/XXL-JOB/good-collection/?win) | |
||||
|
| [Spring Cloud Gateway](https://github.com/spring-cloud/spring-cloud-gateway) | 服务网关 | 4.1.0 | [文档](https://www.iocoder.cn/categories/Spring-Cloud-Gateway/?win) | |
||||
|
| [Seata](https://github.com/seata/seata) | 分布式事务 | 1.6.1 | [文档](https://www.iocoder.cn/categories/Seata/?win) | |
||||
|
| [MySQL](https://www.mysql.com/cn/) | 数据库服务器 | 5.7 / 8.0+ | | |
||||
|
| [Druid](https://github.com/alibaba/druid) | JDBC 连接池、监控组件 | 1.2.20 | [文档](http://www.iocoder.cn/Spring-Boot/datasource-pool/?win) | |
||||
|
| [MyBatis Plus](https://mp.baomidou.com/) | MyBatis 增强工具包 | 3.5.4.1 | [文档](http://www.iocoder.cn/Spring-Boot/MyBatis/?win) | |
||||
|
| [Dynamic Datasource](https://dynamic-datasource.com/) | 动态数据源 | 4.2.0 | [文档](http://www.iocoder.cn/Spring-Boot/datasource-pool/?win) | |
||||
|
| [Redis](https://redis.io/) | key-value 数据库 | 5.0 / 6.0 | | |
||||
|
| [Redisson](https://github.com/redisson/redisson) | Redis 客户端 | 3.25.0 | [文档](http://www.iocoder.cn/Spring-Boot/Redis/?win) | |
||||
|
| [Spring MVC](https://github.com/spring-projects/spring-framework/tree/master/spring-webmvc) | MVC 框架 | 6.1.1 | [文档](http://www.iocoder.cn/SpringMVC/MVC/?win) | |
||||
|
| [Spring Security](https://github.com/spring-projects/spring-security) | Spring 安全框架 | 6.2.0 | [文档](http://www.iocoder.cn/Spring-Boot/Spring-Security/?win) | |
||||
|
| [Hibernate Validator](https://github.com/hibernate/hibernate-validator) | 参数校验组件 | 8.0.1 | [文档](http://www.iocoder.cn/Spring-Boot/Validation/?win) | |
||||
|
| [Flowable](https://github.com/flowable/flowable-engine) | 工作流引擎 | 7.0.0 | [文档](https://doc.iocoder.cn/bpm/) | |
||||
|
| [Knife4j](https://gitee.com/xiaoym/knife4j) | Swagger 增强 UI 实现 | 4.4.0 | [文档](http://www.iocoder.cn/Spring-Boot/Swagger/?win) | |
||||
|
| [SkyWalking](https://skywalking.apache.org/) | 分布式应用追踪系统 | 9.0.0 | [文档](http://www.iocoder.cn/Spring-Boot/SkyWalking/?win) | |
||||
|
| [Spring Boot Admin](https://github.com/codecentric/spring-boot-admin) | Spring Boot 监控平台 | 3.6.1 | [文档](http://www.iocoder.cn/Spring-Boot/Admin/?win) | |
||||
|
| [Jackson](https://github.com/FasterXML/jackson) | JSON 工具库 | 2.15.3 | | |
||||
|
| [MapStruct](https://mapstruct.org/) | Java Bean 转换 | 1.5.5.Final | [文档](http://www.iocoder.cn/Spring-Boot/MapStruct/?win) | |
||||
|
| [Lombok](https://projectlombok.org/) | 消除冗长的 Java 代码 | 1.18.30 | [文档](http://www.iocoder.cn/Spring-Boot/Lombok/?win) | |
||||
|
| [JUnit](https://junit.org/junit5/) | Java 单元测试框架 | 5.10.1 | - | |
||||
|
| [Mockito](https://github.com/mockito/mockito) | Java Mock 框架 | 5.7.0 | - | |
||||
|
|
||||
|
## 🐷 演示图 |
||||
|
|
||||
|
### 系统功能 |
||||
|
|
||||
|
| 模块 | biu | biu | biu | |
||||
|
|----------|-----------------------------|---------------------------|--------------------------| |
||||
|
| 登录 & 首页 |  |  |  | |
||||
|
| 用户 & 应用 |  |  |  | |
||||
|
| 租户 & 套餐 |  |  | - | |
||||
|
| 部门 & 岗位 |  |  | - | |
||||
|
| 菜单 & 角色 |  |  | - | |
||||
|
| 审计日志 |  |  | - | |
||||
|
| 短信 |  |  |  | |
||||
|
| 字典 & 敏感词 |  |  |  | |
||||
|
| 错误码 & 通知 |  |  | - | |
||||
|
|
||||
|
### 工作流程 |
||||
|
|
||||
|
| 模块 | biu | biu | biu | |
||||
|
|---------|---------------------------------|---------------------------------|---------------------------------| |
||||
|
| 流程模型 |  |  |  | |
||||
|
| 表单 & 分组 |  |  | - | |
||||
|
| 我的流程 |  |  |  | |
||||
|
| 待办 & 已办 |  |  |  | |
||||
|
| OA 请假 |  |  |  | |
||||
|
|
||||
|
### 基础设施 |
||||
|
|
||||
|
| 模块 | biu | biu | biu | |
||||
|
|---------------|-------------------------------|-----------------------------|---------------------------| |
||||
|
| 代码生成 |  |  | - | |
||||
|
| 文档 |  |  | - | |
||||
|
| 文件 & 配置 |  |  |  | |
||||
|
| 定时任务 |  |  | - | |
||||
|
| API 日志 |  |  | - | |
||||
|
| MySQL & Redis |  |  | - | |
||||
|
| 监控平台 |  |  |  | |
||||
|
|
||||
|
### 支付系统 |
||||
|
|
||||
|
| 模块 | biu | biu | biu | |
||||
|
|---------|---------------------------|---------------------------------|---------------------------------| |
||||
|
| 商家 & 应用 |  |  |  | |
||||
|
| 支付 & 退款 |  |  | --- | |
||||
|
### 数据报表 |
||||
|
|
||||
|
| 模块 | biu | biu | biu | |
||||
|
|-------|---------------------------------|---------------------------------|---------------------------------------| |
||||
|
| 报表设计器 |  |  |  | |
||||
|
| 大屏设计器 |  |  |  | |
||||
|
|
||||
|
### 移动端（管理后台） |
||||
|
|
||||
|
| biu | biu | biu | |
||||
|
|----------------------------------|----------------------------------|----------------------------------| |
||||
|
|  |  |  | |
||||
|
|  |  |  | |
||||
|
|  |  |  | |
||||
|
|
||||
|
目前已经实现登录、我的、工作台、编辑资料、头像修改、密码修改、常见问题、关于我们等基础功能。 |
||||
|
|||||
@ -0,0 +1,4 @@ |
|||||
|
config.stopBubbling = true |
||||
|
lombok.tostring.callsuper=CALL |
||||
|
lombok.equalsandhashcode.callsuper=CALL |
||||
|
lombok.accessors.chain=true |
||||
@ -0,0 +1,149 @@ |
|||||
|
<?xml version="1.0" encoding="UTF-8"?> |
||||
|
<project xmlns="http://maven.apache.org/POM/4.0.0" |
||||
|
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" |
||||
|
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> |
||||
|
<modelVersion>4.0.0</modelVersion> |
||||
|
<groupId>com.win</groupId> |
||||
|
<artifactId>win</artifactId> |
||||
|
<version>${revision}</version> |
||||
|
<packaging>pom</packaging> |
||||
|
<modules> |
||||
|
<module>win-dependencies</module> |
||||
|
<module>win-gateway</module> |
||||
|
<module>win-framework</module> |
||||
|
<!-- 各种 module 拓展 --> |
||||
|
<module>win-module-system</module> |
||||
|
<module>win-module-infra</module> |
||||
|
<module>win-module-mes</module> |
||||
|
<!-- <module>win-module-member</module>--> |
||||
|
<module>win-module-bpm</module> |
||||
|
<!-- <module>win-module-pay</module>--> |
||||
|
<module>win-module-report</module> |
||||
|
<module>win-module-scp</module> |
||||
|
<!-- <module>win-module-mp</module>--> |
||||
|
<!-- <module>win-module-mall</module>--> |
||||
|
<!-- <module>win-module-crm</module>--> |
||||
|
<!-- <module>win-module-erp</module>--> |
||||
|
</modules> |
||||
|
|
||||
|
<name>${project.artifactId}</name> |
||||
|
<description>芋道项目基础脚手架</description> |
||||
|
<url>https://github.com/YunaiV/ruoyi-vue-pro</url> |
||||
|
|
||||
|
<properties> |
||||
|
<revision>2.1.0-snapshot</revision> |
||||
|
<!-- Maven 相关 --> |
||||
|
<java.version>17</java.version> |
||||
|
<maven.compiler.source>${java.version}</maven.compiler.source> |
||||
|
<maven.compiler.target>${java.version}</maven.compiler.target> |
||||
|
<maven-surefire-plugin.version>3.2.2</maven-surefire-plugin.version> |
||||
|
<maven-compiler-plugin.version>3.11.0</maven-compiler-plugin.version> |
||||
|
<flatten-maven-plugin.version>1.5.0</flatten-maven-plugin.version> |
||||
|
<!-- 看看咋放到 bom 里 --> |
||||
|
<lombok.version>1.18.30</lombok.version> |
||||
|
<spring.boot.version>3.2.0</spring.boot.version> |
||||
|
<mapstruct.version>1.5.5.Final</mapstruct.version> |
||||
|
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> |
||||
|
</properties> |
||||
|
|
||||
|
<dependencyManagement> |
||||
|
<dependencies> |
||||
|
<dependency> |
||||
|
<groupId>com.win</groupId> |
||||
|
<artifactId>win-dependencies</artifactId> |
||||
|
<version>${revision}</version> |
||||
|
<type>pom</type> |
||||
|
<scope>import</scope> |
||||
|
</dependency> |
||||
|
</dependencies> |
||||
|
</dependencyManagement> |
||||
|
|
||||
|
<build> |
||||
|
<pluginManagement> |
||||
|
<plugins> |
||||
|
<!-- maven-surefire-plugin 插件，用于运行单元测试。 --> |
||||
|
<!-- 注意，需要使用 3.0.X+，因为要支持 Junit 5 版本 --> |
||||
|
<plugin> |
||||
|
<groupId>org.apache.maven.plugins</groupId> |
||||
|
<artifactId>maven-surefire-plugin</artifactId> |
||||
|
<version>${maven-surefire-plugin.version}</version> |
||||
|
</plugin> |
||||
|
<!-- maven-compiler-plugin 插件，解决 Lombok + MapStruct 组合 --> |
||||
|
<!-- https://stackoverflow.com/questions/33483697/re-run-spring-boot-configuration-annotation-processor-to-update-generated-metada --> |
||||
|
<plugin> |
||||
|
<groupId>org.apache.maven.plugins</groupId> |
||||
|
<artifactId>maven-compiler-plugin</artifactId> |
||||
|
<version>${maven-compiler-plugin.version}</version> |
||||
|
<configuration> |
||||
|
<annotationProcessorPaths> |
||||
|
<path> |
||||
|
<groupId>org.springframework.boot</groupId> |
||||
|
<artifactId>spring-boot-configuration-processor</artifactId> |
||||
|
<version>${spring.boot.version}</version> |
||||
|
</path> |
||||
|
<path> |
||||
|
<groupId>org.projectlombok</groupId> |
||||
|
<artifactId>lombok</artifactId> |
||||
|
<version>${lombok.version}</version> |
||||
|
</path> |
||||
|
<path> |
||||
|
<groupId>org.mapstruct</groupId> |
||||
|
<artifactId>mapstruct-processor</artifactId> |
||||
|
<version>${mapstruct.version}</version> |
||||
|
</path> |
||||
|
</annotationProcessorPaths> |
||||
|
<!-- 编译参数写在 arg 内，解决 Spring Boot 3.2 的 Parameter Name Discovery 问题 --> |
||||
|
<debug>false</debug> |
||||
|
<compilerArgs> |
||||
|
<arg>-parameters</arg> |
||||
|
</compilerArgs> |
||||
|
</configuration> |
||||
|
</plugin> |
||||
|
</plugins> |
||||
|
</pluginManagement> |
||||
|
|
||||
|
<plugins> |
||||
|
<!-- 统一 revision 版本 --> |
||||
|
<plugin> |
||||
|
<groupId>org.codehaus.mojo</groupId> |
||||
|
<artifactId>flatten-maven-plugin</artifactId> |
||||
|
<version>${flatten-maven-plugin.version}</version> |
||||
|
<configuration> |
||||
|
<flattenMode>resolveCiFriendliesOnly</flattenMode> |
||||
|
<updatePomFile>true</updatePomFile> |
||||
|
</configuration> |
||||
|
<executions> |
||||
|
<execution> |
||||
|
<goals> |
||||
|
<goal>flatten</goal> |
||||
|
</goals> |
||||
|
<id>flatten</id> |
||||
|
<phase>process-resources</phase> |
||||
|
</execution> |
||||
|
<execution> |
||||
|
<goals> |
||||
|
<goal>clean</goal> |
||||
|
</goals> |
||||
|
<id>flatten.clean</id> |
||||
|
<phase>clean</phase> |
||||
|
</execution> |
||||
|
</executions> |
||||
|
</plugin> |
||||
|
</plugins> |
||||
|
</build> |
||||
|
|
||||
|
<!-- 使用 huawei / aliyun 的 Maven 源，提升下载速度 --> |
||||
|
<repositories> |
||||
|
<repository> |
||||
|
<id>huaweicloud</id> |
||||
|
<name>huawei</name> |
||||
|
<url>https://mirrors.huaweicloud.com/repository/maven/</url> |
||||
|
</repository> |
||||
|
<repository> |
||||
|
<id>aliyunmaven</id> |
||||
|
<name>aliyun</name> |
||||
|
<url>https://maven.aliyun.com/repository/public</url> |
||||
|
</repository> |
||||
|
</repositories> |
||||
|
|
||||
|
</project> |
||||
@ -0,0 +1,162 @@ |
|||||
|
version: '3' |
||||
|
services: |
||||
|
win-gateway: |
||||
|
image: win-gateway |
||||
|
container_name: win-gateway |
||||
|
environment: |
||||
|
- TZ=Asia/Shanghai # 配置程序默认时区为上海（中国标准时间） |
||||
|
- JAVA_TOOL_OPTIONS=-javaagent:/data/skywalking/skywalking-agent/skywalking-agent.jar # 配置skywalking |
||||
|
- SW_AGENT_NAME=win-gateway |
||||
|
- SW_AGENT_TRACE_IGNORE_PATH=Redisson/PING,/actuator/**,/admin/** |
||||
|
- SW_AGENT_COLLECTOR_BACKEND_SERVICES=[YOUR_SKYWALKING_ADDR] # 请替换 your.skywalking.addr 为你的 skywalking 地址 |
||||
|
- SPRING_PROFILES_ACTIVE=test # 指定程序运行环境 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_SERVER_ADDR=[YOUR_NACOS_ADDR] # 配置中心地址 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
- SPRING_CLOUD_NACOS_SERVER_ADDR=[YOUR_NACOS_ADDR] # 注册中心地址 |
||||
|
- SPRING_CLOUD_NACOS_DISCOVERY_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
volumes: |
||||
|
- /docker/win-cloud/logs:/root/logs/ |
||||
|
- /data/skywalking/skywalking-agent:/data/skywalking/skywalking-agent |
||||
|
restart: always |
||||
|
network_mode: host # 以主机网络环境运行 |
||||
|
win-system: |
||||
|
image: win-module-system-biz |
||||
|
container_name: win-system |
||||
|
environment: |
||||
|
- TZ=Asia/Shanghai # 配置程序默认时区为上海（中国标准时间） |
||||
|
- JAVA_TOOL_OPTIONS=-javaagent:/data/skywalking/skywalking-agent/skywalking-agent.jar # 配置skywalking |
||||
|
- SW_AGENT_NAME=win-gateway |
||||
|
- SW_AGENT_TRACE_IGNORE_PATH=Redisson/PING,/actuator/**,/admin/** |
||||
|
- SW_AGENT_COLLECTOR_BACKEND_SERVICES=[YOUR_SKYWALKING_ADDR] # 请替换 your.skywalking.addr 为你的 skywalking 地址 |
||||
|
- SPRING_PROFILES_ACTIVE=test # 指定程序运行环境 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_SERVER_ADDR=[YOUR_NACOS_ADDR] # 配置中心地址 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
- SPRING_CLOUD_NACOS_SERVER_ADDR=[YOUR_NACOS_ADDR] # 注册中心地址 |
||||
|
- SPRING_CLOUD_NACOS_DISCOVERY_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
volumes: |
||||
|
- /docker/win-cloud/logs:/root/logs/ |
||||
|
- /data/skywalking/skywalking-agent:/data/skywalking/skywalking-agent |
||||
|
healthcheck: |
||||
|
test: [ "CMD","curl","-f","http://localhost:48081" ] |
||||
|
interval: 30s |
||||
|
timeout: 10s |
||||
|
retries: 5 |
||||
|
start_period: 60s |
||||
|
restart: always |
||||
|
network_mode: host |
||||
|
win-infra: |
||||
|
image: win-module-infra-biz |
||||
|
container_name: win-infra |
||||
|
environment: |
||||
|
- TZ=Asia/Shanghai # 配置程序默认时区为上海（中国标准时间） |
||||
|
- JAVA_TOOL_OPTIONS=-javaagent:/data/skywalking/skywalking-agent/skywalking-agent.jar # 配置skywalking |
||||
|
- SW_AGENT_NAME=win-gateway |
||||
|
- SW_AGENT_TRACE_IGNORE_PATH=Redisson/PING,/actuator/**,/admin/** |
||||
|
- SW_AGENT_COLLECTOR_BACKEND_SERVICES=[YOUR_SKYWALKING_ADDR] # 请替换 your.skywalking.addr 为你的 skywalking 地址 |
||||
|
- SPRING_PROFILES_ACTIVE=test # 指定程序运行环境 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_SERVER_ADDR=[YOUR_NACOS_ADDR] # 配置中心地址 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
- SPRING_CLOUD_NACOS_SERVER_ADDR=[YOUR_NACOS_ADDR] # 注册中心地址 |
||||
|
- SPRING_CLOUD_NACOS_DISCOVERY_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
volumes: |
||||
|
- /docker/win-cloud/logs:/root/logs/ |
||||
|
- /data/skywalking/skywalking-agent:/data/skywalking/skywalking-agent |
||||
|
restart: always |
||||
|
network_mode: host |
||||
|
healthcheck: |
||||
|
test: [ "CMD","curl","-f","http://localhost:48082" ] |
||||
|
interval: 30s |
||||
|
timeout: 10s |
||||
|
retries: 5 |
||||
|
start_period: 60s |
||||
|
depends_on: |
||||
|
win-system: |
||||
|
condition: service_healthy |
||||
|
win-report: |
||||
|
image: win-module-report-biz |
||||
|
container_name: win-report |
||||
|
environment: |
||||
|
- TZ=Asia/Shanghai # 配置程序默认时区为上海（中国标准时间） |
||||
|
- JAVA_TOOL_OPTIONS=-javaagent:/data/skywalking/skywalking-agent/skywalking-agent.jar # 配置skywalking |
||||
|
- SW_AGENT_NAME=win-gateway |
||||
|
- SW_AGENT_TRACE_IGNORE_PATH=Redisson/PING,/actuator/**,/admin/** |
||||
|
- SW_AGENT_COLLECTOR_BACKEND_SERVICES=[YOUR_SKYWALKING_ADDR] # 请替换 your.skywalking.addr 为你的 skywalking 地址 |
||||
|
- SPRING_PROFILES_ACTIVE=test # 指定程序运行环境 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_SERVER_ADDR=[YOUR_NACOS_ADDR] # 配置中心地址 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
- SPRING_CLOUD_NACOS_SERVER_ADDR=[YOUR_NACOS_ADDR] # 注册中心地址 |
||||
|
- SPRING_CLOUD_NACOS_DISCOVERY_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
volumes: |
||||
|
- /docker/win-cloud/logs:/root/logs/ |
||||
|
- /data/skywalking/skywalking-agent:/data/skywalking/skywalking-agent |
||||
|
restart: always |
||||
|
network_mode: host |
||||
|
depends_on: |
||||
|
win-infra: |
||||
|
condition: service_healthy |
||||
|
win-bpm: |
||||
|
image: win-module-bpm-biz |
||||
|
container_name: win-bpm |
||||
|
environment: |
||||
|
- TZ=Asia/Shanghai # 配置程序默认时区为上海（中国标准时间） |
||||
|
- JAVA_TOOL_OPTIONS=-javaagent:/data/skywalking/skywalking-agent/skywalking-agent.jar # 配置skywalking |
||||
|
- SW_AGENT_NAME=win-gateway |
||||
|
- SW_AGENT_TRACE_IGNORE_PATH=Redisson/PING,/actuator/**,/admin/** |
||||
|
- SW_AGENT_COLLECTOR_BACKEND_SERVICES=[YOUR_SKYWALKING_ADDR] # 请替换 your.skywalking.addr 为你的 skywalking 地址 |
||||
|
- SPRING_PROFILES_ACTIVE=test # 指定程序运行环境 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_SERVER_ADDR=[YOUR_NACOS_ADDR] # 配置中心地址 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
- SPRING_CLOUD_NACOS_SERVER_ADDR=[YOUR_NACOS_ADDR] # 注册中心地址 |
||||
|
- SPRING_CLOUD_NACOS_DISCOVERY_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
volumes: |
||||
|
- /docker/win-cloud/logs:/root/logs/ |
||||
|
- /data/skywalking/skywalking-agent:/data/skywalking/skywalking-agent |
||||
|
restart: always |
||||
|
network_mode: host |
||||
|
depends_on: |
||||
|
win-infra: |
||||
|
condition: service_healthy |
||||
|
win-pay: |
||||
|
image: win-module-pay-biz |
||||
|
container_name: win-pay |
||||
|
environment: |
||||
|
- TZ=Asia/Shanghai # 配置程序默认时区为上海（中国标准时间） |
||||
|
- JAVA_TOOL_OPTIONS=-javaagent:/data/skywalking/skywalking-agent/skywalking-agent.jar # 配置skywalking |
||||
|
- SW_AGENT_NAME=win-gateway |
||||
|
- SW_AGENT_TRACE_IGNORE_PATH=Redisson/PING,/actuator/**,/admin/** |
||||
|
- SW_AGENT_COLLECTOR_BACKEND_SERVICES=[YOUR_SKYWALKING_ADDR] # 请替换 your.skywalking.addr 为你的 skywalking 地址 |
||||
|
- SPRING_PROFILES_ACTIVE=test # 指定程序运行环境 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_SERVER_ADDR=[YOUR_NACOS_ADDR] # 配置中心地址 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
- SPRING_CLOUD_NACOS_SERVER_ADDR=[YOUR_NACOS_ADDR] # 注册中心地址 |
||||
|
- SPRING_CLOUD_NACOS_DISCOVERY_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
volumes: |
||||
|
- /docker/win-cloud/logs:/root/logs/ |
||||
|
- /data/skywalking/skywalking-agent:/data/skywalking/skywalking-agent |
||||
|
restart: always |
||||
|
network_mode: host |
||||
|
depends_on: |
||||
|
win-infra: |
||||
|
condition: service_healthy |
||||
|
win-mp: |
||||
|
image: win-module-mp-biz |
||||
|
container_name: win-mp |
||||
|
environment: |
||||
|
- TZ=Asia/Shanghai # 配置程序默认时区为上海（中国标准时间） |
||||
|
- JAVA_TOOL_OPTIONS=-javaagent:/data/skywalking/skywalking-agent/skywalking-agent.jar # 配置skywalking |
||||
|
- SW_AGENT_NAME=win-gateway |
||||
|
- SW_AGENT_TRACE_IGNORE_PATH=Redisson/PING,/actuator/**,/admin/** |
||||
|
- SW_AGENT_COLLECTOR_BACKEND_SERVICES=[YOUR_SKYWALKING_ADDR] # 请替换 your.skywalking.addr 为你的 skywalking 地址 |
||||
|
- SPRING_PROFILES_ACTIVE=test # 指定程序运行环境 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_SERVER_ADDR=[YOUR_NACOS_ADDR] # 配置中心地址 |
||||
|
- SPRING_CLOUD_NACOS_CONFIG_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
- SPRING_CLOUD_NACOS_SERVER_ADDR=[YOUR_NACOS_ADDR] # 注册中心地址 |
||||
|
- SPRING_CLOUD_NACOS_DISCOVERY_NAMESPACE=[YOUR_NAMESPACE] # 命名空间 |
||||
|
volumes: |
||||
|
- /docker/win-cloud/logs:/root/logs/ |
||||
|
- /data/skywalking/skywalking-agent:/data/skywalking/skywalking-agent |
||||
|
restart: always |
||||
|
network_mode: host |
||||
|
depends_on: |
||||
|
win-infra: |
||||
|
condition: service_healthy |
||||
@ -0,0 +1,28 @@ |
|||||
|
{ |
||||
|
"local": { |
||||
|
"baseUrl": "http://127.0.0.1:48080/admin-api", |
||||
|
"systemBaseUrl": "http://127.0.0.1:48081/admin-api", |
||||
|
"infaBaseUrl": "http://127.0.0.1:48082/admin-api", |
||||
|
|
||||
|
"token": "test1", |
||||
|
"adminTenentId": "1", |
||||
|
"tag": "${HOSTNAME}", |
||||
|
|
||||
|
"appApi": "http://127.0.0.1:48080/app-api", |
||||
|
"appToken": "test1", |
||||
|
"appTenentId": "1" |
||||
|
}, |
||||
|
"gateway": { |
||||
|
"baseUrl": "http://127.0.0.1:48080/admin-api", |
||||
|
"systemBaseUrl": "http://127.0.0.1:48080/admin-api", |
||||
|
"infaBaseUrl": "http://127.0.0.1:48080/admin-api", |
||||
|
|
||||
|
"token": "test1", |
||||
|
"adminTenentId": "1", |
||||
|
"tag": "${HOSTNAME}", |
||||
|
|
||||
|
"appApi": "http://127.0.0.1:8888/app-api", |
||||
|
"appToken": "test1", |
||||
|
"appTenentId": "1" |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,3 @@ |
|||||
|
暂未适配 IBM DB2 数据库，如果你有需要，可以微信联系 wangwenbin-server 一起建设。 |
||||
|
|
||||
|
你需要把表结构与数据导入到 DM 数据库，我来测试与适配代码。 |
||||
@ -0,0 +1,598 @@ |
|||||
|
package liquibase.database.core; |
||||
|
|
||||
|
import java.lang.reflect.Method; |
||||
|
import java.sql.Connection; |
||||
|
import java.sql.ResultSet; |
||||
|
import java.sql.SQLException; |
||||
|
import java.sql.Statement; |
||||
|
import java.util.ArrayList; |
||||
|
import java.util.Arrays; |
||||
|
import java.util.HashSet; |
||||
|
import java.util.List; |
||||
|
import java.util.Locale; |
||||
|
import java.util.Map; |
||||
|
import java.util.Properties; |
||||
|
import java.util.Set; |
||||
|
import java.util.regex.Matcher; |
||||
|
import java.util.regex.Pattern; |
||||
|
import liquibase.CatalogAndSchema; |
||||
|
import liquibase.Scope; |
||||
|
import liquibase.database.AbstractJdbcDatabase; |
||||
|
import liquibase.database.DatabaseConnection; |
||||
|
import liquibase.database.OfflineConnection; |
||||
|
import liquibase.database.jvm.JdbcConnection; |
||||
|
import liquibase.exception.DatabaseException; |
||||
|
import liquibase.exception.UnexpectedLiquibaseException; |
||||
|
import liquibase.exception.ValidationErrors; |
||||
|
import liquibase.executor.ExecutorService; |
||||
|
import liquibase.statement.DatabaseFunction; |
||||
|
import liquibase.statement.SequenceCurrentValueFunction; |
||||
|
import liquibase.statement.SequenceNextValueFunction; |
||||
|
import liquibase.statement.core.RawCallStatement; |
||||
|
import liquibase.statement.core.RawSqlStatement; |
||||
|
import liquibase.structure.DatabaseObject; |
||||
|
import liquibase.structure.core.Catalog; |
||||
|
import liquibase.structure.core.Index; |
||||
|
import liquibase.structure.core.PrimaryKey; |
||||
|
import liquibase.structure.core.Schema; |
||||
|
import liquibase.util.JdbcUtils; |
||||
|
import liquibase.util.StringUtil; |
||||
|
|
||||
|
public class DmDatabase extends AbstractJdbcDatabase { |
||||
|
private static final String PRODUCT_NAME = "DM DBMS"; |
||||
|
|
||||
|
@Override |
||||
|
protected String getDefaultDatabaseProductName() { |
||||
|
return PRODUCT_NAME; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* Is this AbstractDatabase subclass the correct one to use for the given connection. |
||||
|
* |
||||
|
* @param conn |
||||
|
*/ |
||||
|
@Override |
||||
|
public boolean isCorrectDatabaseImplementation(DatabaseConnection conn) throws DatabaseException { |
||||
|
return PRODUCT_NAME.equalsIgnoreCase(conn.getDatabaseProductName()); |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* If this database understands the given url, return the default driver class name. Otherwise return null. |
||||
|
* |
||||
|
* @param url |
||||
|
*/ |
||||
|
@Override |
||||
|
public String getDefaultDriver(String url) { |
||||
|
if(url.startsWith("jdbc:dm")) { |
||||
|
return "dm.jdbc.driver.DmDriver"; |
||||
|
} |
||||
|
|
||||
|
return null; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* Returns an all-lower-case short name of the product. Used for end-user selecting of database type |
||||
|
* such as the DBMS precondition. |
||||
|
*/ |
||||
|
@Override |
||||
|
public String getShortName() { |
||||
|
return "dm"; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public Integer getDefaultPort() { |
||||
|
return 5236; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* Returns whether this database support initially deferrable columns. |
||||
|
*/ |
||||
|
@Override |
||||
|
public boolean supportsInitiallyDeferrableColumns() { |
||||
|
return true; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public boolean supportsTablespaces() { |
||||
|
return true; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public int getPriority() { |
||||
|
return PRIORITY_DEFAULT; |
||||
|
} |
||||
|
|
||||
|
private static final Pattern PROXY_USER = Pattern.compile(".*(?:thin|oci)\\:(.+)/@.*"); |
||||
|
|
||||
|
protected final int SHORT_IDENTIFIERS_LENGTH = 30; |
||||
|
protected final int LONG_IDENTIFIERS_LEGNTH = 128; |
||||
|
public static final int ORACLE_12C_MAJOR_VERSION = 12; |
||||
|
|
||||
|
private Set<String> reservedWords = new HashSet<>(); |
||||
|
private Set<String> userDefinedTypes; |
||||
|
private Map<String, String> savedSessionNlsSettings; |
||||
|
|
||||
|
private Boolean canAccessDbaRecycleBin; |
||||
|
private Integer databaseMajorVersion; |
||||
|
private Integer databaseMinorVersion; |
||||
|
|
||||
|
/** |
||||
|
* Default constructor for an object that represents the Oracle Database DBMS. |
||||
|
*/ |
||||
|
public DmDatabase() { |
||||
|
super.unquotedObjectsAreUppercased = true; |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
super.setCurrentDateTimeFunction("SYSTIMESTAMP"); |
||||
|
// Setting list of Oracle's native functions
|
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
dateFunctions.add(new DatabaseFunction("SYSDATE")); |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
dateFunctions.add(new DatabaseFunction("SYSTIMESTAMP")); |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
dateFunctions.add(new DatabaseFunction("CURRENT_TIMESTAMP")); |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
super.sequenceNextValueFunction = "%s.nextval"; |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
super.sequenceCurrentValueFunction = "%s.currval"; |
||||
|
} |
||||
|
|
||||
|
private void tryProxySession(final String url, final Connection con) { |
||||
|
Matcher m = PROXY_USER.matcher(url); |
||||
|
if (m.matches()) { |
||||
|
Properties props = new Properties(); |
||||
|
props.put("PROXY_USER_NAME", m.group(1)); |
||||
|
try { |
||||
|
Method method = con.getClass().getMethod("openProxySession", int.class, Properties.class); |
||||
|
method.setAccessible(true); |
||||
|
method.invoke(con, 1, props); |
||||
|
} catch (Exception e) { |
||||
|
Scope.getCurrentScope().getLog(getClass()).info("Could not open proxy session on OracleDatabase: " + e.getCause().getMessage()); |
||||
|
} |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public int getDatabaseMajorVersion() throws DatabaseException { |
||||
|
if (databaseMajorVersion == null) { |
||||
|
return super.getDatabaseMajorVersion(); |
||||
|
} else { |
||||
|
return databaseMajorVersion; |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public int getDatabaseMinorVersion() throws DatabaseException { |
||||
|
if (databaseMinorVersion == null) { |
||||
|
return super.getDatabaseMinorVersion(); |
||||
|
} else { |
||||
|
return databaseMinorVersion; |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public String getJdbcCatalogName(CatalogAndSchema schema) { |
||||
|
return null; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public String getJdbcSchemaName(CatalogAndSchema schema) { |
||||
|
return correctObjectName((schema.getCatalogName() == null) ? schema.getSchemaName() : schema.getCatalogName(), Schema.class); |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
protected String getAutoIncrementClause(final String generationType, final Boolean defaultOnNull) { |
||||
|
if (StringUtil.isEmpty(generationType)) { |
||||
|
return super.getAutoIncrementClause(); |
||||
|
} |
||||
|
|
||||
|
String autoIncrementClause = "GENERATED %s AS IDENTITY"; // %s -- [ ALWAYS | BY DEFAULT [ ON NULL ] ]
|
||||
|
String generationStrategy = generationType; |
||||
|
if (Boolean.TRUE.equals(defaultOnNull) && generationType.toUpperCase().equals("BY DEFAULT")) { |
||||
|
generationStrategy += " ON NULL"; |
||||
|
} |
||||
|
return String.format(autoIncrementClause, generationStrategy); |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public String generatePrimaryKeyName(String tableName) { |
||||
|
if (tableName.length() > 27) { |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
return "PK_" + tableName.toUpperCase(Locale.US).substring(0, 27); |
||||
|
} else { |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
return "PK_" + tableName.toUpperCase(Locale.US); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public boolean isReservedWord(String objectName) { |
||||
|
return reservedWords.contains(objectName.toUpperCase()); |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public boolean supportsSequences() { |
||||
|
return true; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* Oracle supports catalogs in liquibase terms |
||||
|
* |
||||
|
* @return false |
||||
|
*/ |
||||
|
@Override |
||||
|
public boolean supportsSchemas() { |
||||
|
return false; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
protected String getConnectionCatalogName() throws DatabaseException { |
||||
|
if (getConnection() instanceof OfflineConnection) { |
||||
|
return getConnection().getCatalog(); |
||||
|
} |
||||
|
try { |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
return Scope.getCurrentScope().getSingleton(ExecutorService.class).getExecutor("jdbc", this).queryForObject(new RawCallStatement("select sys_context( 'userenv', 'current_schema' ) from dual"), String.class); |
||||
|
} catch (Exception e) { |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
Scope.getCurrentScope().getLog(getClass()).info("Error getting default schema", e); |
||||
|
} |
||||
|
return null; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public String getDefaultCatalogName() {//NOPMD
|
||||
|
return (super.getDefaultCatalogName() == null) ? null : super.getDefaultCatalogName().toUpperCase(Locale.US); |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* <p>Returns an Oracle date literal with the same value as a string formatted using ISO 8601.</p> |
||||
|
* |
||||
|
* <p>Convert an ISO8601 date string to one of the following results: |
||||
|
* to_date('1995-05-23', 'YYYY-MM-DD') |
||||
|
* to_date('1995-05-23 09:23:59', 'YYYY-MM-DD HH24:MI:SS')</p> |
||||
|
* <p> |
||||
|
* Implementation restriction:<br> |
||||
|
* Currently, only the following subsets of ISO8601 are supported:<br> |
||||
|
* <ul> |
||||
|
* <li>YYYY-MM-DD</li> |
||||
|
* <li>YYYY-MM-DDThh:mm:ss</li> |
||||
|
* </ul> |
||||
|
*/ |
||||
|
@Override |
||||
|
public String getDateLiteral(String isoDate) { |
||||
|
String normalLiteral = super.getDateLiteral(isoDate); |
||||
|
|
||||
|
if (isDateOnly(isoDate)) { |
||||
|
return "TO_DATE(" + normalLiteral + ", 'YYYY-MM-DD')"; |
||||
|
} else if (isTimeOnly(isoDate)) { |
||||
|
return "TO_DATE(" + normalLiteral + ", 'HH24:MI:SS')"; |
||||
|
} else if (isTimestamp(isoDate)) { |
||||
|
return "TO_TIMESTAMP(" + normalLiteral + ", 'YYYY-MM-DD HH24:MI:SS.FF')"; |
||||
|
} else if (isDateTime(isoDate)) { |
||||
|
int seppos = normalLiteral.lastIndexOf('.'); |
||||
|
if (seppos != -1) { |
||||
|
normalLiteral = normalLiteral.substring(0, seppos) + "'"; |
||||
|
} |
||||
|
return "TO_DATE(" + normalLiteral + ", 'YYYY-MM-DD HH24:MI:SS')"; |
||||
|
} |
||||
|
return "UNSUPPORTED:" + isoDate; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public boolean isSystemObject(DatabaseObject example) { |
||||
|
if (example == null) { |
||||
|
return false; |
||||
|
} |
||||
|
|
||||
|
if (this.isLiquibaseObject(example)) { |
||||
|
return false; |
||||
|
} |
||||
|
|
||||
|
if (example instanceof Schema) { |
||||
|
//noinspection HardCodedStringLiteral,HardCodedStringLiteral,HardCodedStringLiteral,HardCodedStringLiteral
|
||||
|
if ("SYSTEM".equals(example.getName()) || "SYS".equals(example.getName()) || "CTXSYS".equals(example.getName()) || "XDB".equals(example.getName())) { |
||||
|
return true; |
||||
|
} |
||||
|
//noinspection HardCodedStringLiteral,HardCodedStringLiteral,HardCodedStringLiteral,HardCodedStringLiteral
|
||||
|
if ("SYSTEM".equals(example.getSchema().getCatalogName()) || "SYS".equals(example.getSchema().getCatalogName()) || "CTXSYS".equals(example.getSchema().getCatalogName()) || "XDB".equals(example.getSchema().getCatalogName())) { |
||||
|
return true; |
||||
|
} |
||||
|
} else if (isSystemObject(example.getSchema())) { |
||||
|
return true; |
||||
|
} |
||||
|
if (example instanceof Catalog) { |
||||
|
//noinspection HardCodedStringLiteral,HardCodedStringLiteral,HardCodedStringLiteral,HardCodedStringLiteral
|
||||
|
if (("SYSTEM".equals(example.getName()) || "SYS".equals(example.getName()) || "CTXSYS".equals(example.getName()) || "XDB".equals(example.getName()))) { |
||||
|
return true; |
||||
|
} |
||||
|
} else if (example.getName() != null) { |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
if (example.getName().startsWith("BIN$")) { //oracle deleted table
|
||||
|
boolean filteredInOriginalQuery = this.canAccessDbaRecycleBin(); |
||||
|
if (!filteredInOriginalQuery) { |
||||
|
filteredInOriginalQuery = StringUtil.trimToEmpty(example.getSchema().getName()).equalsIgnoreCase(this.getConnection().getConnectionUserName()); |
||||
|
} |
||||
|
|
||||
|
if (filteredInOriginalQuery) { |
||||
|
return !((example instanceof PrimaryKey) || (example instanceof Index) || (example instanceof |
||||
|
liquibase.statement.UniqueConstraint)); |
||||
|
} else { |
||||
|
return true; |
||||
|
} |
||||
|
} else //noinspection HardCodedStringLiteral
|
||||
|
if (example.getName().startsWith("AQ$")) { //oracle AQ tables
|
||||
|
return true; |
||||
|
} else //noinspection HardCodedStringLiteral
|
||||
|
if (example.getName().startsWith("DR$")) { //oracle index tables
|
||||
|
return true; |
||||
|
} else //noinspection HardCodedStringLiteral
|
||||
|
if (example.getName().startsWith("SYS_IOT_OVER")) { //oracle system table
|
||||
|
return true; |
||||
|
} else //noinspection HardCodedStringLiteral,HardCodedStringLiteral
|
||||
|
if ((example.getName().startsWith("MDRT_") || example.getName().startsWith("MDRS_")) && example.getName().endsWith("$")) { |
||||
|
// CORE-1768 - Oracle creates these for spatial indices and will remove them when the index is removed.
|
||||
|
return true; |
||||
|
} else //noinspection HardCodedStringLiteral
|
||||
|
if (example.getName().startsWith("MLOG$_")) { //Created by materliaized view logs for every table that is part of a materialized view. Not available for DDL operations.
|
||||
|
return true; |
||||
|
} else //noinspection HardCodedStringLiteral
|
||||
|
if (example.getName().startsWith("RUPD$_")) { //Created by materialized view log tables using primary keys. Not available for DDL operations.
|
||||
|
return true; |
||||
|
} else //noinspection HardCodedStringLiteral
|
||||
|
if (example.getName().startsWith("WM$_")) { //Workspace Manager backup tables.
|
||||
|
return true; |
||||
|
} else //noinspection HardCodedStringLiteral
|
||||
|
if ("CREATE$JAVA$LOB$TABLE".equals(example.getName())) { //This table contains the name of the Java object, the date it was loaded, and has a BLOB column to store the Java object.
|
||||
|
return true; |
||||
|
} else //noinspection HardCodedStringLiteral
|
||||
|
if ("JAVA$CLASS$MD5$TABLE".equals(example.getName())) { //This is a hash table that tracks the loading of Java objects into a schema.
|
||||
|
return true; |
||||
|
} else //noinspection HardCodedStringLiteral
|
||||
|
if (example.getName().startsWith("ISEQ$$_")) { //System-generated sequence
|
||||
|
return true; |
||||
|
} else //noinspection HardCodedStringLiteral
|
||||
|
if (example.getName().startsWith("USLOG$")) { //for update materialized view
|
||||
|
return true; |
||||
|
} else if (example.getName().startsWith("SYS_FBA")) { //for Flashback tables
|
||||
|
return true; |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
return super.isSystemObject(example); |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public boolean supportsAutoIncrement() { |
||||
|
// Oracle supports Identity beginning with version 12c
|
||||
|
boolean isAutoIncrementSupported = false; |
||||
|
|
||||
|
try { |
||||
|
if (getDatabaseMajorVersion() >= 12) { |
||||
|
isAutoIncrementSupported = true; |
||||
|
} |
||||
|
|
||||
|
// Returning true will generate create table command with 'IDENTITY' clause, example:
|
||||
|
// CREATE TABLE AutoIncTest (IDPrimaryKey NUMBER(19) GENERATED BY DEFAULT AS IDENTITY NOT NULL, TypeID NUMBER(3) NOT NULL, Description NVARCHAR2(50), CONSTRAINT PK_AutoIncTest PRIMARY KEY (IDPrimaryKey));
|
||||
|
|
||||
|
// While returning false will continue to generate create table command without 'IDENTITY' clause, example:
|
||||
|
// CREATE TABLE AutoIncTest (IDPrimaryKey NUMBER(19) NOT NULL, TypeID NUMBER(3) NOT NULL, Description NVARCHAR2(50), CONSTRAINT PK_AutoIncTest PRIMARY KEY (IDPrimaryKey));
|
||||
|
|
||||
|
} catch (DatabaseException ex) { |
||||
|
isAutoIncrementSupported = false; |
||||
|
} |
||||
|
|
||||
|
return isAutoIncrementSupported; |
||||
|
} |
||||
|
|
||||
|
|
||||
|
// public Set<UniqueConstraint> findUniqueConstraints(String schema) throws DatabaseException {
|
||||
|
// Set<UniqueConstraint> returnSet = new HashSet<UniqueConstraint>();
|
||||
|
//
|
||||
|
// List<Map> maps = new Executor(this).queryForList(new RawSqlStatement("SELECT UC.CONSTRAINT_NAME, UCC.TABLE_NAME, UCC.COLUMN_NAME FROM USER_CONSTRAINTS UC, USER_CONS_COLUMNS UCC WHERE UC.CONSTRAINT_NAME=UCC.CONSTRAINT_NAME AND CONSTRAINT_TYPE='U' ORDER BY UC.CONSTRAINT_NAME"));
|
||||
|
//
|
||||
|
// UniqueConstraint constraint = null;
|
||||
|
// for (Map map : maps) {
|
||||
|
// if (constraint == null || !constraint.getName().equals(constraint.getName())) {
|
||||
|
// returnSet.add(constraint);
|
||||
|
// Table table = new Table((String) map.get("TABLE_NAME"));
|
||||
|
// constraint = new UniqueConstraint(map.get("CONSTRAINT_NAME").toString(), table);
|
||||
|
// }
|
||||
|
// }
|
||||
|
// if (constraint != null) {
|
||||
|
// returnSet.add(constraint);
|
||||
|
// }
|
||||
|
//
|
||||
|
// return returnSet;
|
||||
|
// }
|
||||
|
|
||||
|
@Override |
||||
|
public boolean supportsRestrictForeignKeys() { |
||||
|
return false; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public int getDataTypeMaxParameters(String dataTypeName) { |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
if ("BINARY_FLOAT".equals(dataTypeName.toUpperCase())) { |
||||
|
return 0; |
||||
|
} |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
if ("BINARY_DOUBLE".equals(dataTypeName.toUpperCase())) { |
||||
|
return 0; |
||||
|
} |
||||
|
return super.getDataTypeMaxParameters(dataTypeName); |
||||
|
} |
||||
|
|
||||
|
public String getSystemTableWhereClause(String tableNameColumn) { |
||||
|
List<String> clauses = new ArrayList<String>(Arrays.asList("BIN$", |
||||
|
"AQ$", |
||||
|
"DR$", |
||||
|
"SYS_IOT_OVER", |
||||
|
"MLOG$_", |
||||
|
"RUPD$_", |
||||
|
"WM$_", |
||||
|
"ISEQ$$_", |
||||
|
"USLOG$", |
||||
|
"SYS_FBA")); |
||||
|
|
||||
|
for (int i = 0;i<clauses.size(); i++) { |
||||
|
clauses.set(i, tableNameColumn+" NOT LIKE '"+clauses.get(i)+"%'"); |
||||
|
} |
||||
|
return "("+ StringUtil.join(clauses, " AND ") + ")"; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public boolean jdbcCallsCatalogsSchemas() { |
||||
|
return true; |
||||
|
} |
||||
|
|
||||
|
public Set<String> getUserDefinedTypes() { |
||||
|
if (userDefinedTypes == null) { |
||||
|
userDefinedTypes = new HashSet<>(); |
||||
|
if ((getConnection() != null) && !(getConnection() instanceof OfflineConnection)) { |
||||
|
try { |
||||
|
try { |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
userDefinedTypes.addAll(Scope.getCurrentScope().getSingleton(ExecutorService.class).getExecutor("jdbc", this).queryForList(new RawSqlStatement("SELECT DISTINCT TYPE_NAME FROM ALL_TYPES"), String.class)); |
||||
|
} catch (DatabaseException e) { //fall back to USER_TYPES if the user cannot see ALL_TYPES
|
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
userDefinedTypes.addAll(Scope.getCurrentScope().getSingleton(ExecutorService.class).getExecutor("jdbc", this).queryForList(new RawSqlStatement("SELECT TYPE_NAME FROM USER_TYPES"), String.class)); |
||||
|
} |
||||
|
} catch (DatabaseException e) { |
||||
|
//ignore error
|
||||
|
} |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
return userDefinedTypes; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public String generateDatabaseFunctionValue(DatabaseFunction databaseFunction) { |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
if ((databaseFunction != null) && "current_timestamp".equalsIgnoreCase(databaseFunction.toString())) { |
||||
|
return databaseFunction.toString(); |
||||
|
} |
||||
|
if ((databaseFunction instanceof SequenceNextValueFunction) || (databaseFunction instanceof |
||||
|
SequenceCurrentValueFunction)) { |
||||
|
String quotedSeq = super.generateDatabaseFunctionValue(databaseFunction); |
||||
|
// replace "myschema.my_seq".nextval with "myschema"."my_seq".nextval
|
||||
|
return quotedSeq.replaceFirst("\"([^\\.\"]+)\\.([^\\.\"]+)\"", "\"$1\".\"$2\""); |
||||
|
|
||||
|
} |
||||
|
|
||||
|
return super.generateDatabaseFunctionValue(databaseFunction); |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public ValidationErrors validate() { |
||||
|
ValidationErrors errors = super.validate(); |
||||
|
DatabaseConnection connection = getConnection(); |
||||
|
if ((connection == null) || (connection instanceof OfflineConnection)) { |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
Scope.getCurrentScope().getLog(getClass()).info("Cannot validate offline database"); |
||||
|
return errors; |
||||
|
} |
||||
|
|
||||
|
if (!canAccessDbaRecycleBin()) { |
||||
|
errors.addWarning(getDbaRecycleBinWarning()); |
||||
|
} |
||||
|
|
||||
|
return errors; |
||||
|
|
||||
|
} |
||||
|
|
||||
|
public String getDbaRecycleBinWarning() { |
||||
|
//noinspection HardCodedStringLiteral,HardCodedStringLiteral,HardCodedStringLiteral,HardCodedStringLiteral,
|
||||
|
// HardCodedStringLiteral
|
||||
|
//noinspection HardCodedStringLiteral,HardCodedStringLiteral,HardCodedStringLiteral
|
||||
|
return "Liquibase needs to access the DBA_RECYCLEBIN table so we can automatically handle the case where " + |
||||
|
"constraints are deleted and restored. Since Oracle doesn't properly restore the original table names " + |
||||
|
"referenced in the constraint, we use the information from the DBA_RECYCLEBIN to automatically correct this" + |
||||
|
" issue.\n" + |
||||
|
"\n" + |
||||
|
"The user you used to connect to the database (" + getConnection().getConnectionUserName() + |
||||
|
") needs to have \"SELECT ON SYS.DBA_RECYCLEBIN\" permissions set before we can perform this operation. " + |
||||
|
"Please run the following SQL to set the appropriate permissions, and try running the command again.\n" + |
||||
|
"\n" + |
||||
|
" GRANT SELECT ON SYS.DBA_RECYCLEBIN TO " + getConnection().getConnectionUserName() + ";"; |
||||
|
} |
||||
|
|
||||
|
public boolean canAccessDbaRecycleBin() { |
||||
|
if (canAccessDbaRecycleBin == null) { |
||||
|
DatabaseConnection connection = getConnection(); |
||||
|
if ((connection == null) || (connection instanceof OfflineConnection)) { |
||||
|
return false; |
||||
|
} |
||||
|
|
||||
|
Statement statement = null; |
||||
|
try { |
||||
|
statement = ((JdbcConnection) connection).createStatement(); |
||||
|
@SuppressWarnings("HardCodedStringLiteral") ResultSet resultSet = statement.executeQuery("select 1 from dba_recyclebin where 0=1"); |
||||
|
resultSet.close(); //don't need to do anything with the result set, just make sure statement ran.
|
||||
|
this.canAccessDbaRecycleBin = true; |
||||
|
} catch (Exception e) { |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
if ((e instanceof SQLException) && e.getMessage().startsWith("ORA-00942")) { //ORA-00942: table or view does not exist
|
||||
|
this.canAccessDbaRecycleBin = false; |
||||
|
} else { |
||||
|
//noinspection HardCodedStringLiteral
|
||||
|
Scope.getCurrentScope().getLog(getClass()).warning("Cannot check dba_recyclebin access", e); |
||||
|
this.canAccessDbaRecycleBin = false; |
||||
|
} |
||||
|
} finally { |
||||
|
JdbcUtils.close(null, statement); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
return canAccessDbaRecycleBin; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public boolean supportsNotNullConstraintNames() { |
||||
|
return true; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* Tests if the given String would be a valid identifier in Oracle DBMS. In Oracle, a valid identifier has |
||||
|
* the following form (case-insensitive comparison): |
||||
|
* 1st character: A-Z |
||||
|
* 2..n characters: A-Z0-9$_# |
||||
|
* The maximum length of an identifier differs by Oracle version and object type. |
||||
|
*/ |
||||
|
public boolean isValidOracleIdentifier(String identifier, Class<? extends DatabaseObject> type) { |
||||
|
if ((identifier == null) || (identifier.length() < 1)) |
||||
|
return false; |
||||
|
|
||||
|
if (!identifier.matches("^(i?)[A-Z][A-Z0-9\\$\\_\\#]*$")) |
||||
|
return false; |
||||
|
|
||||
|
/* |
||||
|
* @todo It seems we currently do not have a class for tablespace identifiers, and all other classes |
||||
|
* we do know seem to be supported as 12cR2 long identifiers, so: |
||||
|
*/ |
||||
|
return (identifier.length() <= LONG_IDENTIFIERS_LEGNTH); |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* Returns the maximum number of bytes (NOT: characters) for an identifier. For Oracle <=12c Release 20, this |
||||
|
* is 30 bytes, and starting from 12cR2, up to 128 (except for tablespaces, PDB names and some other rather rare |
||||
|
* object types). |
||||
|
* |
||||
|
* @return the maximum length of an object identifier, in bytes |
||||
|
*/ |
||||
|
public int getIdentifierMaximumLength() { |
||||
|
try { |
||||
|
if (getDatabaseMajorVersion() < ORACLE_12C_MAJOR_VERSION) { |
||||
|
return SHORT_IDENTIFIERS_LENGTH; |
||||
|
} else if ((getDatabaseMajorVersion() == ORACLE_12C_MAJOR_VERSION) && (getDatabaseMinorVersion() <= 1)) { |
||||
|
return SHORT_IDENTIFIERS_LENGTH; |
||||
|
} else { |
||||
|
return LONG_IDENTIFIERS_LEGNTH; |
||||
|
} |
||||
|
} catch (DatabaseException ex) { |
||||
|
throw new UnexpectedLiquibaseException("Cannot determine the Oracle database version number", ex); |
||||
|
} |
||||
|
|
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,165 @@ |
|||||
|
package liquibase.datatype.core; |
||||
|
|
||||
|
import liquibase.change.core.LoadDataChange; |
||||
|
import liquibase.database.Database; |
||||
|
import liquibase.database.core.*; |
||||
|
import liquibase.datatype.DataTypeInfo; |
||||
|
import liquibase.datatype.DatabaseDataType; |
||||
|
import liquibase.datatype.LiquibaseDataType; |
||||
|
import liquibase.exception.UnexpectedLiquibaseException; |
||||
|
import liquibase.statement.DatabaseFunction; |
||||
|
import liquibase.util.StringUtil; |
||||
|
|
||||
|
import java.util.Locale; |
||||
|
import java.util.regex.Pattern; |
||||
|
|
||||
|
@DataTypeInfo(name = "boolean", aliases = {"java.sql.Types.BOOLEAN", "java.lang.Boolean", "bit", "bool"}, minParameters = 0, maxParameters = 0, priority = LiquibaseDataType.PRIORITY_DEFAULT) |
||||
|
public class BooleanType extends LiquibaseDataType { |
||||
|
|
||||
|
@Override |
||||
|
public DatabaseDataType toDatabaseDataType(Database database) { |
||||
|
String originalDefinition = StringUtil.trimToEmpty(getRawDefinition()); |
||||
|
if ((database instanceof Firebird3Database)) { |
||||
|
return new DatabaseDataType("BOOLEAN"); |
||||
|
} |
||||
|
|
||||
|
if ((database instanceof Db2zDatabase) || (database instanceof FirebirdDatabase)) { |
||||
|
return new DatabaseDataType("SMALLINT"); |
||||
|
} else if (database instanceof MSSQLDatabase) { |
||||
|
return new DatabaseDataType(database.escapeDataTypeName("bit")); |
||||
|
} else if (database instanceof MySQLDatabase) { |
||||
|
if (originalDefinition.toLowerCase(Locale.US).startsWith("bit")) { |
||||
|
return new DatabaseDataType("BIT", getParameters()); |
||||
|
} |
||||
|
return new DatabaseDataType("BIT", 1); |
||||
|
} else if (database instanceof OracleDatabase) { |
||||
|
return new DatabaseDataType("NUMBER", 1); |
||||
|
} else if ((database instanceof SybaseASADatabase) || (database instanceof SybaseDatabase)) { |
||||
|
return new DatabaseDataType("BIT"); |
||||
|
} else if (database instanceof DerbyDatabase) { |
||||
|
if (((DerbyDatabase) database).supportsBooleanDataType()) { |
||||
|
return new DatabaseDataType("BOOLEAN"); |
||||
|
} else { |
||||
|
return new DatabaseDataType("SMALLINT"); |
||||
|
} |
||||
|
} else if (database instanceof DB2Database) { |
||||
|
if (((DB2Database) database).supportsBooleanDataType()) |
||||
|
return new DatabaseDataType("BOOLEAN"); |
||||
|
else |
||||
|
return new DatabaseDataType("SMALLINT"); |
||||
|
} else if (database instanceof HsqlDatabase) { |
||||
|
return new DatabaseDataType("BOOLEAN"); |
||||
|
} else if (database instanceof PostgresDatabase) { |
||||
|
if (originalDefinition.toLowerCase(Locale.US).startsWith("bit")) { |
||||
|
return new DatabaseDataType("BIT", getParameters()); |
||||
|
} |
||||
|
} else if (database instanceof DmDatabase) { // dhb52: DM Support
|
||||
|
return new DatabaseDataType("bit"); |
||||
|
} |
||||
|
|
||||
|
return super.toDatabaseDataType(database); |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public String objectToSql(Object value, Database database) { |
||||
|
if ((value == null) || "null".equals(value.toString().toLowerCase(Locale.US))) { |
||||
|
return null; |
||||
|
} |
||||
|
|
||||
|
String returnValue; |
||||
|
if (value instanceof String) { |
||||
|
value = ((String) value).replaceAll("'", ""); |
||||
|
if ("true".equals(((String) value).toLowerCase(Locale.US)) || "1".equals(value) || "b'1'".equals(((String) value).toLowerCase(Locale.US)) || "t".equals(((String) value).toLowerCase(Locale.US)) || ((String) value).toLowerCase(Locale.US).equals(this.getTrueBooleanValue(database).toLowerCase(Locale.US))) { |
||||
|
returnValue = this.getTrueBooleanValue(database); |
||||
|
} else if ("false".equals(((String) value).toLowerCase(Locale.US)) || "0".equals(value) || "b'0'".equals( |
||||
|
((String) value).toLowerCase(Locale.US)) || "f".equals(((String) value).toLowerCase(Locale.US)) || ((String) value).toLowerCase(Locale.US).equals(this.getFalseBooleanValue(database).toLowerCase(Locale.US))) { |
||||
|
returnValue = this.getFalseBooleanValue(database); |
||||
|
} else if (database instanceof PostgresDatabase && Pattern.matches("b?([01])\\1*(::bit|::\"bit\")?", (String) value)) { |
||||
|
returnValue = "b'" |
||||
|
+ value.toString() |
||||
|
.replace("b", "") |
||||
|
.replace("\"", "") |
||||
|
.replace("::it", "") |
||||
|
+ "'::\"bit\""; |
||||
|
} else { |
||||
|
throw new UnexpectedLiquibaseException("Unknown boolean value: " + value); |
||||
|
} |
||||
|
} else if (value instanceof Long) { |
||||
|
if (Long.valueOf(1).equals(value)) { |
||||
|
returnValue = this.getTrueBooleanValue(database); |
||||
|
} else { |
||||
|
returnValue = this.getFalseBooleanValue(database); |
||||
|
} |
||||
|
} else if (value instanceof Number) { |
||||
|
if (value.equals(1) || "1".equals(value.toString()) || "1.0".equals(value.toString())) { |
||||
|
returnValue = this.getTrueBooleanValue(database); |
||||
|
} else { |
||||
|
returnValue = this.getFalseBooleanValue(database); |
||||
|
} |
||||
|
} else if (value instanceof DatabaseFunction) { |
||||
|
return value.toString(); |
||||
|
} else if (value instanceof Boolean) { |
||||
|
if (((Boolean) value)) { |
||||
|
returnValue = this.getTrueBooleanValue(database); |
||||
|
} else { |
||||
|
returnValue = this.getFalseBooleanValue(database); |
||||
|
} |
||||
|
} else { |
||||
|
throw new UnexpectedLiquibaseException("Cannot convert type " + value.getClass() + " to a boolean value"); |
||||
|
} |
||||
|
|
||||
|
return returnValue; |
||||
|
} |
||||
|
|
||||
|
protected boolean isNumericBoolean(Database database) { |
||||
|
if (database instanceof Firebird3Database) { |
||||
|
return false; |
||||
|
} |
||||
|
if (database instanceof DerbyDatabase) { |
||||
|
return !((DerbyDatabase) database).supportsBooleanDataType(); |
||||
|
} else if (database instanceof DB2Database) { |
||||
|
return !((DB2Database) database).supportsBooleanDataType(); |
||||
|
} |
||||
|
return (database instanceof Db2zDatabase) |
||||
|
|| (database instanceof FirebirdDatabase) |
||||
|
|| (database instanceof MSSQLDatabase) |
||||
|
|| (database instanceof MySQLDatabase) |
||||
|
|| (database instanceof OracleDatabase) |
||||
|
|| (database instanceof SQLiteDatabase) |
||||
|
|| (database instanceof SybaseASADatabase) |
||||
|
|| (database instanceof SybaseDatabase) |
||||
|
|| (database instanceof DmDatabase); // dhb52: DM Support
|
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* The database-specific value to use for "false" "boolean" columns. |
||||
|
*/ |
||||
|
public String getFalseBooleanValue(Database database) { |
||||
|
if (isNumericBoolean(database)) { |
||||
|
return "0"; |
||||
|
} |
||||
|
if (database instanceof InformixDatabase) { |
||||
|
return "'f'"; |
||||
|
} |
||||
|
return "FALSE"; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* The database-specific value to use for "true" "boolean" columns. |
||||
|
*/ |
||||
|
public String getTrueBooleanValue(Database database) { |
||||
|
if (isNumericBoolean(database)) { |
||||
|
return "1"; |
||||
|
} |
||||
|
if (database instanceof InformixDatabase) { |
||||
|
return "'t'"; |
||||
|
} |
||||
|
return "TRUE"; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public LoadDataChange.LOAD_DATA_TYPE getLoadTypeName() { |
||||
|
return LoadDataChange.LOAD_DATA_TYPE.BOOLEAN; |
||||
|
} |
||||
|
|
||||
|
} |
||||
File diff suppressed because it is too large
@ -0,0 +1 @@ |
|||||
|
防止IDEA将`.`和`/`混为一谈 |
||||
@ -0,0 +1,21 @@ |
|||||
|
liquibase.database.core.CockroachDatabase |
||||
|
liquibase.database.core.DB2Database |
||||
|
liquibase.database.core.Db2zDatabase |
||||
|
liquibase.database.core.DerbyDatabase |
||||
|
liquibase.database.core.Firebird3Database |
||||
|
liquibase.database.core.FirebirdDatabase |
||||
|
liquibase.database.core.H2Database |
||||
|
liquibase.database.core.HsqlDatabase |
||||
|
liquibase.database.core.InformixDatabase |
||||
|
liquibase.database.core.Ingres9Database |
||||
|
liquibase.database.core.MSSQLDatabase |
||||
|
liquibase.database.core.MariaDBDatabase |
||||
|
liquibase.database.core.MockDatabase |
||||
|
liquibase.database.core.MySQLDatabase |
||||
|
liquibase.database.core.OracleDatabase |
||||
|
liquibase.database.core.PostgresDatabase |
||||
|
liquibase.database.core.SQLiteDatabase |
||||
|
liquibase.database.core.SybaseASADatabase |
||||
|
liquibase.database.core.SybaseDatabase |
||||
|
liquibase.database.core.DmDatabase |
||||
|
liquibase.database.core.UnsupportedDatabase |
||||
File diff suppressed because it is too large
Some files were not shown because too many files changed in this diff
Loading…
Reference in new issue