Mybatis 소스 코드 분석의 저장 프로 세 스 호출 및 실행 프로 세 스

이 편 은 Mybatis 가 저장 프로 세 스 를 호출 하 는 사용 과 실행 절 차 를 배 워 보 겠 습 니 다.우선 간단 한 저장 프로 세 스 를 만 듭 니 다.

DELIMITER $ 
CREATE PROCEDURE mybatis.ges_user_count(IN age INT, OUT user_count INT) 
BEGIN 
SELECT COUNT(*) FROM users WHERE users.age=age INTO user_count; 
END 
$ 

이 저장 과정의 의 미 는 사실 비교적 간단 하 다.바로 age 를 입력 한 다음 에 select count(*)from users where users.age=age into user 를 실행 하 는 것 이다.count；나이 가 age 와 같은 인원 을 획득 하여 usercount,그래도 비교적 간단 합 니 다.
다음은 저장 과정의 호출 입 니 다.다음 명령 을 실행 하면 저장 과정의 호출 을 완성 할 수 있 습 니 다.

다음은 Mybatis 를 이용 하여 저장 과정 을 어떻게 호출 하 는 지 살 펴 보 자.
userMapper.xml 저장 프로 세 스 호출 설정 추가:

<select id="count" statementType="CALLABLE" parameterMap="getUserCountMap"> 
  CALL mybatis.ges_user_count(?,?) 
</select> 

주 함수:

public class Learn1Main { 
 public static void main(String [] args){ 
  //mybatis      
  String resource = "learn/mybatis-config.xml"; 
  //        mybatis     （           ） 
  InputStream is = Learn1Main.class.getClassLoader().getResourceAsStream(resource); 
  //  sqlSession    
  SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder().build(is); 
  SqlSession session = sessionFactory.openSession(); 
  Map<String, Integer> parameterMap = new HashMap<String, Integer>(); 
  parameterMap.put("age", 12); 
  parameterMap.put("user_count", -1); 
  session.selectOne("com.tianjunwei.learn.learn1.entity.User.count", parameterMap); 
  Integer result = parameterMap.get("user_count"); 
  System.out.println(result); 
 } 
} 

실행 결과:
그 최종 실행 과정 은 Default ResultSetHandler 에서 일반적인 sql 과 저장 과정 을 호출 하 는 것 과 차이 가 있 습 니 다.Sql 문장의 실행 은 Callable Statement 을 사용 합 니 다.

// 
// HANDLE OUTPUT PARAMETER 
// 
//          ，          
@Override 
public void handleOutputParameters(CallableStatement cs) throws SQLException { 
 final Object parameterObject = parameterHandler.getParameterObject(); 
 final MetaObject metaParam = configuration.newMetaObject(parameterObject); 
 final List<ParameterMapping> parameterMappings = boundSql.getParameterMappings(); 
/         
 for (int i = 0; i < parameterMappings.size(); i++) { 
 final ParameterMapping parameterMapping = parameterMappings.get(i); 
 //        
 if (parameterMapping.getMode() == ParameterMode.OUT || parameterMapping.getMode() == ParameterMode.INOUT) { 
  if (ResultSet.class.equals(parameterMapping.getJavaType())) { 
  handleRefCursorOutputParameter((ResultSet) cs.getObject(i + 1), parameterMapping, metaParam); 
  } else { 
  final TypeHandler<?> typeHandler = parameterMapping.getTypeHandler(); 
  metaParam.setValue(parameterMapping.getProperty(), typeHandler.getResult(cs, i + 1)); 
  } 
 } 
 } 
} 
private void handleRefCursorOutputParameter(ResultSet rs, ParameterMapping parameterMapping, MetaObject metaParam) throws SQLException { 
 try { 
 final String resultMapId = parameterMapping.getResultMapId(); 
 final ResultMap resultMap = configuration.getResultMap(resultMapId); 
 final DefaultResultHandler resultHandler = new DefaultResultHandler(objectFactory); 
 final ResultSetWrapper rsw = new ResultSetWrapper(rs, configuration); 
 handleRowValues(rsw, resultMap, resultHandler, new RowBounds(), null); 
 metaParam.setValue(parameterMapping.getProperty(), resultHandler.getResultList()); 
 } finally { 
 // issue #228 (close resultsets) 
 closeResultSet(rs); 
 } 
} 

위 에서 말 한 것 은 소 편 이 소개 한 Mybatis 소스 코드 분석의 저장 과정 호출 과 운영 절차 입 니 다.여러분 에 게 도움 이 되 기 를 바 랍 니 다.궁금 한 점 이 있 으 시 면 메 시 지 를 남 겨 주세요.소 편 은 신속하게 답 해 드 리 겠 습 니 다.여기 서도 저희 사이트 에 대한 여러분 의 지지 에 감 사 드 립 니 다!