Compare commits
4 Commits
master
...
experiment
| Author | SHA1 | Date |
|---|---|---|
Yan
|
7c89a6361e | 4 weeks ago |
|
Yan
|
fadca4d287 | 4 weeks ago |
|
Yan
|
ee7b4028de | 4 weeks ago |
|
Yan
|
21b1e672ff | 1 month ago |
@ -0,0 +1,20 @@
|
|||||||
|
meta {
|
||||||
|
name: findUser
|
||||||
|
type: http
|
||||||
|
seq: 4
|
||||||
|
}
|
||||||
|
|
||||||
|
get {
|
||||||
|
url: http://localhost:9091/services/api/user/2
|
||||||
|
body: none
|
||||||
|
auth: basic
|
||||||
|
}
|
||||||
|
|
||||||
|
headers {
|
||||||
|
operationName: findUsers
|
||||||
|
}
|
||||||
|
|
||||||
|
auth:basic {
|
||||||
|
username: cxfrs
|
||||||
|
password: password
|
||||||
|
}
|
||||||
@ -0,0 +1,26 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<configuration scan="true">
|
||||||
|
<appender name="STDOUT"
|
||||||
|
class="ch.qos.logback.core.ConsoleAppender">
|
||||||
|
<encoder>
|
||||||
|
<pattern>%-5level %d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %logger{36} - %msg%n</pattern>
|
||||||
|
</encoder>
|
||||||
|
</appender>
|
||||||
|
<appender name="FILE"
|
||||||
|
class="ch.qos.logback.core.rolling.RollingFileAppender">
|
||||||
|
<file>logs/server.log</file>
|
||||||
|
<rollingPolicy
|
||||||
|
class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
|
||||||
|
<fileNamePattern>logs/server.%d{yyyy-MM-dd}.log.gz</fileNamePattern>
|
||||||
|
<maxHistory>3</maxHistory>
|
||||||
|
<totalSizeCap>300MB</totalSizeCap>
|
||||||
|
</rollingPolicy>
|
||||||
|
<encoder>
|
||||||
|
<pattern>%-5level %d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %logger{36} - %msg%n</pattern>
|
||||||
|
</encoder>
|
||||||
|
</appender>
|
||||||
|
<logger name="com.example.sbcamel" level="DEBUG" />
|
||||||
|
<root level="INFO">
|
||||||
|
<appender-ref ref="STDOUT" />
|
||||||
|
</root>
|
||||||
|
</configuration>
|
||||||
@ -0,0 +1,26 @@
|
|||||||
|
server:
|
||||||
|
port: 9091
|
||||||
|
|
||||||
|
camel:
|
||||||
|
springboot:
|
||||||
|
main-run-controller: true
|
||||||
|
|
||||||
|
spring:
|
||||||
|
activemq:
|
||||||
|
broker-url: "tcp://localhost:61616"
|
||||||
|
ldap:
|
||||||
|
urls: ldap://localhost:10389
|
||||||
|
base: dc=example,dc=com
|
||||||
|
username: uid=admin,ou=system
|
||||||
|
password: secret
|
||||||
|
|
||||||
|
app:
|
||||||
|
queue-name: "UserServiceQueue"
|
||||||
|
zookeeper:
|
||||||
|
url: "127.0.0.1:2181"
|
||||||
|
group-name: "UserServiceGroup"
|
||||||
|
database:
|
||||||
|
url: "jdbc:h2:tcp://localhost/~/h2/db/appdb"
|
||||||
|
username: "app"
|
||||||
|
password: "app"
|
||||||
|
mapper-package: "com.example.sbcamel.mapper"
|
||||||
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,81 @@
|
|||||||
|
package com.example.sbcamel;
|
||||||
|
|
||||||
|
import org.apache.camel.Exchange;
|
||||||
|
import org.apache.camel.builder.RouteBuilder;
|
||||||
|
import org.apache.camel.component.bean.BeanConstants;
|
||||||
|
import org.apache.camel.component.bean.validator.BeanValidationException;
|
||||||
|
import org.apache.camel.component.cxf.common.message.CxfConstants;
|
||||||
|
import org.apache.camel.component.zookeepermaster.policy.MasterRoutePolicy;
|
||||||
|
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 jakarta.annotation.PostConstruct;
|
||||||
|
import jakarta.ws.rs.core.Response;
|
||||||
|
|
||||||
|
@Component
|
||||||
|
public class CamelRouter extends RouteBuilder {
|
||||||
|
private static final String createUserSql = "CREATE TABLE IF NOT EXISTS public.\"user\" (id BIGINT not null, "
|
||||||
|
+ "name CHARACTER VARYING not null, PRIMARY KEY (id))";
|
||||||
|
|
||||||
|
@Value("${app.queue-name}")
|
||||||
|
private String queueName;
|
||||||
|
|
||||||
|
@Value("${app.zookeeper.url}")
|
||||||
|
private String zookeeperUrl;
|
||||||
|
|
||||||
|
@Value("${app.zookeeper.group-name}")
|
||||||
|
private String groupName;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private JdbcTemplate jdbcTemplate;
|
||||||
|
|
||||||
|
@PostConstruct
|
||||||
|
private void init() {
|
||||||
|
org.apache.ibatis.logging.LogFactory.useSlf4jLogging();
|
||||||
|
jdbcTemplate.execute(createUserSql);
|
||||||
|
}
|
||||||
|
|
||||||
|
@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()}"));
|
||||||
|
|
||||||
|
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=" + UserService.class.getName() + "&bindingStyle=Default"
|
||||||
|
+ "&providers=jaxrsProvider&loggingFeatureEnabled=true").to("log:cxfrs?showAll=true")
|
||||||
|
.to("bean-validator:user").to("activemq6:queue:" + 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();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
MasterRoutePolicy masterRoutePolicy = new MasterRoutePolicy();
|
||||||
|
masterRoutePolicy.setZooKeeperUrl(zookeeperUrl);
|
||||||
|
masterRoutePolicy.setGroupName(groupName);
|
||||||
|
|
||||||
|
from("activemq6:queue:" + queueName).autoStartup("false").routePolicy(masterRoutePolicy)
|
||||||
|
.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("updateUser"))
|
||||||
|
.to("mybatis:com.example.sbcamel.mapper.UserMapper.updateUser?statementType=Update")
|
||||||
|
.when(header(BeanConstants.BEAN_METHOD_NAME).isEqualTo("findUsers"))
|
||||||
|
.to("mybatis:com.example.sbcamel.mapper.UserMapper.findUsers?statementType=SelectList")
|
||||||
|
.when(header(BeanConstants.BEAN_METHOD_NAME).isEqualTo("findUser"))
|
||||||
|
.to("mybatis:com.example.sbcamel.mapper.UserMapper.findUser?statementType=SelectOne")
|
||||||
|
.end().marshal().json(JsonLibrary.Jackson);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,120 @@
|
|||||||
|
package com.example.sbcamel;
|
||||||
|
|
||||||
|
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,52 @@
|
|||||||
|
package com.example.sbcamel;
|
||||||
|
|
||||||
|
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();
|
||||||
|
}
|
||||||
|
}
|
||||||
@ -0,0 +1,50 @@
|
|||||||
|
package com.example.sbcamel;
|
||||||
|
|
||||||
|
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);
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,24 @@
|
|||||||
|
package com.example.sbcamel.mapper;
|
||||||
|
|
||||||
|
import java.util.Collection;
|
||||||
|
|
||||||
|
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 com.example.sbcamel.User;
|
||||||
|
|
||||||
|
public interface UserMapper {
|
||||||
|
|
||||||
|
@Insert({ "<script>", "MERGE INTO public.\"user\" (id, name) KEY (id) VALUES (#{id}, #{name}) ", "</script>" })
|
||||||
|
User updateUser(User user);
|
||||||
|
|
||||||
|
@Results({ @Result(property = "id", column = "id"), @Result(property = "name", column = "name") })
|
||||||
|
@Select({ "<script>", "select id, name from public.\"user\" where id=#{list[0]}", "</script>" })
|
||||||
|
User findUser(Integer id);
|
||||||
|
|
||||||
|
@Results({ @Result(property = "id", column = "id"), @Result(property = "name", column = "name") })
|
||||||
|
@Select({ "<script>", "select id, name from public.\"user\" order by id", "</script>" })
|
||||||
|
Collection<User> findUsers();
|
||||||
|
}
|
||||||
Loading…
Reference in new issue