当前位置：首页 > wzjs >正文

北京天通苑网站建设怎样开网站

wzjs 2025/7/21 0:31:08

北京天通苑网站建设,怎样开网站,动态网站建设多少钱,seo网站设计营销工具一、项目结构 src/main/java ├── com.example │ ├── config │ │ └── TableInitializer.java # 动态建表配置 │ ├── entity │ │ └── Order.java # JPA实体类 │ ├── repository │ │ └── OrderRepository.j…

一、项目结构

src/main/java
├── com.example
│   ├── config
│   │   └── TableInitializer.java      # 动态建表配置
│   ├── entity
│   │   └── Order.java                # JPA实体类
│   ├── repository
│   │   └── OrderRepository.java      # JPA Repository接口
│   └── DemoApplication.java          # 启动类
resources
├── application.yml                   # ShardingSphere配置

二、完整代码实现

pom.xml 依赖

<dependencies><!-- Spring Boot Starter --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- ShardingSphere JDBC --><dependency><groupId>org.apache.shardingsphere</groupId><artifactId>shardingsphere-jdbc-core-spring-boot-starter</artifactId><version>5.3.2</version></dependency><!-- Spring Data JPA --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jpa</artifactId></dependency><!-- MySQL驱动 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.28</version></dependency><!-- 日期时间处理 --><dependency><groupId>org.hibernate</groupId><artifactId>hibernate-java8</artifactId></dependency>
</dependencies>

application.yml 配置

spring:shardingsphere:# 数据源配置datasource:names: dsds:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://localhost:3306/test_db?serverTimezone=UTCusername: rootpassword: root# 分片规则rules:sharding:tables:t_order:  # 逻辑表名actual-data-nodes: ds.t_order_$->{2020..2030}  # 实际表结构table-strategy:standard:sharding-column: order_time  # 分片字段sharding-algorithm-name: order-year-intervalsharding-algorithms:order-year-interval:type: INTERVALprops:datetime-pattern: "yyyy-MM-dd HH:mm:ss"datetime-lower: "2020-01-01 00:00:00"datetime-upper: "2030-12-31 23:59:59"sharding-suffix-pattern: "yyyy"     # 表后缀格式datetime-interval-amount: 1         # 分片间隔1年# 其他配置props:sql-show: true  # 显示SQL日志jpa:hibernate:ddl-auto: none  # 禁用自动建表show-sql: trueproperties:hibernate:dialect: org.hibernate.dialect.MySQL8Dialect

实体类 Order.java

package com.example.entity;import javax.persistence.*;
import java.time.LocalDateTime;@Entity
@Table(name = "t_order")  // 对应逻辑表名
public class Order {@Id@GeneratedValue(generator = "snowflake")  // 使用分布式IDprivate Long id;@Column(name = "order_time", nullable = false)private LocalDateTime orderTime;  // 分片关键字段@Column(length = 50)private String orderNo;private BigDecimal amount;// Getters & Setters// 省略...
}

Repository接口 OrderRepository.java

package com.example.repository;import com.example.entity.Order;
import org.springframework.data.jpa.repository.JpaRepository;public interface OrderRepository extends JpaRepository<Order, Long> {// 根据时间范围查询（自动路由到对应年度表）List<Order> findByOrderTimeBetween(LocalDateTime start, LocalDateTime end);
}

动态建表配置 TableInitializer.java

package com.example.config;import javax.annotation.PostConstruct;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
import java.time.Year;
import java.util.stream.IntStream;@Component
public class TableInitializer {@Autowiredprivate DataSource dataSource;@PostConstructpublic void initTables() throws SQLException {try (Connection conn = dataSource.getConnection();Statement stmt = conn.createStatement()) {// 自动创建2020-2030年的物理表IntStream.rangeClosed(2020, 2030).forEach(year -> {String sql = "CREATE TABLE IF NOT EXISTS t_order_" + year + " (" +"id BIGINT PRIMARY KEY, " +"order_time DATETIME NOT NULL, " +"order_no VARCHAR(50), " +"amount DECIMAL(10,2))";try {stmt.executeUpdate(sql);} catch (SQLException e) {e.printStackTrace();}});}}
}

三、测试用例

@SpringBootTest
public class OrderTest {@Autowiredprivate OrderRepository orderRepository;@Testvoid testInsert() {Order order = new Order();order.setOrderTime(LocalDateTime.of(2023, 5, 20, 14, 30));order.setOrderNo("NO202305201430");order.setAmount(new BigDecimal("999.99"));orderRepository.save(order);  // 数据会插入t_order_2023表}@Testvoid testQuery() {LocalDateTime start = LocalDateTime.of(2023, 1, 1, 0, 0);LocalDateTime end = LocalDateTime.of(2023, 12, 31, 23, 59);List<Order> orders = orderRepository.findByOrderTimeBetween(start, end);System.out.println("Query Result: " + orders.size());}
}