This is an automated email from the ASF dual-hosted git repository.
jimin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-seata-samples.git
The following commit(s) were added to refs/heads/master by this push:
new 651c8afc optimize: optimize spring-seata sample (#678)
651c8afc is described below
commit 651c8afc9af32af2ab440520b2a1170da5ed2f5f
Author: jimin <[email protected]>
AuthorDate: Fri May 17 00:06:00 2024 +0800
optimize: optimize spring-seata sample (#678)
---
.../main/java/org/apache/seata/config/DataSourceConfiguration.java | 2 +-
.../src/main/java/org/apache/seata/config/SeataConfiguration.java | 2 +-
.../apache/seata/service/{StorageService.java => StockService.java} | 2 +-
.../java/org/apache/seata/service/impl/BusinessServiceImpl.java | 6 +++---
.../main/java/org/apache/seata/service/impl/OrderServiceImpl.java | 2 +-
.../service/impl/{StorageServiceImpl.java => StockServiceImpl.java} | 6 +++---
at-sample/spring-seata/src/main/resources/all.sql | 5 ++++-
7 files changed, 14 insertions(+), 11 deletions(-)
diff --git
a/at-sample/spring-seata/src/main/java/org/apache/seata/config/DataSourceConfiguration.java
b/at-sample/spring-seata/src/main/java/org/apache/seata/config/DataSourceConfiguration.java
index 7d6687c4..abf7f46f 100644
---
a/at-sample/spring-seata/src/main/java/org/apache/seata/config/DataSourceConfiguration.java
+++
b/at-sample/spring-seata/src/main/java/org/apache/seata/config/DataSourceConfiguration.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.seata.provider.config;
+package org.apache.seata.config;
import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.beans.factory.annotation.Value;
diff --git
a/at-sample/spring-seata/src/main/java/org/apache/seata/config/SeataConfiguration.java
b/at-sample/spring-seata/src/main/java/org/apache/seata/config/SeataConfiguration.java
index 029f876a..c5af9c6d 100644
---
a/at-sample/spring-seata/src/main/java/org/apache/seata/config/SeataConfiguration.java
+++
b/at-sample/spring-seata/src/main/java/org/apache/seata/config/SeataConfiguration.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.apache.seata.provider.config;
+package org.apache.seata.config;
import io.seata.spring.annotation.GlobalTransactionScanner;
import org.springframework.beans.factory.annotation.Value;
diff --git
a/at-sample/spring-seata/src/main/java/org/apache/seata/service/StorageService.java
b/at-sample/spring-seata/src/main/java/org/apache/seata/service/StockService.java
similarity index 96%
rename from
at-sample/spring-seata/src/main/java/org/apache/seata/service/StorageService.java
rename to
at-sample/spring-seata/src/main/java/org/apache/seata/service/StockService.java
index 0f68fad9..bf4d6541 100644
---
a/at-sample/spring-seata/src/main/java/org/apache/seata/service/StorageService.java
+++
b/at-sample/spring-seata/src/main/java/org/apache/seata/service/StockService.java
@@ -19,7 +19,7 @@ package org.apache.seata.service;
/**
* The interface Stock service.
*/
-public interface StorageService {
+public interface StockService {
/**
* 扣减库存
diff --git
a/at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/BusinessServiceImpl.java
b/at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/BusinessServiceImpl.java
index a18e5aa8..2a63949b 100644
---
a/at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/BusinessServiceImpl.java
+++
b/at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/BusinessServiceImpl.java
@@ -21,7 +21,7 @@ import io.seata.spring.annotation.GlobalTransactional;
import org.apache.seata.service.BusinessService;
import org.apache.seata.service.OrderService;
-import org.apache.seata.service.StorageService;
+import org.apache.seata.service.StockService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -41,7 +41,7 @@ public class BusinessServiceImpl implements BusinessService {
private static final Logger LOGGER =
LoggerFactory.getLogger(BusinessService.class);
@Resource
- private StorageService storageService;
+ private StockService stockService;
@Resource
private OrderService orderService;
private final Random random = new Random();
@@ -50,7 +50,7 @@ public class BusinessServiceImpl implements BusinessService {
@GlobalTransactional(timeoutMills = 300000, name = "spring-seata-tx")
public void purchase(String userId, String commodityCode, int orderCount) {
LOGGER.info("purchase begin ... xid: " + RootContext.getXID());
- storageService.deduct(commodityCode, orderCount);
+ stockService.deduct(commodityCode, orderCount);
orderService.create(userId, commodityCode, orderCount);
if (random.nextBoolean()) {
throw new RuntimeException("random exception mock!");
diff --git
a/at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/OrderServiceImpl.java
b/at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/OrderServiceImpl.java
index 7aede43d..80e1b898 100644
---
a/at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/OrderServiceImpl.java
+++
b/at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/OrderServiceImpl.java
@@ -78,7 +78,7 @@ public class OrderServiceImpl implements OrderService {
}
private int calculate(String commodityId, int orderCount) {
- return 200 * orderCount;
+ return 100 * orderCount;
}
}
diff --git
a/at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/StorageServiceImpl.java
b/at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/StockServiceImpl.java
similarity index 92%
rename from
at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/StorageServiceImpl.java
rename to
at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/StockServiceImpl.java
index 8ee0cc42..0ca6406f 100644
---
a/at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/StorageServiceImpl.java
+++
b/at-sample/spring-seata/src/main/java/org/apache/seata/service/impl/StockServiceImpl.java
@@ -16,7 +16,7 @@
package org.apache.seata.service.impl;
import io.seata.core.context.RootContext;
-import org.apache.seata.service.StorageService;
+import org.apache.seata.service.StockService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jdbc.core.JdbcTemplate;
@@ -30,9 +30,9 @@ import javax.annotation.Resource;
* @author jimin.jm @alibaba-inc.com
*/
@Service
-public class StorageServiceImpl implements StorageService {
+public class StockServiceImpl implements StockService {
- private static final Logger LOGGER =
LoggerFactory.getLogger(StorageService.class);
+ private static final Logger LOGGER =
LoggerFactory.getLogger(StockService.class);
@Resource
private JdbcTemplate jdbcTemplate;
diff --git a/at-sample/spring-seata/src/main/resources/all.sql
b/at-sample/spring-seata/src/main/resources/all.sql
index a6974d7f..48d7ff4c 100644
--- a/at-sample/spring-seata/src/main/resources/all.sql
+++ b/at-sample/spring-seata/src/main/resources/all.sql
@@ -53,4 +53,7 @@ CREATE TABLE IF NOT EXISTS `undo_log`
`log_modified` DATETIME(6) NOT NULL COMMENT 'modify datetime',
UNIQUE KEY `ux_undo_log` (`xid`, `branch_id`)
) ENGINE = InnoDB AUTO_INCREMENT = 1 DEFAULT CHARSET = utf8mb4 COMMENT
='AT transaction mode undo table';
-ALTER TABLE `undo_log` ADD INDEX `ix_log_created` (`log_created`);
\ No newline at end of file
+ALTER TABLE `undo_log` ADD INDEX `ix_log_created` (`log_created`);
+
+insert into account_tbl (user_id, money) values ('U100001', 10000);
+insert into stock_tbl (commodity_code, count) values ('C00321', 100);
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
