|
[문법] MYSQL 에서 Stored Procedure 사용하기(내부 Transaction 사용가능)
|
|
|
 글쓴이 |
   제록 |
날 짜 |
06-08-16 19:39 |
조 회 |
5324 |
|
|
0. 준비사항 : MYSQL5.x 이상. 웹에서 사용할 경우 PHP5.x 이상
1. 테이블 생성
CREATE TABLE `TranTest` (
`num` int(11) NOT NULL auto_increment,
`col01` varchar(32) default NULL,
PRIMARY KEY (`num`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
CREATE TABLE `TranTest2` (
`num` int(11) NOT NULL auto_increment,
`col01` varchar(32) default NULL,
PRIMARY KEY (`num`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
2. 입력 용 프로시저 생성
CREATE PROCEDURE `Prc_TranTest_Input`
(
in in_col01 varchar(32)
)
BEGIN
INSERT INTO TranTest SET col01 = in_col01;
END;
3. SELECT 용 프로시저 생성
CREATE PROCEDURE `Prc_TranTest_Select`
(
in in_col01 varchar(32)
)
BEGIN
SELECT num, col01 FROM TranTest WHERE col01 like concat(in_col01, '%') ;
END;
4. Transaction 용 프로시저 생성
CREATE PROCEDURE `Prc_TranTest_InError`
(
)
NOT DETERMINISTIC
SQL SECURITY DEFINER
COMMENT ''
BEGIN
DECLARE dbErr int default 0;
DECLARE CONTINUE HANDLER FOR SQLEXCEPTION SET dbErr = -1;
START TRANSACTION;
INSERT INTO TranTest SET col01 = '1234';
INSERT INTO TranTest2 SET col012 = '1234'; //일부러 에러값을 내기위해 칼럼명을 다르게 적습니다.
IF dbErr < 0 THEN
ROLLBACK;
ELSE
COMMIT;
END IF;
END;
5. PHP 를 이용하여 SELECT 및 입력하기
$mysqli = new mysqli("localhost", "USERID", "USERPW", "USERDB");
if (mysqli_connect_error()) {
printf("Connect Failed : %s\n", mysqli_connect_error());
exit;
}
$mysqli->query("set names utf8");
//SELECT
if($qry = $mysqli->query("Call Prc_TranTest_Select('123')")) {
$rs = $qry->fetch_object();
echo $rs->col01;
}
//INSERT TranTest;
$mysqli->query("Call Prc_TranTest_InError()");
|
|
|
|
|
