{"id":1961,"date":"2023-04-01T10:26:09","date_gmt":"2023-04-01T02:26:09","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=1961"},"modified":"2023-04-22T08:36:04","modified_gmt":"2023-04-22T00:36:04","slug":"sharding-sphere-sharding-jdbc-sub-database-and-sub-table-based-on-jpa","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/04\/01\/sharding-sphere-sharding-jdbc-sub-database-and-sub-table-based-on-jpa\/","title":{"rendered":"Sharding-Sphere\uff1aSharding-JDBC\u5206\u5e93\u5206\u8868\uff08\u57fa\u4e8eJPA\uff09"},"content":{"rendered":"

\u5b98\u65b9\u6587\u6863<\/h2>\n

GitHub\u7684\u5730\u5740\uff1ahttps:\/\/github.com\/apache\/incubator-shardingsphere<\/a>
\nshardingsphere\uff1ahttps:\/\/github.com\/apache\/incubator-shardingsphere-example<\/a>
\n\u4e2d\u6587\u6587\u6863\u5730\u5740\uff1ahttps:\/\/shardingsphere.apache.org\/document\/current\/cn\/overview\/<\/a><\/p>\n

<\/p>\n

\u4ee3\u7801\u5b9e\u73b0\uff08JPA\uff09<\/h2>\n

\uff081\uff09\u67093\u5f20\u8868t_member<\/code>\u3001t_order<\/code>\u3001t_order_item<\/code>\uff0c\u62c6\u5206\u52302\u4e2a\u6570\u636e\u5e93\u4e2d\uff0c\u6bcf\u4e2a\u6570\u636e\u5e932\u4efd\uff0c\u76f8\u5f53\u4e8e\u6bcf\u5f20\u8868\u62c6\u6210\u4e864\u5f20\uff0c\u9700\u8981\u6ce8\u610f\u7684\u662f\u6bcf\u4e2a\u8868\u7684\u4e3b\u952eId\u5c3d\u91cf\u8bbe\u7f6e\u6210 bigint \uff08\u6211\u5f00\u59cb\u8bbe\u7f6e\u4e3avarchar\uff0c\u7ed3\u679c\u5206\u8868\u65f6\u62a5\u9519\uff09\uff0c\u7ed3\u6784\u5982\u4e0b\uff1a<\/p>\n

\"\u5206\u5e93\u5206\u8868\u8bbe\u8ba1\"<\/p>\n

\uff082\uff09\u65b0\u5efaSpringBoot\u9879\u76ee\uff0c\u5f15\u5165\u4f9d\u8d56\uff1a<\/p>\n

<dependency>\n    <groupId>org.apache.shardingsphere<\/groupId>\n    <artifactId>sharding-jdbc-spring-boot-starter<\/artifactId>\n    <version>${sharding-sphere.version}<\/version>\n<\/dependency>\n<dependency>\n    <groupId>org.apache.shardingsphere<\/groupId>\n    <artifactId>sharding-jdbc-spring-namespace<\/artifactId>\n    <version>${sharding-sphere.version}<\/version>\n<\/dependency>\n<dependency>\n    <groupId>org.springframework.boot<\/groupId>\n    <artifactId>spring-boot-starter-web<\/artifactId>\n<\/dependency>\n<dependency>\n    <groupId>org.springframework.boot<\/groupId>\n    <artifactId>spring-boot-starter-data-jpa<\/artifactId>\n<\/dependency>\n<dependency>\n    <groupId>mysql<\/groupId>\n    <artifactId>mysql-connector-java<\/artifactId>\n    <version>5.1.47<\/version>\n<\/dependency>\n<dependency>\n    <groupId>com.alibaba<\/groupId>\n    <artifactId>druid<\/artifactId>\n    <version>1.1.16<\/version>\n<\/dependency>\n<dependency>\n    <groupId>com.alibaba<\/groupId>\n    <artifactId>fastjson<\/artifactId>\n    <version>1.2.47<\/version>\n<\/dependency>\n<dependency>\n    <groupId>org.projectlombok<\/groupId>\n    <artifactId>lombok<\/artifactId>\n    <optional>true<\/optional>\n<\/dependency><\/code><\/pre>\n
\uff083\uff09\u6dfb\u52a0\u914d\u7f6e\u6587\u4ef6\uff0c\u8fd9\u70b9\u5f88\u91cd\u8981\uff0c\u5426\u5219\u65e0\u6cd5\u5b9e\u73b0\u5206\u5e93\u5206\u8868\uff0cds$->{0..1}.t_member$->{0..1}<\/code>\uff0c\u8868\u8fbe\u5f0f\u76f8\u5f53\u4e8e\uff1ads0.t_member0<\/code>\u3001ds0.t_member1<\/code>\u3001ds1.t_member0<\/code>\u3001ds1.t_member1<\/code>\uff0c\u5728\u914d\u7f6e\u4e2d\u914d\u7f6e\u4e86key-generator.column<\/code>\uff0c\u6240\u4ee5\u65b0\u589e\u8be5\u8868\u6570\u636e\u65f6\uff0c\u4e0d\u9700\u8981\u7ed9\u4e3b\u952eid\u8d4b\u503c\uff0csharding-jdbc\u4f1a\u8c03\u7528\u5185\u7f6e\u7684SNOWFLAKE\u7b97\u6cd5\u751f\u6210\u5206\u5e03\u5f0fid\uff0c\u8bf7\u5f80\u4e0b\u770b<\/p>\n
server.port=8072\n\nspring.jpa.hibernate.ddl-auto=none\nspring.jpa.database=mysql\nspring.jpa.show-sql=true\nspring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5Dialect\n\nspring.shardingsphere.datasource.names=ds0,ds1\n\nspring.shardingsphere.datasource.ds0.type=com.alibaba.druid.pool.DruidDataSource\nspring.shardingsphere.datasource.ds0.driver-class-name=com.mysql.jdbc.Driver\nspring.shardingsphere.datasource.ds0.url=jdbc:mysql:\/\/47.107.177.150:3306\/ds0?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&failOverReadOnly=false&maxReconnects=15000&allowMultiQueries=true&useSSL=false\nspring.shardingsphere.datasource.ds0.username=xnxx\nspring.shardingsphere.datasource.ds0.password=Xnxx85781245!\n\nspring.shardingsphere.datasource.ds1.type=com.alibaba.druid.pool.DruidDataSource\nspring.shardingsphere.datasource.ds1.driver-class-name=com.mysql.jdbc.Driver\nspring.shardingsphere.datasource.ds1.url=jdbc:mysql:\/\/47.107.177.150:3306\/ds1?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&failOverReadOnly=false&maxReconnects=15000&allowMultiQueries=true&useSSL=false\nspring.shardingsphere.datasource.ds1.username=xnxx\nspring.shardingsphere.datasource.ds1.password=Xnxx85781245!\n\nspring.shardingsphere.sharding.default-database-strategy.inline.sharding-column=member_id\nspring.shardingsphere.sharding.default-database-strategy.inline.algorithm-expression=ds$->{member_id % 2}\n\nspring.shardingsphere.sharding.tables.t_member.actual-data-nodes=ds$->{0..1}.t_member$->{0..1}\nspring.shardingsphere.sharding.tables.t_member.table-strategy.inline.sharding-column=member_id\nspring.shardingsphere.sharding.tables.t_member.table-strategy.inline.algorithm-expression=t_member$->{member_id % 2}\nspring.shardingsphere.sharding.tables.t_member.key-generator.column=member_id\nspring.shardingsphere.sharding.tables.t_member.key-generator.type=SNOWFLAKE\n\n#spring.shardingsphere.sharding.tables.t_order.actual-data-nodes=ds$->{0..1}.t_order$->{0..1}\n#spring.shardingsphere.sharding.tables.t_order.actual-data-nodes=ds0.t_order0, ds1.t_order1\n#spring.shardingsphere.sharding.tables.t_order.table-strategy.inline.sharding-column=order_id\n#spring.shardingsphere.sharding.tables.t_order.table-strategy.inline.algorithm-expression=t_order$->{order_id % 2}\n#spring.shardingsphere.sharding.tables.t_order.key-generator.column=order_id\n#spring.shardingsphere.sharding.tables.t_order.key-generator.type=SNOWFLAKE\n#\n#spring.shardingsphere.sharding.tables.t_order_item.actual-data-nodes=ds$->{0..1}.t_order_item$->{0..1}\n#spring.shardingsphere.sharding.tables.t_order_item.table-strategy.inline.sharding-column=order_id\n#spring.shardingsphere.sharding.tables.t_order_item.table-strategy.inline.algorithm-expression=t_order_item$->{order_id % 2}\n#spring.shardingsphere.sharding.tables.t_order_item.key-generator.column=order_item_id\n#spring.shardingsphere.sharding.tables.t_order_item.key-generator.type=SNOWFLAKE\n\n#spring.shardingsphere.sharding.binding-tables=t_member,t_order,t_order_item\n#spring.shardingsphere.sharding.broadcast-tables=t_config\n\nspring.shardingsphere.props.sql.show=true<\/code><\/pre>\n
\uff084\uff09Durid\u914d\u7f6e<\/p>\n
@Configuration\npublic class DuridConfig {\n\n    @Bean\n    public Filter statFilter() {\n        StatFilter filter = new StatFilter();\n        filter.setSlowSqlMillis(5000);\n        filter.setLogSlowSql(true);\n        filter.setMergeSql(true);\n        return filter;\n    }\n\n    @Bean\n    public ServletRegistrationBean statViewServlet() {\n        \/\/\u521b\u5efaservlet\u6ce8\u518c\u5b9e\u4f53\n        ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(), "\/druid\/*");\n        \/\/\u8bbe\u7f6eip\u767d\u540d\u5355\n        servletRegistrationBean.addInitParameter("allow", "127.0.0.1");\n        \/\/\u8bbe\u7f6eip\u9ed1\u540d\u5355\uff0c\u5982\u679callow\u4e0edeny\u5171\u540c\u5b58\u5728\u65f6,deny\u4f18\u5148\u4e8eallow\n        \/\/servletRegistrationBean.addInitParameter("deny","192.168.0.19");\n        \/\/\u8bbe\u7f6e\u63a7\u5236\u53f0\u7ba1\u7406\u7528\u6237\n        servletRegistrationBean.addInitParameter("loginUsername", "admin");\n        servletRegistrationBean.addInitParameter("loginPassword", "123456");\n        \/\/\u662f\u5426\u53ef\u4ee5\u91cd\u7f6e\u6570\u636e\n        servletRegistrationBean.addInitParameter("resetEnable", "false");\n        return servletRegistrationBean;\n    }\n\n}<\/code><\/pre>\n
\uff085\uff09\u6dfb\u52a0MemberService\u670d\u52a1\u63a5\u53e3\u4e0e\u5b9e\u73b0<\/p>\n
@Data\n@Entity\n@Table(name = "t_member")\npublic class Member {\n\n    @Id\n    @Column(name = "member_id")\n    private Long memberId;\n\n    @Column(name = "member_name")\n    private String memberName;\n\n    @Column(name = "nick_name")\n    private String nickName;\n\n    @Column(name = "account_no")\n    private String accountNo;\n\n    @Column(name = "password")\n    private String password;\n\n    @Column(name = "age")\n    private Integer age;\n\n    @Column(name = "birth_date")\n    private Date birthDate;\n\n    @Column(name = "ebl_flag")\n    private String eblFlag;\n\n    @Column(name = "del_flag")\n    private String delFlag;\n\n    @Column(name = "description")\n    private String description;\n\n    @Column(name = "create_time")\n    private Date createTime;\n\n    @Column(name = "update_time")\n    private Date updateTime;\n}\n\n@Repository\npublic interface MemberRepository extends JpaRepository<Member , Long> {\n\n}<\/code><\/pre>\n
\uff086\uff09\u6dfb\u52a0MemberController<\/p>\n
@RequestMapping("\/member")\n@RestController\npublic class MemberController {\n\n    @Autowired private MemberRepository memberRepository;\n\n    @RequestMapping("\/health")\n    public String health(){\n        return "success";\n    }\n\n    @RequestMapping("\/findAll")\n    public Object findAll(){\n        return memberRepository.findAll();\n    }\n\n    @RequestMapping("\/add")\n    public Object add(){\n        Member member = addMember();\n        return memberRepository.save(member);\n    }\n\n    @RequestMapping("\/findById")\n    public Member findById(Long memberId){\n        return memberRepository.findById(memberId).get();\n    }\n\n    private Member addMember(){\n        Member member = new Member();\n        member.setMemberId(IdWorker.getLongId());\n        \/\/SnowflakeShardingKeyGenerator keyGenerator = new SnowflakeShardingKeyGenerator();\n        \/\/member.setMemberId(Long.parseLong(keyGenerator.generateKey().toString()));\n        member.setMemberName("\u5f20\u4e09");\n        member.setNickName("\u95ea\u8000\u7684\u77ac\u95f4");\n        member.setAccountNo(member.getMemberId()+"");\n        member.setPassword("123465");\n        member.setAge(27);\n        member.setBirthDate(new Date());\n        member.setEblFlag("1");\n        member.setDelFlag("0");\n        member.setDescription("xxx");\n        member.setCreateTime(new Date());\n        member.setUpdateTime(new Date());\n        return member;\n    }\n}<\/code><\/pre>\n
\uff087\uff09\u542f\u52a8\u9879\u76ee\uff0c\u8bbf\u95ee\u65b0\u589e\u63a5\u53e3 http:\/\/localhost:8071\/member\/add<\/a> \uff0c\u53ef\u4ee5\u770b\u5230\u9875\u9762\u8fd4\u56de\u4e86\u65b0\u589e\u540e\u7684\u6570\u636e<\/p>\n
\u540c\u65f6\u67e5\u770bIntellij IDEA\u63a7\u5236\u53f0\uff0c\u53ef\u4ee5\u770b\u5230\u6570\u636e\u63d2\u5165\u5230ds1<\/code>\u5e93\u7684t_member1<\/code>\u8868\u4e86<\/p>\n
\u518d\u67e5\u770bds1<\/code>\u6570\u636e\u5e93\u7684t_member1<\/code>\u8868\uff0c\u6709\u521a\u521a\u65b0\u589e\u7684\u8bb0\u5f55<\/p>\n
\uff088\uff09\u8bbf\u95ee\u67e5\u8be2\u63a5\u53e3 http:\/\/localhost:8072\/member\/findById?memberId=xxxxxx<\/a><\/p>\n
\u540c\u65f6\u67e5\u770b\u63a7\u5236\u53f0\uff0csql\u4f1a\u81ea\u52a8\u8def\u7531\u5230ds1<\/code>\u5e93\u53bb\u67e5\u8be2\u6570\u636e<\/p>\n
\u53c2\u8003\uff1ahttps:\/\/gitee.com\/zhuyu1991\/spring-cloud\/tree\/master\/sharding-business\/db-table-jpa<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
\u5b98\u65b9\u6587\u6863 GitHub\u7684\u5730\u5740\uff1ahttps:\/\/github.com\/apache\/incubator-shar […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[491],"tags":[451,436,492,299],"class_list":["post-1961","post","type-post","status-publish","format-standard","hentry","category-sharding-sphere","tag-jpa","tag-sharding-jdbc","tag-sharding-sphere","tag-299"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1961","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/comments?post=1961"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1961\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=1961"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=1961"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=1961"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}