Browse code First import master
0 parent commit ab3201ad86c9d57f44344a94925671149bb79516 Seiji Sogabe authored on 11 Dec 2014

Showing 13 changed files

• pom.xml
• src/main/java/com/buildria/camel/mybatisinproc/logic/GasAlertLogic.java
• src/main/java/com/buildria/camel/mybatisinproc/mappers/GasAlertMapper.java
• src/main/java/com/buildria/camel/mybatisinproc/models/GasAlert.java
• src/main/java/com/buildria/camel/mybatisinproc/models/package-info.java
• src/main/resources/META-INF/spring/spring-context-camel.xml
• src/main/resources/META-INF/spring/spring-context-data.xml
• src/main/resources/data/01_droptable.sql
• src/main/resources/data/02_createtable.sql
• src/main/resources/data/03_createdata.sql
• src/main/resources/data/GasAlertMapper.xml
• src/main/resources/data/SqlMapConfig.xml
• src/main/resources/log4j.xml

Ignore Space Show notes View pom.xml

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.buildria.camel.netty</groupId> <artifactId>mybatisInProc</artifactId> <version>1.0-SNAPSHOT</version> <packaging>jar</packaging> <name>MyBatis In Proc</name> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <maven.compiler.source>1.7</maven.compiler.source> <maven.compiler.target>1.7</maven.compiler.target> <camel.version>2.13.2</camel.version> <h2.version>1.4.181</h2.version> <spring.version>3.2.10.RELEASE</spring.version> <mybatis.version>3.2.7</mybatis.version> <mybatis-spring.version>1.2.2</mybatis-spring.version> <slf4j.version>1.7.7</slf4j.version> <log4j.version>1.2.17</log4j.version> <junit.version>4.11</junit.version> </properties> <build> <plugins> <plugin> <groupId>org.apache.camel</groupId> <artifactId>camel-maven-plugin</artifactId> <version>${camel.version}</version> </plugin> </plugins> </build> <dependencies> <!-- Camel Dependencies --> <dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-core</artifactId> <version>${camel.version}</version> </dependency> <!-- <dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-mybatis</artifactId> <version>${camel.version}</version> </dependency> --> <dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-spring</artifactId> <version>${camel.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-orm</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>${spring.version}</version> </dependency> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>${mybatis.version}</version> </dependency> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis-spring</artifactId> <version>${mybatis-spring.version}</version> </dependency> <!-- DB --> <dependency> <groupId>com.h2database</groupId> <artifactId>h2</artifactId> <version>${h2.version}</version> </dependency> <!-- logging --> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>${slf4j.version}</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>${slf4j.version}</version> </dependency> <dependency> <groupId>log4j</groupId> <artifactId>log4j</artifactId> <version>${log4j.version}</version> </dependency> <!-- testing --> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>${junit.version}</version> <scope>test</scope> </dependency> </dependencies> </project>

Ignore Space Show notes View src/main/java/com/buildria/camel/mybatisinproc/logic/GasAlertLogic.java

package com.buildria.camel.mybatisinproc.logic; import com.buildria.camel.mybatisinproc.mappers.GasAlertMapper; import com.buildria.camel.mybatisinproc.models.GasAlert; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; public class GasAlertLogic { private static final Logger LOG = LoggerFactory.getLogger(GasAlertLogic.class); @Autowired private GasAlertMapper mapper; public GasAlertMapper getMapper() { return mapper; } public void setMapper(GasAlertMapper mapper) { this.mapper = mapper; } public GasAlert[] registry() { GasAlert a = new GasAlert("2015/01/01 12:00:00", "99", 999); mapper.insert(a); GasAlert[] alerts = mapper.selectAll(); for (GasAlert alert : alerts) { LOG.debug("### {}", alert); } return mapper.selectAll(); } }

Ignore Space Show notes View src/main/java/com/buildria/camel/mybatisinproc/mappers/GasAlertMapper.java
package com.buildria.camel.mybatisinproc.mappers; import com.buildria.camel.mybatisinproc.models.GasAlert; import java.util.List; public interface GasAlertMapper { GasAlert[] selectAll(); void insert(GasAlert alert); void delete(List<GasAlert> alerts); }

Ignore Space Show notes View src/main/java/com/buildria/camel/mybatisinproc/models/GasAlert.java

package com.buildria.camel.mybatisinproc.models; import java.io.Serializable; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * アラートモデル * * @author sogabe */ public class GasAlert implements Serializable { private static final Logger LOG = LoggerFactory.getLogger(GasAlert.class); /** * ID */ private String id; /** * 発生年月日時分秒(yyyy/MM/dd HH:mm:ss) 19桁 */ private String date; /** * 種別 1桁 */ private String type; /** * ガス圧(pa) 3 桁 */ private int tension; public String getId() { return id; } public void setId(String id) { this.id = id; } public String getDate() { return date; } public void setDate(String date) { this.date = date; } public String getType() { return type; } public void setType(String type) { this.type = type; } public int getTension() { return tension; } public void setTension(int tension) { this.tension = tension; } /** * コンストラクタ */ public GasAlert() { // } /** * コンストラクタ * * @param date 発生年月日 * @param type 種別 * @param tension ガス圧 */ public GasAlert(String date, String type, int tension) { this(null, date, type, tension); } /** * コンストラクタ * * @param id ID * @param date 発生年月日 * @param type 種別 * @param tension ガス圧 */ public GasAlert(String id, String date, String type, int tension) { this.id = id; this.date = date; this.type = type; this.tension = tension; } @Override public String toString() { return "GasAlert{" + "id=" + id + ", date=" + date + ", type=" + type + ", tension=" + tension + '}'; } }

Ignore Space Show notes View src/main/java/com/buildria/camel/mybatisinproc/models/package-info.java
/** * 電文のモデルです。 */ package com.buildria.camel.mybatisinproc.models;

Ignore Space Show notes View src/main/resources/META-INF/spring/spring-context-camel.xml

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:camel="http://camel.apache.org/schema/spring" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd" > <!-- プロパティファイルの設定 --> <!-- <bean id="bridgePropertyPlaceholder" class="org.apache.camel.spring.spi.BridgePropertyPlaceholderConfigurer"> <property name="location" value="classpath:system.properties"/> </bean> --> <camelContext xmlns="http://camel.apache.org/schema/spring" useMDCLogging="true"> <route> <from uri="timer:TIMER?period=5000" /> <transacted ref="PROPAGATION_REQUIRED"/> <bean ref="gasAlertLogic" method="registry" /> </route> </camelContext> <!-- トランザクションマネージャ --> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <!-- トランザクションの振る舞いを設定 --> <bean id="PROPAGATION_REQUIRED" class="org.apache.camel.spring.spi.SpringTransactionPolicy"> <property name="transactionManager" ref="transactionManager"/> <property name="propagationBehaviorName" value="PROPAGATION_REQUIRED"/> </bean> <!-- MyBatisのSqlSessionFactory --> <!-- MyBatisで使用する設定ファイルを指定 --> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="dataSource"/> <property name="configLocation" value="classpath:data/SqlMapConfig.xml"/> </bean> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="basePackage" value="com.buildria.camel.mybatisinproc.mappers" /> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" /> </bean> <!-- <bean id="GasAlertMapper" class="org.mybatis.spring.mapper.MapperFactoryBean" > <property name="mapperInterface" value="com.buildria.camel.mybatisinproc.mappers.GasAlertMapper" /> <property name="sqlSessionFactory" ref="sqlSessionFactory" /> </bean> --> <bean id="gasAlertLogic" class="com.buildria.camel.mybatisinproc.logic.GasAlertLogic" > <property name="mapper" ref="gasAlertMapper" /> </bean> </beans>

Ignore Space Show notes View src/main/resources/META-INF/spring/spring-context-data.xml

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd"> <!-- <context:component-scan base-package="com.buildria.camel.mybatisinproc.logic" /> --> <jdbc:embedded-database type="H2" id="dataSource"> <jdbc:script encoding="UTF-8" location="classpath:data/01_droptable.sql"/> <jdbc:script encoding="UTF-8" location="classpath:data/02_createtable.sql"/> <jdbc:script encoding="UTF-8" location="classpath:data/03_createdata.sql"/> </jdbc:embedded-database> </beans>

Ignore Space Show notes View src/main/resources/data/01_droptable.sql
DROP TABLE IF EXISTS gasalert;

Ignore Space Show notes View src/main/resources/data/02_createtable.sql
CREATE TABLE gasalert ( id INT PRIMARY KEY AUTO_INCREMENT, date VARCHAR(19) NOT NULL, type VARCHAR(2) NOT NULL, tension int NOT NULL );

Ignore Space Show notes View src/main/resources/data/03_createdata.sql
INSERT INTO gasalert (date, type, tension) VALUES ('2014/12/01 12:00:00', '01', 123); INSERT INTO gasalert (date, type, tension) VALUES ('2014/12/01 12:00:01', '11', 456); INSERT INTO gasalert (date, type, tension) VALUES ('2014/12/02 12:10:01', '91', 56);

Ignore Space Show notes View src/main/resources/data/GasAlertMapper.xml

<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.buildria.camel.mybatisinproc.mappers.GasAlertMapper"> <select id="selectAll" resultType="com.buildria.camel.mybatisinproc.models.GasAlert"> SELECT id, date, type, tension FROM gasalert ORDER BY id </select> <insert id="insert" parameterType="com.buildria.camel.mybatisinproc.models.GasAlert"> INSERT INTO gasalert (date, type, tension) VALUES (#{date}, #{type}, #{tension}) </insert> <delete id="delete" parameterType="java.util.List"> DELETE FROM gasalert WHERE id IN <foreach item="GasAlert" collection="list" open="(" close=")" separator=","> #{GasAlert.id} </foreach> </delete> </mapper>

Ignore Space Show notes View src/main/resources/data/SqlMapConfig.xml
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration> <mappers> <mapper resource="data/GasAlertMapper.xml" /> </mappers> </configuration>

Ignore Space Show notes View src/main/resources/log4j.xml

<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE log4j:configuration SYSTEM "log4j.dtd"> <log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/"> <appender name="stdout" class="org.apache.log4j.ConsoleAppender"> <param name="Target" value="System.out"/> <layout class="org.apache.log4j.PatternLayout"> <param name="ConversionPattern" value="%d{HH:mm:ss,SSS} [%t] [%p] [%X{camel.routeId}] %m%n"/> </layout> </appender> <logger name="org.apache.camel.component.mybatis" additivity="false"> <level value="info"/> <appender-ref ref="stdout"/> </logger> <logger name="org.springframework" additivity="false"> <level value="debug"/> <appender-ref ref="stdout"/> </logger> <logger name="org.apache.ibatis" additivity="false"> <level value="info"/> <appender-ref ref="stdout"/> </logger> <logger name="com.buildria.camel" additivity="false"> <level value="debug"/> <appender-ref ref="stdout"/> </logger> <root> <level value="info"/> <appender-ref ref="stdout"/> </root> </log4j:configuration>

Show line notes below