In spring boot this solution is not work..

[liu2510865]

my project struct

when i test saveWrite() is ok,print log below

▶ DEBUG 10:12:53.671 [main] org.hibernate.SQL[logStatement:92] - select user0_.id as id1_4_0_, user0_.name as name2_4_0_ from users user0_ where user0_.id=?
▶ INFO 10:12:53.672 [main] m.j.t.r.ReplicationRoutingDataSource[determineCurrentLookupKey:19] - current dataSourceType : read
▶ TRACE 10:12:53.692 [main] o.h.type.descriptor.sql.BasicBinder[bind:65] - binding parameter [1] as [INTEGER] - [1]
▶ TRACE 10:12:53.739 [main] o.h.t.descriptor.sql.BasicExtractor[extract:61] - extracted value ([name2_4_0_] : [VARCHAR]) - [read_1]
▶ DEBUG 10:13:10.687 [main] org.hibernate.SQL[logStatement:92] - insert into users (id, name) values (null, ?)
▶ INFO 10:13:10.688 [main] m.j.t.r.ReplicationRoutingDataSource[determineCurrentLookupKey:19] - current dataSourceType : write
▶ TRACE 10:13:10.694 [main] o.h.type.descriptor.sql.BasicBinder[bind:65] - binding parameter [1] as [VARCHAR] - [New User]
▶ INFO 10:13:36.599 [main] m.j.t.AbstractReplicationDataSourceIntegrationTest[saveWrite:46] - User saved : User{id=5, name='New User'}
▶ DEBUG 10:13:37.237 [main] org.hibernate.SQL[logStatement:92] - select user0_.id as id1_4_0_, user0_.name as name2_4_0_ from users user0_ where user0_.id=?
▶ INFO 10:13:37.238 [main] m.j.t.r.ReplicationRoutingDataSource[determineCurrentLookupKey:19] - current dataSourceType : read
▶ TRACE 10:13:37.242 [main] o.h.type.descriptor.sql.BasicBinder[bind:65] - binding parameter [1] as [INTEGER] - [5]
▶ DEBUG 10:13:54.507 [main] org.hibernate.SQL[logStatement:92] - select user0_.id as id1_4_0_, user0_.name as name2_4_0_ from users user0_ where user0_.id=?
▶ INFO 10:13:54.509 [main] m.j.t.r.ReplicationRoutingDataSource[determineCurrentLookupKey:19] - current dataSourceType : write
▶ TRACE 10:13:54.521 [main] o.h.type.descriptor.sql.BasicBinder[bind:65] - binding parameter [1] as [INTEGER] - [5]
▶ TRACE 10:13:54.524 [main] o.h.t.descriptor.sql.BasicExtractor[extract:61] - extracted value ([name2_4_0_] : [VARCHAR]) - [New User]

,but in spring is not work, log below:

▶ DEBUG 18:27:11.716 [http-nio-8080-exec-4] org.hibernate.SQL[logStatement:92] - select user0_.id as id1_4_0_, user0_.name as name2_4_0_ from users user0_ where user0_.id=?
▶ INFO 18:27:17.901 [http-nio-8080-exec-4] mw.jpa.rwdb.DynamicDataSource[determineCurrentLookupKey:24] - current dataSourceType : read
▶ TRACE 18:27:17.904 [http-nio-8080-exec-4] o.h.type.descriptor.sql.BasicBinder[bind:65] - binding parameter [1] as [INTEGER] - [1]
▶ TRACE 18:27:17.906 [http-nio-8080-exec-4] o.h.t.descriptor.sql.BasicExtractor[extract:61] - extracted value ([name2_4_0_] : [VARCHAR]) - [read_1]
▶ DEBUG 18:27:17.913 [http-nio-8080-exec-4] org.hibernate.SQL[logStatement:92] - insert into users (id, name) values (null, ?)
▶ TRACE 18:27:17.914 [http-nio-8080-exec-4] o.h.type.descriptor.sql.BasicBinder[bind:65] - binding parameter [1] as [VARCHAR] - [New User]
▶ INFO 18:27:17.918 [http-nio-8080-exec-4] m.j.c.ReportTempletController[test:75] - User saved : User{id=7, name='New User'}
▶ INFO 18:27:17.920 [http-nio-8080-exec-4] m.j.c.ReportTempletController[test:78] - findByIdRead : false
▶ INFO 18:27:17.921 [http-nio-8080-exec-4] m.j.c.ReportTempletController[test:80] - findByIdWrite : false

in the test method current dataSourceType print three times, but in webController print just once.

my code zip,
spring-jpa-app.zip

please help.

[kwon37xi]

I don't get what you exactly did.

Please clarify your question.

Which url did you call? and what was the result you expected?

[liu2510865]

@kwon37xi
thank you reply.

I run test by ReplicationRoutingDataSourceIntegrationTest.java debug saveWrite method,print log below:

▶ DEBUG 10:12:53.671 [main] org.hibernate.SQL[logStatement:92] - select user0_.id as id1_4_0_, user0_.name as name2_4_0_ from users user0_ where user0_.id=?
▶ INFO 10:12:53.672 [main] m.j.t.r.ReplicationRoutingDataSource[determineCurrentLookupKey:19] - current dataSourceType : read
▶ TRACE 10:12:53.692 [main] o.h.type.descriptor.sql.BasicBinder[bind:65] - binding parameter [1] as [INTEGER] - [1]
▶ TRACE 10:12:53.739 [main] o.h.t.descriptor.sql.BasicExtractor[extract:61] - extracted value ([name2_4_0_] : [VARCHAR]) - [read_1]
▶ DEBUG 10:13:10.687 [main] org.hibernate.SQL[logStatement:92] - insert into users (id, name) values (null, ?)
▶ INFO 10:13:10.688 [main] m.j.t.r.ReplicationRoutingDataSource[determineCurrentLookupKey:19] - current dataSourceType : write
▶ TRACE 10:13:10.694 [main] o.h.type.descriptor.sql.BasicBinder[bind:65] - binding parameter [1] as [VARCHAR] - [New User]
▶ INFO 10:13:36.599 [main] m.j.t.AbstractReplicationDataSourceIntegrationTest[saveWrite:46] - User saved : User{id=5, name='New User'}
▶ DEBUG 10:13:37.237 [main] org.hibernate.SQL[logStatement:92] - select user0_.id as id1_4_0_, user0_.name as name2_4_0_ from users user0_ where user0_.id=?
▶ INFO 10:13:37.238 [main] m.j.t.r.ReplicationRoutingDataSource[determineCurrentLookupKey:19] - current dataSourceType : read
▶ TRACE 10:13:37.242 [main] o.h.type.descriptor.sql.BasicBinder[bind:65] - binding parameter [1] as [INTEGER] - [5]
▶ DEBUG 10:13:54.507 [main] org.hibernate.SQL[logStatement:92] - select user0_.id as id1_4_0_, user0_.name as name2_4_0_ from users user0_ where user0_.id=?
▶ INFO 10:13:54.509 [main] m.j.t.r.ReplicationRoutingDataSource[determineCurrentLookupKey:19] - current dataSourceType : write
▶ TRACE 10:13:54.521 [main] o.h.type.descriptor.sql.BasicBinder[bind:65] - binding parameter [1] as [INTEGER] - [5]
▶ TRACE 10:13:54.524 [main] o.h.t.descriptor.sql.BasicExtractor[extract:61] - extracted value ([name2_4_0_] : [VARCHAR]) - [New User]

▶ INFO 10:12:53.672 [main] m.j.t.r.ReplicationRoutingDataSource[determineCurrentLookupKey:19] - current dataSourceType :xxx
run three times when saveWrite processing,master salve can normal switch.

I copy this codes to main java dir,

add control
`@RestController
public class ExampleController {

@Autowired
private UserOuterService userOuterService;
@GetMapping("test")
public void saveWrite() throws Exception {
    User newUserFromRead = userOuterService.findByIdRead(1);
    User newUser = new User();
    newUser.setName("New User");

    userOuterService.save(newUser);
    System.out.println("***********************User saved : "+ newUser);

    newUserFromRead = userOuterService.findByIdRead(newUser.getId());
    System.out.println("***********************newUserFromRead : "+ (newUserFromRead==null));

    User newUserFromWrite = userOuterService.findByIdWrite(newUser.getId());
    System.out.println("***********************newUserFromRead : "+ (newUserFromWrite==null));
}

}`
run as spring boot, get http://localhost:8080/test server console print log below:

▶ INFO 10:13:51.259 [http-nio-8080-exec-2] o.a.c.c.C.[Tomcat].[localhost].[/][log:179] - Initializing Spring FrameworkServlet 'dispatcherServlet'
▶ INFO 10:13:51.260 [http-nio-8080-exec-2] o.s.web.servlet.DispatcherServlet[initServletBean:489] - FrameworkServlet 'dispatcherServlet': initialization started
▶ INFO 10:13:51.301 [http-nio-8080-exec-2] o.s.web.servlet.DispatcherServlet[initServletBean:508] - FrameworkServlet 'dispatcherServlet': initialization completed in 41 ms
▶ DEBUG 10:13:51.551 [http-nio-8080-exec-2] org.hibernate.SQL[logStatement:92] -
select
user0_.id as id1_0_0_,
user0_.name as name2_0_0_
from
users user0_
where
user0_.id=?
▶ INFO 10:13:51.551 [http-nio-8080-exec-2] k.p.k.r.r.ReplicationRoutingDataSource[determineCurrentLookupKey:20] - current dataSourceType : read
▶ TRACE 10:13:51.557 [http-nio-8080-exec-2] o.h.type.descriptor.sql.BasicBinder[bind:65] - binding parameter [1] as [INTEGER] - [1]
▶ TRACE 10:13:51.570 [http-nio-8080-exec-2] o.h.t.descriptor.sql.BasicExtractor[extract:61] - extracted value ([name2_0_0_] : [VARCHAR]) - [read_1]
▶ DEBUG 10:13:51.595 [http-nio-8080-exec-2] org.hibernate.SQL[logStatement:92] -
insert
into
users
(id, name)
values
(null, ?)
▶ TRACE 10:13:51.597 [http-nio-8080-exec-2] o.h.type.descriptor.sql.BasicBinder[bind:65] - binding parameter [1] as [VARCHAR] - [New User]
***********************User saved : User{id=5, name='New User'}
***********************newUserFromRead : false
***********************newUserFromRead : false

in this log information
,▶ INFO 10:13:51.551 [http-nio-8080-exec-2] k.p.k.r.r.ReplicationRoutingDataSource[determineCurrentLookupKey:20] - current dataSourceType : xxx
just run one time, execute the same code.
so in this Controller method master salve db cann't switch.