Compare commits
14 Commits
| Author | SHA1 | Date |
|---|---|---|
Yan
|
ea1dda8da5 | 4 months ago |
|
Yan
|
1cef5e5d65 | 4 months ago |
|
Yan
|
13436df52c | 7 months ago |
|
Yan
|
c0a0544923 | 7 months ago |
|
Yan
|
be9d328eee | 7 months ago |
|
Yan
|
4bfe1461d2 | 7 months ago |
|
Yan
|
b580a25efd | 7 months ago |
|
Yan
|
bdf0ce7e0b | 7 months ago |
|
Yan
|
2f7c4075f7 | 7 months ago |
|
Yan
|
b5c8890bfb | 7 months ago |
|
Yan
|
7c89a6361e | 8 months ago |
|
Yan
|
fadca4d287 | 8 months ago |
|
Yan
|
ee7b4028de | 8 months ago |
|
Yan
|
21b1e672ff | 8 months ago |
@ -0,0 +1,20 @@
|
|||||||
|
meta {
|
||||||
|
name: findSession
|
||||||
|
type: http
|
||||||
|
seq: 4
|
||||||
|
}
|
||||||
|
|
||||||
|
get {
|
||||||
|
url: http://localhost:8761/services/api/session/d4415f6c-da1d-435c-95be-73bafe165768
|
||||||
|
body: none
|
||||||
|
auth: basic
|
||||||
|
}
|
||||||
|
|
||||||
|
headers {
|
||||||
|
operationName: findUsers
|
||||||
|
}
|
||||||
|
|
||||||
|
auth:basic {
|
||||||
|
username: cxfrs
|
||||||
|
password: password
|
||||||
|
}
|
||||||
@ -1,11 +1,11 @@
|
|||||||
meta {
|
meta {
|
||||||
name: findUsers
|
name: findSessions
|
||||||
type: http
|
type: http
|
||||||
seq: 2
|
seq: 2
|
||||||
}
|
}
|
||||||
|
|
||||||
get {
|
get {
|
||||||
url: http://localhost:9090/services/api/user
|
url: http://localhost:8761/services/api/session
|
||||||
body: none
|
body: none
|
||||||
auth: basic
|
auth: basic
|
||||||
}
|
}
|
||||||
@ -0,0 +1,33 @@
|
|||||||
|
meta {
|
||||||
|
name: updateSession
|
||||||
|
type: http
|
||||||
|
seq: 3
|
||||||
|
}
|
||||||
|
|
||||||
|
post {
|
||||||
|
url: http://localhost:8761/services/api/session
|
||||||
|
body: json
|
||||||
|
auth: basic
|
||||||
|
}
|
||||||
|
|
||||||
|
headers {
|
||||||
|
Content-Type: application/json
|
||||||
|
X-MethodName: updateUser
|
||||||
|
}
|
||||||
|
|
||||||
|
auth:basic {
|
||||||
|
username: cxfrs
|
||||||
|
password: password
|
||||||
|
}
|
||||||
|
|
||||||
|
body:json {
|
||||||
|
{
|
||||||
|
"sessionId": "{{uuid}}",
|
||||||
|
"username": "admin",
|
||||||
|
"password": "@dminPwd123"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
script:pre-request {
|
||||||
|
bru.setVar('uuid', require("uuid").v4());
|
||||||
|
}
|
||||||
@ -1,28 +0,0 @@
|
|||||||
meta {
|
|
||||||
name: updateUser
|
|
||||||
type: http
|
|
||||||
seq: 3
|
|
||||||
}
|
|
||||||
|
|
||||||
post {
|
|
||||||
url: http://localhost:9090/services/api/user
|
|
||||||
body: json
|
|
||||||
auth: basic
|
|
||||||
}
|
|
||||||
|
|
||||||
headers {
|
|
||||||
Content-Type: application/json
|
|
||||||
X-MethodName: updateUser
|
|
||||||
}
|
|
||||||
|
|
||||||
auth:basic {
|
|
||||||
username: cxfrs
|
|
||||||
password: password
|
|
||||||
}
|
|
||||||
|
|
||||||
body:json {
|
|
||||||
{
|
|
||||||
"id": 3,
|
|
||||||
"name": "Bruce Wayne"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Binary file not shown.
@ -0,0 +1,105 @@
|
|||||||
|
2025-03-08 12:36:27.115360+08:00 jdbc[3]: exception
|
||||||
|
org.h2.jdbc.JdbcSQLSyntaxErrorException: Syntax error in SQL statement "MERGE INTO [*]USER (?) VALUES (?, ?)"; expected "identifier"; SQL statement:
|
||||||
|
MERGE INTO USER (?) VALUES (?, ?) [42001-224]
|
||||||
|
2025-03-08 12:41:38.334685+08:00 jdbc[3]: exception
|
||||||
|
org.h2.jdbc.JdbcSQLSyntaxErrorException: Syntax error in SQL statement "CREATE TABLE IF NOT EXISTS public.[*]user (id BIGINT not null, name CHARACTER VARYING not null, PRIMARY KEY (id))"; expected "identifier"; SQL statement:
|
||||||
|
CREATE TABLE IF NOT EXISTS public.user (id BIGINT not null, name CHARACTER VARYING not null, PRIMARY KEY (id)) [42001-224]
|
||||||
|
2025-03-08 12:45:24.184967+08:00 jdbc[3]: exception
|
||||||
|
org.h2.jdbc.JdbcSQLSyntaxErrorException: Syntax error in SQL statement "MERGE INTO public.""user"" ([*]?) VALUES (?, ?)"; expected "identifier"; SQL statement:
|
||||||
|
MERGE INTO public."user" (?) VALUES (?, ?) [42001-224]
|
||||||
|
2025-03-08 15:26:55.471296+08:00 database: flush
|
||||||
|
org.h2.message.DbException: General error: "org.h2.mvstore.MVStoreException: The file is locked: C:/Users/Yan/eclipse-workspace/camel-springboot-activemq6-example/db/appdb.mv.db [2.2.224/7]" [50000-224]
|
||||||
|
at org.h2.message.DbException.get(DbException.java:212)
|
||||||
|
at org.h2.message.DbException.convert(DbException.java:407)
|
||||||
|
at org.h2.mvstore.db.Store.lambda$new$0(Store.java:122)
|
||||||
|
at org.h2.mvstore.MVStore.handleException(MVStore.java:1546)
|
||||||
|
at org.h2.mvstore.MVStore.panic(MVStore.java:371)
|
||||||
|
at org.h2.mvstore.MVStore.<init>(MVStore.java:291)
|
||||||
|
at org.h2.mvstore.MVStore$Builder.open(MVStore.java:2035)
|
||||||
|
at org.h2.mvstore.db.Store.<init>(Store.java:133)
|
||||||
|
at org.h2.engine.Database.<init>(Database.java:326)
|
||||||
|
at org.h2.engine.Engine.openSession(Engine.java:92)
|
||||||
|
at org.h2.engine.Engine.openSession(Engine.java:222)
|
||||||
|
at org.h2.engine.Engine.createSession(Engine.java:201)
|
||||||
|
at org.h2.engine.SessionRemote.connectEmbeddedOrServer(SessionRemote.java:343)
|
||||||
|
at org.h2.jdbc.JdbcConnection.<init>(JdbcConnection.java:125)
|
||||||
|
at org.h2.Driver.connect(Driver.java:59)
|
||||||
|
at com.zaxxer.hikari.util.DriverDataSource.getConnection(DriverDataSource.java:137)
|
||||||
|
at com.zaxxer.hikari.pool.PoolBase.newConnection(PoolBase.java:360)
|
||||||
|
at com.zaxxer.hikari.pool.PoolBase.newPoolEntry(PoolBase.java:202)
|
||||||
|
at com.zaxxer.hikari.pool.HikariPool.createPoolEntry(HikariPool.java:461)
|
||||||
|
at com.zaxxer.hikari.pool.HikariPool.checkFailFast(HikariPool.java:550)
|
||||||
|
at com.zaxxer.hikari.pool.HikariPool.<init>(HikariPool.java:98)
|
||||||
|
at com.zaxxer.hikari.HikariDataSource.<init>(HikariDataSource.java:80)
|
||||||
|
at com.example.sbcamel.DatabaseConfig.dataSource(DatabaseConfig.java:69)
|
||||||
|
at com.example.sbcamel.DatabaseConfig$$SpringCGLIB$$0.CGLIB$dataSource$0(<generated>)
|
||||||
|
at com.example.sbcamel.DatabaseConfig$$SpringCGLIB$$FastClass$$1.invoke(<generated>)
|
||||||
|
at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:258)
|
||||||
|
at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:372)
|
||||||
|
at com.example.sbcamel.DatabaseConfig$$SpringCGLIB$$0.dataSource(<generated>)
|
||||||
|
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
|
||||||
|
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
|
||||||
|
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
|
||||||
|
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
|
||||||
|
at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:146)
|
||||||
|
at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:644)
|
||||||
|
at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:636)
|
||||||
|
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1355)
|
||||||
|
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1185)
|
||||||
|
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:562)
|
||||||
|
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:522)
|
||||||
|
at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:337)
|
||||||
|
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
|
||||||
|
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:335)
|
||||||
|
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:200)
|
||||||
|
at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:254)
|
||||||
|
at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1448)
|
||||||
|
at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1358)
|
||||||
|
at org.springframework.beans.factory.support.ConstructorResolver.resolveAutowiredArgument(ConstructorResolver.java:904)
|
||||||
|
at org.springframework.beans.factory.support.ConstructorResolver.createArgumentArray(ConstructorResolver.java:782)
|
||||||
|
at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:542)
|
||||||
|
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1355)
|
||||||
|
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1185)
|
||||||
|
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:562)
|
||||||
|
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:522)
|
||||||
|
at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:337)
|
||||||
|
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
|
||||||
|
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:335)
|
||||||
|
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:200)
|
||||||
|
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:313)
|
||||||
|
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:200)
|
||||||
|
at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:254)
|
||||||
|
at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1448)
|
||||||
|
at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1358)
|
||||||
|
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.resolveFieldValue(AutowiredAnnotationBeanPostProcessor.java:785)
|
||||||
|
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:768)
|
||||||
|
at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:145)
|
||||||
|
at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessProperties(AutowiredAnnotationBeanPostProcessor.java:509)
|
||||||
|
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1439)
|
||||||
|
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:599)
|
||||||
|
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:522)
|
||||||
|
at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:337)
|
||||||
|
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
|
||||||
|
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:335)
|
||||||
|
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:200)
|
||||||
|
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:975)
|
||||||
|
at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:971)
|
||||||
|
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:625)
|
||||||
|
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:146)
|
||||||
|
at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:754)
|
||||||
|
at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:456)
|
||||||
|
at org.springframework.boot.SpringApplication.run(SpringApplication.java:335)
|
||||||
|
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1363)
|
||||||
|
at org.springframework.boot.SpringApplication.run(SpringApplication.java:1352)
|
||||||
|
at com.example.sbcamel.Boot.main(Boot.java:27)
|
||||||
|
Caused by: org.h2.jdbc.JdbcSQLNonTransientException: General error: "org.h2.mvstore.MVStoreException: The file is locked: C:/Users/Yan/eclipse-workspace/camel-springboot-activemq6-example/db/appdb.mv.db [2.2.224/7]" [50000-224]
|
||||||
|
at org.h2.message.DbException.getJdbcSQLException(DbException.java:566)
|
||||||
|
at org.h2.message.DbException.getJdbcSQLException(DbException.java:489)
|
||||||
|
... 83 more
|
||||||
|
Caused by: org.h2.mvstore.MVStoreException: The file is locked: C:/Users/Yan/eclipse-workspace/camel-springboot-activemq6-example/db/appdb.mv.db [2.2.224/7]
|
||||||
|
at org.h2.mvstore.DataUtils.newMVStoreException(DataUtils.java:996)
|
||||||
|
at org.h2.mvstore.SingleFileStore.lockFileChannel(SingleFileStore.java:143)
|
||||||
|
at org.h2.mvstore.SingleFileStore.open(SingleFileStore.java:117)
|
||||||
|
at org.h2.mvstore.SingleFileStore.open(SingleFileStore.java:81)
|
||||||
|
at org.h2.mvstore.MVStore.<init>(MVStore.java:286)
|
||||||
|
... 77 more
|
||||||
@ -1,34 +0,0 @@
|
|||||||
package com.example.camel;
|
|
||||||
|
|
||||||
import org.apache.camel.Exchange;
|
|
||||||
import org.apache.camel.builder.RouteBuilder;
|
|
||||||
import org.apache.camel.component.bean.validator.BeanValidationException;
|
|
||||||
import org.apache.camel.model.dataformat.JsonLibrary;
|
|
||||||
import org.springframework.beans.factory.annotation.Value;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
import jakarta.ws.rs.core.Response;
|
|
||||||
|
|
||||||
@Component
|
|
||||||
public class CamelRouter extends RouteBuilder {
|
|
||||||
|
|
||||||
@Value("${app.queue-name}")
|
|
||||||
private String queueName;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void configure() throws Exception {
|
|
||||||
// very raw way, just to handle the validation responses
|
|
||||||
onException(BeanValidationException.class).handled(true)
|
|
||||||
.setHeader(Exchange.HTTP_RESPONSE_CODE, constant(Response.Status.BAD_REQUEST.getStatusCode()))
|
|
||||||
.setBody(simple("${exchangeProperty.CamelExceptionCaught.getMessage()}"));
|
|
||||||
|
|
||||||
from("cxfrs:/api?resourceClasses=" + UserService.class.getName() + "&bindingStyle=SimpleConsumer"
|
|
||||||
+ "&providers=jaxrsProvider&loggingFeatureEnabled=true").to("log:cxfrs-log?showAll=true")
|
|
||||||
.setHeader(Exchange.BEAN_METHOD_NAME, simple("${header.operationName}"))
|
|
||||||
.to("activemq6:queue:" + queueName);
|
|
||||||
|
|
||||||
from("activemq6:queue:" + queueName).to("bean-validator:user").bean(UserServiceImpl.class).marshal()
|
|
||||||
.json(JsonLibrary.Jackson);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,54 +0,0 @@
|
|||||||
package com.example.camel;
|
|
||||||
|
|
||||||
import java.io.Serializable;
|
|
||||||
import java.util.StringJoiner;
|
|
||||||
|
|
||||||
import jakarta.validation.constraints.NotNull;
|
|
||||||
import jakarta.validation.constraints.Size;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* User entity
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
@SuppressWarnings("serial")
|
|
||||||
public class User implements Serializable {
|
|
||||||
|
|
||||||
@NotNull(message = "custom message")
|
|
||||||
private Integer id;
|
|
||||||
|
|
||||||
@NotNull
|
|
||||||
@Size(min = 3, max = 20)
|
|
||||||
private String name;
|
|
||||||
|
|
||||||
public User() {
|
|
||||||
}
|
|
||||||
|
|
||||||
public User(Integer id, String name) {
|
|
||||||
this.id = id;
|
|
||||||
this.name = name;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Integer getId() {
|
|
||||||
return id;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setId(Integer id) {
|
|
||||||
this.id = id;
|
|
||||||
}
|
|
||||||
|
|
||||||
public String getName() {
|
|
||||||
return name;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void setName(String name) {
|
|
||||||
this.name = name;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public String toString() {
|
|
||||||
return new StringJoiner(", ", User.class.getSimpleName() + "[", "]")
|
|
||||||
.add("id=" + id)
|
|
||||||
.add("name='" + name + "'")
|
|
||||||
.toString();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,52 +0,0 @@
|
|||||||
package com.example.camel;
|
|
||||||
|
|
||||||
import java.util.Collection;
|
|
||||||
|
|
||||||
import jakarta.validation.Valid;
|
|
||||||
import jakarta.ws.rs.Consumes;
|
|
||||||
import jakarta.ws.rs.GET;
|
|
||||||
import jakarta.ws.rs.POST;
|
|
||||||
import jakarta.ws.rs.Path;
|
|
||||||
import jakarta.ws.rs.PathParam;
|
|
||||||
import jakarta.ws.rs.Produces;
|
|
||||||
import jakarta.ws.rs.core.MediaType;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Service interface for managing users.
|
|
||||||
*/
|
|
||||||
public interface UserService {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Find a user by the given ID
|
|
||||||
*
|
|
||||||
* @param id
|
|
||||||
* the ID of the user
|
|
||||||
* @return the user, or <code>null</code> if user not found.
|
|
||||||
*/
|
|
||||||
@GET
|
|
||||||
@Path("/user/{id}")
|
|
||||||
@Produces(MediaType.APPLICATION_JSON)
|
|
||||||
User findUser(@PathParam("id") Integer id);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Find all users
|
|
||||||
*
|
|
||||||
* @return a collection of all users
|
|
||||||
*/
|
|
||||||
@GET
|
|
||||||
@Path("/user")
|
|
||||||
@Produces(MediaType.APPLICATION_JSON)
|
|
||||||
Collection<User> findUsers();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Update the given user
|
|
||||||
*
|
|
||||||
* @param user
|
|
||||||
* the user
|
|
||||||
*/
|
|
||||||
@POST
|
|
||||||
@Path("/user")
|
|
||||||
@Consumes(MediaType.APPLICATION_JSON)
|
|
||||||
User updateUser(@Valid User user);
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -1,33 +0,0 @@
|
|||||||
package com.example.camel;
|
|
||||||
|
|
||||||
import java.util.Collection;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.TreeMap;
|
|
||||||
|
|
||||||
public class UserServiceImpl implements UserService {
|
|
||||||
|
|
||||||
private final Map<Integer, User> users = new TreeMap<>();
|
|
||||||
|
|
||||||
public UserServiceImpl() {
|
|
||||||
users.put(1, new User(1, "John Coltrane"));
|
|
||||||
users.put(2, new User(2, "Miles Davis"));
|
|
||||||
users.put(3, new User(3, "Sonny Rollins"));
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public User findUser(Integer id) {
|
|
||||||
return users.get(id);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public Collection<User> findUsers() {
|
|
||||||
return users.values();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public User updateUser(User user) {
|
|
||||||
users.put(user.getId(), user);
|
|
||||||
return user;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
@ -0,0 +1,26 @@
|
|||||||
|
package com.example.sbcamel.init;
|
||||||
|
|
||||||
|
import org.springframework.context.annotation.Bean;
|
||||||
|
import org.springframework.context.annotation.Configuration;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||||
|
import com.fasterxml.jackson.datatype.jdk8.Jdk8Module;
|
||||||
|
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
|
||||||
|
import com.fasterxml.jackson.jakarta.rs.json.JacksonJsonProvider;
|
||||||
|
|
||||||
|
@Configuration
|
||||||
|
public class AppConfig {
|
||||||
|
|
||||||
|
@Bean("objectMapper")
|
||||||
|
public ObjectMapper objectMapper() {
|
||||||
|
ObjectMapper mapper = new ObjectMapper();
|
||||||
|
mapper.registerModule(new JavaTimeModule());
|
||||||
|
mapper.registerModule(new Jdk8Module());
|
||||||
|
return mapper;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Bean
|
||||||
|
public JacksonJsonProvider jaxrsProvider() {
|
||||||
|
return new JacksonJsonProvider();
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,73 @@
|
|||||||
|
package com.example.sbcamel.init;
|
||||||
|
|
||||||
|
import org.apache.camel.Exchange;
|
||||||
|
import org.apache.camel.builder.RouteBuilder;
|
||||||
|
import org.apache.camel.component.bean.BeanConstants;
|
||||||
|
import org.apache.camel.component.cxf.common.message.CxfConstants;
|
||||||
|
import org.apache.camel.model.dataformat.JsonLibrary;
|
||||||
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
import org.springframework.beans.factory.annotation.Value;
|
||||||
|
import org.springframework.jdbc.core.JdbcTemplate;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
import com.example.sbcamel.mapper.SessionMapper;
|
||||||
|
import com.example.sbcamel.service.SessionService;
|
||||||
|
|
||||||
|
import jakarta.annotation.PostConstruct;
|
||||||
|
import jakarta.ws.rs.core.Response;
|
||||||
|
|
||||||
|
@Component
|
||||||
|
public class CamelRouter extends RouteBuilder {
|
||||||
|
|
||||||
|
private static final String dropSessionSql = "DROP TABLE IF EXISTS public.session";
|
||||||
|
|
||||||
|
private static final String createSessionSql = "CREATE TABLE public.session (sessionId UUID not null, "
|
||||||
|
+ "username CHARACTER VARYING not null, password CHARACTER VARYING not null, PRIMARY KEY (sessionId))";
|
||||||
|
|
||||||
|
@Value("${app.queue-name}")
|
||||||
|
private String queueName;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private JdbcTemplate jdbcTemplate;
|
||||||
|
|
||||||
|
@PostConstruct
|
||||||
|
private void init() {
|
||||||
|
org.apache.ibatis.logging.LogFactory.useSlf4jLogging();
|
||||||
|
jdbcTemplate.execute(dropSessionSql);
|
||||||
|
jdbcTemplate.execute(createSessionSql);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void configure() throws Exception {
|
||||||
|
onException(jakarta.ws.rs.NotFoundException.class).handled(true)
|
||||||
|
.setHeader(Exchange.HTTP_RESPONSE_CODE, constant(Response.Status.NOT_FOUND.getStatusCode()))
|
||||||
|
.setBody(simple("${exchangeProperty.CamelExceptionCaught.getMessage()}"));
|
||||||
|
|
||||||
|
from("cxfrs:/api?resourceClasses=" + SessionService.class.getName() + "&bindingStyle=Default"
|
||||||
|
+ "&providers=jaxrsProvider&loggingFeatureEnabled=true").to("log:cxfrs?showAll=true")
|
||||||
|
.to("seda:" + queueName).process(exchange -> {
|
||||||
|
if (exchange.getMessage().getBody() != null && exchange.getMessage().getBody() instanceof byte[]
|
||||||
|
&& new String((byte[]) exchange.getMessage().getBody()).equals("null")) {
|
||||||
|
if (exchange.getIn().getHeader(Exchange.HTTP_METHOD).equals("GET")) {
|
||||||
|
throw new jakarta.ws.rs.NotFoundException();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
from("seda:" + queueName)
|
||||||
|
.process(exchange -> exchange.getIn().setHeader(BeanConstants.BEAN_METHOD_NAME,
|
||||||
|
exchange.getIn().getHeader(CxfConstants.OPERATION_NAME.toLowerCase())))
|
||||||
|
.to("log:activemq?showAll=true").transacted("propagationRequired").choice()
|
||||||
|
.when(header(BeanConstants.BEAN_METHOD_NAME).isEqualTo("updateSession"))
|
||||||
|
.to("mybatis:" + SessionMapper.class.getName()
|
||||||
|
+ ".updateSession?statementType=Update&outputHeader=X-UpdateResult")
|
||||||
|
.process(exchange -> {
|
||||||
|
exchange.getMessage().setBody(exchange.getIn().getBody());
|
||||||
|
}).when(header(BeanConstants.BEAN_METHOD_NAME).isEqualTo("findSessions"))
|
||||||
|
.to("mybatis:" + SessionMapper.class.getName() + ".findSessions?statementType=SelectList")
|
||||||
|
.when(header(BeanConstants.BEAN_METHOD_NAME).isEqualTo("findSession"))
|
||||||
|
.to("mybatis:" + SessionMapper.class.getName() + ".findSession?statementType=SelectOne")
|
||||||
|
.end().marshal().json(JsonLibrary.Jackson);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,120 @@
|
|||||||
|
package com.example.sbcamel.init;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.util.Objects;
|
||||||
|
import java.util.Set;
|
||||||
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
|
import javax.sql.DataSource;
|
||||||
|
|
||||||
|
import org.apache.camel.component.mybatis.MyBatisComponent;
|
||||||
|
import org.apache.camel.spring.spi.SpringTransactionPolicy;
|
||||||
|
import org.apache.ibatis.mapping.Environment;
|
||||||
|
import org.apache.ibatis.session.SqlSessionFactory;
|
||||||
|
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
|
||||||
|
import org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
|
import org.springframework.beans.factory.annotation.Value;
|
||||||
|
import org.springframework.context.annotation.Bean;
|
||||||
|
import org.springframework.context.annotation.Configuration;
|
||||||
|
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
|
||||||
|
import org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy;
|
||||||
|
import org.springframework.transaction.PlatformTransactionManager;
|
||||||
|
|
||||||
|
import com.google.common.reflect.ClassPath;
|
||||||
|
import com.zaxxer.hikari.HikariConfig;
|
||||||
|
import com.zaxxer.hikari.HikariDataSource;
|
||||||
|
|
||||||
|
@Configuration
|
||||||
|
public class DatabaseConfig {
|
||||||
|
|
||||||
|
private static final Logger logger = LoggerFactory.getLogger(DatabaseConfig.class);
|
||||||
|
|
||||||
|
public static final String CFG_APP_DATABASE_URL = "${app.database.url}";
|
||||||
|
public static final String CFG_APP_DATABASE_USERNAME = "${app.database.username:}";
|
||||||
|
public static final String CFG_APP_DATABASE_PASSWORD = "${app.database.password:}";
|
||||||
|
public static final String CFG_APP_DATABASE_MAPPER_PACKAGE = "${app.database.mapper-package}";
|
||||||
|
public static final String CFG_APP_DATABASE_SPRINGBOOT_CLASS_PREFIX = "${app.database.springboot-class-prefix:BOOT-INF.classes.}";
|
||||||
|
|
||||||
|
@Value(CFG_APP_DATABASE_URL)
|
||||||
|
private String dbUrl;
|
||||||
|
|
||||||
|
@Value(CFG_APP_DATABASE_USERNAME)
|
||||||
|
private String dbUsername;
|
||||||
|
|
||||||
|
@Value(CFG_APP_DATABASE_PASSWORD)
|
||||||
|
private String dbPassword;
|
||||||
|
|
||||||
|
@Value(CFG_APP_DATABASE_MAPPER_PACKAGE)
|
||||||
|
private String mapperPackage;
|
||||||
|
|
||||||
|
@Value(CFG_APP_DATABASE_SPRINGBOOT_CLASS_PREFIX)
|
||||||
|
private String springBootClassPrefix;
|
||||||
|
|
||||||
|
@Bean
|
||||||
|
HikariConfig hikariConfig() {
|
||||||
|
HikariConfig config = new HikariConfig();
|
||||||
|
config.setJdbcUrl(dbUrl);
|
||||||
|
config.setUsername(dbUsername);
|
||||||
|
config.setPassword(dbPassword);
|
||||||
|
config.addDataSourceProperty("cachePrepStmts", "true");
|
||||||
|
config.addDataSourceProperty("prepStmtCacheSize", "250");
|
||||||
|
config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048");
|
||||||
|
return config;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Bean
|
||||||
|
DataSource dataSource(HikariConfig hikariConfig) {
|
||||||
|
return new TransactionAwareDataSourceProxy(new HikariDataSource(hikariConfig));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Bean
|
||||||
|
PlatformTransactionManager txManager(DataSource dataSource) {
|
||||||
|
return new DataSourceTransactionManager(dataSource);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Bean
|
||||||
|
SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {
|
||||||
|
Environment environment = new Environment("development", new JdbcTransactionFactory(), dataSource);
|
||||||
|
org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration(
|
||||||
|
environment);
|
||||||
|
Set<Class<?>> mapperClasses = findAllClassesUsingGuava(mapperPackage);
|
||||||
|
mapperClasses.forEach(configuration::addMapper);
|
||||||
|
return new SqlSessionFactoryBuilder().build(configuration);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Bean
|
||||||
|
MyBatisComponent mybatis(SqlSessionFactory sqlSessionFactory) {
|
||||||
|
MyBatisComponent mybatis = new MyBatisComponent();
|
||||||
|
mybatis.setSqlSessionFactory(sqlSessionFactory);
|
||||||
|
return mybatis;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Bean
|
||||||
|
SpringTransactionPolicy propagationRequired(PlatformTransactionManager txManager) {
|
||||||
|
SpringTransactionPolicy propagationRequired = new SpringTransactionPolicy();
|
||||||
|
propagationRequired.setTransactionManager(txManager);
|
||||||
|
propagationRequired.setPropagationBehaviorName("PROPAGATION_REQUIRED");
|
||||||
|
return propagationRequired;
|
||||||
|
}
|
||||||
|
|
||||||
|
private Set<Class<?>> findAllClassesUsingGuava(String packageName) throws IOException {
|
||||||
|
logger.trace("Orm mappers packageName: {}", packageName);
|
||||||
|
return ClassPath.from(ClassLoader.getSystemClassLoader()).getAllClasses().stream()
|
||||||
|
.peek(clazz -> logger.trace("candidate class: {}, package name: {}", clazz, clazz.getPackageName()))
|
||||||
|
.filter(clazz -> clazz.getPackageName().endsWith(packageName))
|
||||||
|
.peek(clazz -> logger.info("accepted class: {}, package name: {}", clazz, clazz.getPackageName()))
|
||||||
|
.map(clazz -> {
|
||||||
|
try {
|
||||||
|
if (clazz.getName().startsWith(springBootClassPrefix)) {
|
||||||
|
return Class.forName(clazz.getName().replace(springBootClassPrefix, ""));
|
||||||
|
}
|
||||||
|
return Class.forName(clazz.getName());
|
||||||
|
} catch (ClassNotFoundException e) {
|
||||||
|
logger.error("cannot convert this class name to class: {}", clazz.getName());
|
||||||
|
}
|
||||||
|
return null;
|
||||||
|
}).filter(Objects::nonNull).collect(Collectors.toSet());
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,39 @@
|
|||||||
|
package com.example.sbcamel.mapper;
|
||||||
|
|
||||||
|
import java.util.Collection;
|
||||||
|
import java.util.UUID;
|
||||||
|
|
||||||
|
import org.apache.ibatis.annotations.Insert;
|
||||||
|
import org.apache.ibatis.annotations.Result;
|
||||||
|
import org.apache.ibatis.annotations.Results;
|
||||||
|
import org.apache.ibatis.annotations.Select;
|
||||||
|
import org.apache.ibatis.type.JdbcType;
|
||||||
|
|
||||||
|
import com.example.sbcamel.service.Session;
|
||||||
|
import com.example.sbcamel.service.UuidTypeHandler;
|
||||||
|
|
||||||
|
public interface SessionMapper {
|
||||||
|
|
||||||
|
@Insert({ "<script>",
|
||||||
|
"MERGE INTO public.session (sessionId, username, password) KEY (sessionId) VALUES (#{sessionId, javaType=java.util.UUID, "
|
||||||
|
+ "jdbcType=OTHER, typeHandler=com.example.sbcamel.service.UuidTypeHandler}, #{username}, #{password}) ",
|
||||||
|
"</script>" })
|
||||||
|
int updateSession(Session session);
|
||||||
|
|
||||||
|
@Results({
|
||||||
|
@Result(property = "sessionId", column = "sessionId", javaType = UUID.class, jdbcType = JdbcType.OTHER, typeHandler = UuidTypeHandler.class),
|
||||||
|
@Result(property = "username", column = "username"), @Result(property = "password", column = "password")})
|
||||||
|
@Select({ "<script>",
|
||||||
|
"select sessionId, username, password from public.session where sessionId=#{list[0], javaType=java.util.UUID, "
|
||||||
|
+ "jdbcType=OTHER, typeHandler=com.example.sbcamel.service.UuidTypeHandler}",
|
||||||
|
"</script>" })
|
||||||
|
Session findSession(UUID sessionId);
|
||||||
|
|
||||||
|
@Results({
|
||||||
|
@Result(property = "sessionId", column = "sessionId", javaType = UUID.class, jdbcType = JdbcType.OTHER, typeHandler = UuidTypeHandler.class),
|
||||||
|
@Result(property = "username", column = "username"), @Result(property = "password", column = "password") })
|
||||||
|
@Select({ "<script>",
|
||||||
|
"select sessionId, username, password from public.session order by sessionId",
|
||||||
|
"</script>" })
|
||||||
|
Collection<Session> findSessions();
|
||||||
|
}
|
||||||
@ -0,0 +1,66 @@
|
|||||||
|
package com.example.sbcamel.service;
|
||||||
|
|
||||||
|
import java.io.Serializable;
|
||||||
|
import java.util.UUID;
|
||||||
|
|
||||||
|
import org.apache.commons.lang3.builder.ReflectionToStringBuilder;
|
||||||
|
|
||||||
|
import jakarta.validation.constraints.NotNull;
|
||||||
|
import jakarta.validation.constraints.Size;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* User entity
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
@SuppressWarnings("serial")
|
||||||
|
public class Session implements Serializable {
|
||||||
|
|
||||||
|
private UUID sessionId;
|
||||||
|
|
||||||
|
@NotNull
|
||||||
|
@Size(min = 3, max = 40)
|
||||||
|
private String username;
|
||||||
|
|
||||||
|
@NotNull
|
||||||
|
@Size(min = 3, max = 40)
|
||||||
|
private String password;
|
||||||
|
|
||||||
|
public Session() {
|
||||||
|
}
|
||||||
|
|
||||||
|
public Session(UUID sessionId, @NotNull @Size(min = 3, max = 40) String username,
|
||||||
|
@NotNull @Size(min = 3, max = 40) String password) {
|
||||||
|
this.sessionId = sessionId;
|
||||||
|
this.username = username;
|
||||||
|
this.password = password;
|
||||||
|
}
|
||||||
|
|
||||||
|
public UUID getSessionId() {
|
||||||
|
return sessionId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setSessionId(UUID sessionId) {
|
||||||
|
this.sessionId = sessionId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getUsername() {
|
||||||
|
return username;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setUsername(String username) {
|
||||||
|
this.username = username;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getPassword() {
|
||||||
|
return password;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setPassword(String password) {
|
||||||
|
this.password = password;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String toString() {
|
||||||
|
return ReflectionToStringBuilder.toString(this);
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,46 @@
|
|||||||
|
package com.example.sbcamel.service;
|
||||||
|
|
||||||
|
import java.util.Collection;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.UUID;
|
||||||
|
|
||||||
|
import jakarta.validation.Valid;
|
||||||
|
import jakarta.ws.rs.Consumes;
|
||||||
|
import jakarta.ws.rs.GET;
|
||||||
|
import jakarta.ws.rs.POST;
|
||||||
|
import jakarta.ws.rs.Path;
|
||||||
|
import jakarta.ws.rs.PathParam;
|
||||||
|
import jakarta.ws.rs.Produces;
|
||||||
|
import jakarta.ws.rs.core.MediaType;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Service interface for managing sessions.
|
||||||
|
*/
|
||||||
|
public interface SessionService {
|
||||||
|
|
||||||
|
@POST
|
||||||
|
@Path("/session")
|
||||||
|
@Consumes(MediaType.APPLICATION_JSON)
|
||||||
|
Session updateSession(@Valid Session session);
|
||||||
|
|
||||||
|
@GET
|
||||||
|
@Path("/session/{sessionId}")
|
||||||
|
@Produces(MediaType.APPLICATION_JSON)
|
||||||
|
Session findSession(@PathParam("sessionId") UUID sessionId);
|
||||||
|
|
||||||
|
@GET
|
||||||
|
@Path("/session")
|
||||||
|
@Produces(MediaType.APPLICATION_JSON)
|
||||||
|
Collection<Session> findSessions();
|
||||||
|
|
||||||
|
@POST
|
||||||
|
@Path("/inspect/{sessionId}")
|
||||||
|
@Produces(MediaType.APPLICATION_JSON)
|
||||||
|
Map<String, List<String>> inspect(@PathParam("sessionId") UUID sessionId);
|
||||||
|
|
||||||
|
@POST
|
||||||
|
@Path("/test")
|
||||||
|
@Produces(MediaType.APPLICATION_JSON)
|
||||||
|
Map<String, Map<String, List<String>>> test(List<String> selectors);
|
||||||
|
}
|
||||||
@ -0,0 +1,33 @@
|
|||||||
|
package com.example.sbcamel.service;
|
||||||
|
|
||||||
|
import java.sql.CallableStatement;
|
||||||
|
import java.sql.PreparedStatement;
|
||||||
|
import java.sql.ResultSet;
|
||||||
|
import java.sql.SQLException;
|
||||||
|
import java.util.UUID;
|
||||||
|
|
||||||
|
import org.apache.ibatis.type.BaseTypeHandler;
|
||||||
|
import org.apache.ibatis.type.JdbcType;
|
||||||
|
|
||||||
|
public class UuidTypeHandler extends BaseTypeHandler<UUID> {
|
||||||
|
@Override
|
||||||
|
public void setNonNullParameter(PreparedStatement ps, int i, UUID parameter, JdbcType jdbcType)
|
||||||
|
throws SQLException {
|
||||||
|
ps.setObject(i, parameter);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public UUID getNullableResult(ResultSet rs, String columnName) throws SQLException {
|
||||||
|
return rs.getObject(columnName, UUID.class);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public UUID getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
|
||||||
|
return rs.getObject(columnIndex, UUID.class);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public UUID getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
|
||||||
|
return cs.getObject(columnIndex, UUID.class);
|
||||||
|
}
|
||||||
|
}
|
||||||
Loading…
Reference in new issue