[위 에] 제4 장: Dubbo 통합 maven + spring + springmv + my batis 의 my batis 통합

세 편의 박문 을 이어서 계속 하 다.
1. ivan - dubbo - server 에 spring - mybatis. 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:tx="http://www.springframework.org/schema/tx"
	xmlns:aop="http://www.springframework.org/schema/aop"
	xsi:schemaLocation="
		http://www.springframework.org/schema/beans 
		http://www.springframework.org/schema/beans/spring-beans-4.1.xsd 
		http://www.springframework.org/schema/tx 
		http://www.springframework.org/schema/tx/spring-tx-4.1.xsd
		http://www.springframework.org/schema/aop 
		http://www.springframework.org/schema/aop/spring-aop-4.1.xsd
		">

	<!-- <context:property-placeholder location="classpath:jdbc.properties"/> -->
	<!--           Druid    -->
	<bean name="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
		init-method="init" destroy-method="close">
		<property name="url" value="${jdbc.url}" />
		<property name="username" value="${jdbc.username}" />
		<property name="password" value="${jdbc.password}" />

		<!--         -->
		<property name="initialSize" value="0" />
		<!--             -->
		<property name="maxActive" value="20" />

		<!--         -->
		<property name="minIdle" value="0" />
		<!--            -->
		<property name="maxWait" value="60000" />
		<property name="poolPreparedStatements" value="true" />
		<property name="maxPoolPreparedStatementPerConnectionSize"
			value="33" />
		<!--       sql -->
		<property name="validationQuery" value="${validationQuery}" />
		<property name="testOnBorrow" value="false" />
		<property name="testOnReturn" value="false" />
		<property name="testWhileIdle" value="true" />
		<!--              ,           ,      -->
		<property name="timeBetweenEvictionRunsMillis" value="60000" />
		<!--                 ,      -->
		<property name="minEvictableIdleTimeMillis" value="25200000" />
		<!--   removeAbandoned   -->
		<property name="removeAbandoned" value="true" />
		<!-- 1800 ,   30   -->
		<property name="removeAbandonedTimeout" value="1800" />
		<!--   abanded          -->
		<property name="logAbandoned" value="true" />
		<!--       -->
		<property name="filters" value="mergeStat" />
	</bean>

	<!-- myBatis   -->
	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
		<property name="dataSource" ref="dataSource" />
		<!--     entity  ,   Configuration.xml       -->
		<property name="mapperLocations" value="classpath:com/ivan/**/mapping/*.xml" />
	</bean>

	<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
		<property name="basePackage" value="com.ivan.*.dao" />
		<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
	</bean>

	<!--         -->
	<bean id="transactionManager"
		class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource" />
	</bean>

	<!--          -->
	<!-- <tx:annotation-driven transaction-manager="transactionManager" /> -->

	<!--           -->
	<tx:advice id="transactionAdvice" transaction-manager="transactionManager">
		<tx:attributes>
			<tx:method name="insert*" propagation="REQUIRED" />
			<tx:method name="update*" propagation="REQUIRED" />
			<tx:method name="delete*" propagation="REQUIRED" />

			<tx:method name="get*" propagation="SUPPORTS" read-only="true" />
			<tx:method name="find*" propagation="SUPPORTS" read-only="true" />
			<tx:method name="select*" propagation="SUPPORTS" read-only="true" />

		</tx:attributes>
	</tx:advice>
	<!-- 
<span style="font-family:FangSong_GB2312;">             </span>Spring aop    
<span style="font-family:FangSong_GB2312;">                            ,         </span>

         -->
	<!-- <aop:config>
		<aop:pointcut id="transactionPointcut"  expression="execution(* com.ivan..service.impl.*Impl.*(..))" />
		<aop:advisor advice-ref="transactionAdvice" pointcut-ref="transactionPointcut"/>
	</aop:config> -->

</beans>

2. ivan - dubbo - server 프로젝트 에 jdbc. properties 설정 파일 을 추가 하고 자신의 설정 에 따라 수정 합 니 다. 이 설정 파일 의 인용 은 spring - registry, xml 에 있 습 니 다.
#mysql version database druid setting
validationQuery=SELECT 1
jdbc.url=jdbc:mysql://localhost:3306/ivan?useUnicode=true&characterEncoding=utf-8
jdbc.username=root
jdbc.password=

3. ivan - dubbo - server 프로젝트 의
spring - registry, xml 로 컬 프로필 도입
jdbc.properties :
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
		<property name="locations">
			<list>
				<value>classpath:zookeeper.properties</value>
				<value>classpath:jdbc.properties</value>
            </list>
		</property>
	</bean>

4. ivan - dubbo - server 프로젝트 에서 dao 인터페이스 UserMapper 를 만 듭 니 다. 여 기 는 generator 로 자동 으로 생 성 된 dao, mapping, enity 입 니 다.
generator 설정 에 대한 자세 한 설명 은 여 기 를 클릭 하 십시오.
import java.util.List;

import com.ivan.entity.User;

public interface UserMapper {
    int deleteByPrimaryKey(Integer id);

    int insert(User record);

    int insertSelective(User record);

    User selectByPrimaryKey(Integer id);

    int updateByPrimaryKeySelective(User record);

    int updateByPrimaryKey(User record);

	List<User> selectAll();
}

5. ivan - dubbo - server 프로젝트 에서 실체 맵 파일 UserMapping. 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.ivan.dubbo.dao.UserMapper" >
  <resultMap id="BaseResultMap" type="com.ivan.entity.User" >
    <id column="id" property="id" jdbcType="INTEGER" />
    <result column="name" property="name" jdbcType="VARCHAR" />
    <result column="age" property="age" jdbcType="INTEGER" />
  </resultMap>
  <sql id="Base_Column_List" >
    id, name, age
  </sql>
  
  <select id="selectAll" resultMap="BaseResultMap">
  	select
  	<include refid="Base_Column_List" />
  	from user
  </select>
  
  <select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
    select 
    <include refid="Base_Column_List" />
    from user
    where id = #{id,jdbcType=INTEGER}
  </select>
  <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer" >
    delete from user
    where id = #{id,jdbcType=INTEGER}
  </delete>
  <insert id="insert" parameterType="com.ivan.entity.User" >
    insert into user (id, name, age
      )
    values (#{id,jdbcType=INTEGER}, #{name,jdbcType=VARCHAR}, #{age,jdbcType=INTEGER}
      )
  </insert>
  <insert id="insertSelective" parameterType="com.ivan.entity.User" >
    insert into user
    <trim prefix="(" suffix=")" suffixOverrides="," >
      <if test="id != null" >
        id,
      </if>
      <if test="name != null" >
        name,
      </if>
      <if test="age != null" >
        age,
      </if>
    </trim>
    <trim prefix="values (" suffix=")" suffixOverrides="," >
      <if test="id != null" >
        #{id,jdbcType=INTEGER},
      </if>
      <if test="name != null" >
        #{name,jdbcType=VARCHAR},
      </if>
      <if test="age != null" >
        #{age,jdbcType=INTEGER},
      </if>
    </trim>
  </insert>
  <update id="updateByPrimaryKeySelective" parameterType="com.ivan.entity.User" >
    update user
    <set >
      <if test="name != null" >
        name = #{name,jdbcType=VARCHAR},
      </if>
      <if test="age != null" >
        age = #{age,jdbcType=INTEGER},
      </if>
    </set>
    where id = #{id,jdbcType=INTEGER}
  </update>
  <update id="updateByPrimaryKey" parameterType="com.ivan.entity.User" >
    update user
    set name = #{name,jdbcType=VARCHAR},
      age = #{age,jdbcType=INTEGER}
    where id = #{id,jdbcType=INTEGER}
  </update>
</mapper>

6. ivan - entity 에서 실체 User 를 만 들 때 주의해 야 할 것 은 사용 입 니 다.
generator 생 성 실체, Serializable 실현 되 지 않 습 니 다. 수 동 으로 가입 해 야 합 니 다. 그렇지 않 으 면 dubbo 호출 시 오류 가 발생 할 수 있 습 니 다.
import java.io.Serializable;

@SuppressWarnings("serial")
public class User implements Serializable{
    private Integer id;

    private String name;

    private Integer age;
    
    public User(){};
    
    public User(Integer id,String name,Integer age){
    	this.id = id;
    	this.name = name;
    	this.age = age;
    }

    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 == null ? null : name.trim();
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }
}

7. ivan - api 프로젝트 에서 기 존의 인터페이스 류 UserService 를 수정 하면 dao 인터페이스 UserMapper 의 방법 을 직접 복사 할 수 있 습 니 다.
import java.util.List;

import com.ivan.entity.User;

public interface UserService {

	int deleteByPrimaryKey(Integer id);

	int insert(User record);

	int insertSelective(User record);

	User selectByPrimaryKey(Integer id);

	int updateByPrimaryKeySelective(User record);

	int updateByPrimaryKey(User record);
	
	//   
	List<User> getUsers();
}

8. ivan - dubbo - server 프로젝트 에서 UserService 인 터 페 이 스 를 실현 하고 @ Autowired 를 사용 하여 dao 인터페이스 UserMapper 를 자동 으로 주입 합 니 다.
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;

import com.alibaba.dubbo.common.json.JSON;
import com.alibaba.dubbo.config.annotation.Service;
import com.ivan.api.dubbo.UserService;
import com.ivan.dubbo.dao.UserMapper;
import com.ivan.entity.User;

@Service
public class UserServiceImpl implements UserService {

	private static final Logger logger = LoggerFactory.getLogger(UserServiceImpl.class);
	
	@Autowired
	private UserMapper userMapper;
	
	public int insert(User record){
		return userMapper.insert(record);
	}

      public int insertSelective(User record){
    	return userMapper.insertSelective(record);
    }
	//      Mapper      
	public List<User> getUsers() {
		logger.info("          ");
		
		logger.info("    ");
		return userMapper.selectAll();
	}

	public int deleteByPrimaryKey(Integer id) {
		return userMapper.deleteByPrimaryKey(id);
	}

	public User selectByPrimaryKey(Integer id) {
		return userMapper.selectByPrimaryKey(id);
	}

	public int updateByPrimaryKeySelective(User record) {
		return userMapper.updateByPrimaryKeySelective(record);
	}

	public int updateByPrimaryKey(User record) {
		return userMapper.updateByPrimaryKey(record);
	}

}

9. ivan - dubbo - server 시작 클래스 ServerMain 에 spring - mybatis. xml 코드 추가
import java.io.IOException;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class ServerMain {
	
	public static void main(String[] args) throws IOException {
		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
				new String[] { "spring-registry.xml","spring-mybatis.xml"});
		context.start();

		System.in.read(); //       
	}
}

여기까지 백 스테이지 준비 가 끝 났 습 니 다. ivan - dubbo - server 프로젝트 의 main 함수 ServerMain 을 시작 하여 백 스테이지 를 시작 합 니 다.
10. 프론트 프로젝트 ivan - dubbo - web 에서 controller 류 UserController 를 수정 합 니 다.
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import com.alibaba.dubbo.config.annotation.Reference;
import com.ivan.api.dubbo.UserService;
import com.ivan.entity.User;

/**
 * @author ivan
 *
 */
@Controller
@RequestMapping("/user")
public class UserController {
	
	@SuppressWarnings("unused")
	private static final Logger logger = LoggerFactory.getLogger(UserController.class);
	
	@Reference
	private UserService userService;
	/**
	 *      
	 * @return index.jsp
	 */
	@RequestMapping("/")
	public String goIndex(){
		return "index";
	}
	/**
	 *   user
	 */
	@RequestMapping("/insert")
	@ResponseBody
	public List<User> insert(){
		User user = new User(1,"jack",18);
		userService.insert(user);
		return getUsers();
	}
	/**
	 *      user
	 */
	@RequestMapping("/insertSelective")
	@ResponseBody
    public List<User> insertSelective(){
    	User user = new User(2,"ivan",25);
        userService.insertSelective(user);
        return getUsers();
    }
	
	/**
	 *       
	 */
	@RequestMapping("/list")
	@ResponseBody
	public List<User> getUsers(){
		return userService.getUsers();
	}
	
	/**
	 *  id  user
	 *@param   id
	 */
	@RequestMapping("/one")
	@ResponseBody
	public User getUserById(String id){
		return userService.selectByPrimaryKey(Integer.valueOf(id));
	}
	
	/**
	 *  id  user
	 *@param   id
	 */
	@RequestMapping("/delete")
	@ResponseBody
	public List<User> deleteUserById(String id){
		userService.deleteByPrimaryKey(Integer.valueOf(id));
		return getUsers();
	}
	
	/**
	 *  id  user
	 *@param   id
	 */
	@RequestMapping("/updateById")
	@ResponseBody
	public User updateUserById(String id){
		User user = new User(Integer.valueOf(id),"ivan",30);
		userService.updateByPrimaryKey(user);
		return userService.selectByPrimaryKey(Integer.valueOf(id));
	}
}

tomcat 를 시작 하면 다음 경 로 를 방문 하면 구축 성공 여 부 를 심각하게 할 수 있 습 니 다.
1、http://127.0.0.1:8080/ivan-dubbo-web/user/insert/  데이터베이스 에 user: id: 1, name: jack, 나이: 18 삽입
2、http://127.0.0.1:8080/ivan-dubbo-web/user/insertSelective/  데이터베이스 에 user: id: 2, name: ivan 2, 나이: 25 삽입
3、http://127.0.0.1:8080/ivan-dubbo-web/user/list/    검색 데이터 의 모든 사용자 가 순서대로 1, 2 절 차 를 실행 하면 브 라 우 저 는 되 돌아 가 야 합 니 다. [{"id": 1, "name": "jack", "age": 18}, {"id": 2, "name": "ivan", "age": 25}]
4、http://127.0.0.1:8080/ivan- dbo - web / user / one /? id = 1 검색 id 가 1 인 사용자, 브 라 우 저 반환: {"id": 1, "name": "jack", "age": 18}
5、http://127.0.0.1:8080/ivan- dbo - web / user / delete /? id = 1 삭제 id 가 1 인 사용자, 브 라 우 저 는 삭제 후 데이터베이스 에 있 는 모든 사용 자 를 되 돌려 줍 니 다.
6、http://127.0.0.1:8080/ivan- dubbo - web / user / updateById /? id = 1 업데이트 id 가 1 인 사용자, 브 라 우 저 는 업 데 이 트 된 모든 데이터베이스 사용 자 를 되 돌려 줍 니 다.
데이터 시트 구 조 를 첨부 한 sql
/*
Navicat MySQL Data Transfer

Source Server         : 127.0.0.1
Source Server Version : 50627
Source Host           : localhost:3306
Source Database       : ivan

Target Server Type    : MYSQL
Target Server Version : 50627
File Encoding         : 65001

Date: 2015-11-13 11:19:18
*/

SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for user
-- ----------------------------
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
  `id` int(11) NOT NULL,
  `name` varchar(255) COLLATE utf8_unicode_ci DEFAULT NULL,
  `age` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;

이로써 통합 이 끝 났 습 니 다. 다음은 무엇 을 연구 해 볼 까요?

좋은 웹페이지 즐겨찾기