모듈 설치
npm install redis
소스
var _redis = require("redis");
var redis = _redis.createClient(포트, 아이피);
redis.get('키', function(error, result) {
if (error) console.log('Error: '+ error);
else console.log('Name: ' + result);
});
redis.set('키', Date(), function(error, result) {
if (error) console.log('Error: ' + error);
else console.log('Saved');
});
참조
모듈 설치
npm install mysql
소스
var mysql = require("mysql");
var mysqlConfig = {
host : "아이피",
port : "포트",
user : "로그인ID",
password : "비밀번호",
database : "데이터베이스명"
}
var conn = mysql.createConnection(mysqlConfig);
conn.query("CALL 프로시저명(?, ?);", [인자1, 인자2], function(err, rows) {
if (err) {
console.log("MySQL Query Execution Failed....");
console.log(err);
}
for (var i = 0; i < rows[0].length; i++) {
console.log(rows[0][i]);
}
conn.destroy();
});
---------------------------------------------------------------------------------------------------------------
// OUTPUT 인자 가져오기
conn.query("CALL 프로시저명(?, ?, @id);", [인자1, 인자2], function(err, rows) {
if (err) {
console.log("MySQL Query Execution Failed....");
console.log(err);
} else {
conn.query("SELECT @id;", function(err, rows, field) {
console.log('id is ' + rows[0]['@id']);
conn.destroy();
});
}
});
My SQL 프로시저 생성 방법
DELIMITER //
DROP PROCEDURE IF EXISTS sp_UserInfo_Select_All //
CREATE PROCEDURE sp_UserInfo_Select_All( )
BEGIN
SELECT *
FROM UserInfo;
END//
DELIMITER ;
DELIMITER //
DROP PROCEDURE IF EXISTS sp_UserInfo_Select //
CREATE PROCEDURE sp_UserInfo_Select
(
pi_UserID INT
)
BEGIN
SELECT *
FROM UserInfo
WHERE UserID = pi_UserID;
END//
DELIMITER ;
DELIMITER //
DROP PROCEDURE IF EXISTS sp_UserInfo_Insert //
CREATE PROCEDURE sp_UserInfo_Insert
(
pi_UserName VARCHAR(20)
,OUT po_UserID INT
)
BEGIN
INSERT INTO UserInfo (UserName)
VALUES (pi_UserName);
-- Auto Increment 값 조회
SELECT LAST_INSERT_ID()
INTO po_UserID; -- OUT 파라메터 담기
END//
DELIMITER ;
DELIMITER //
DROP PROCEDURE IF EXISTS sp_UserInfo_Update //
CREATE PROCEDURE sp_UserInfo_Update
(
pi_UserID INT
, pi_UserName VARCHAR(20)
)
BEGIN
UPDATE UserInfo
SET UserName = pi_UserName
WHERE UserID = pi_UserID;
END//
DELIMITER ;
DELIMITER //
DROP PROCEDURE IF EXISTS sp_UserInfo_Delete //
CREATE PROCEDURE sp_UserInfo_Delete
(
pi_UserID INT
)
BEGIN
DELETE FROM UserInfo
WHERE UserID = pi_UserID;
END//
DELIMITER ;
프로시저 호출
CALL sp_UserInfo_Select_All();
CALL sp_UserInfo_Select(1);
CALL sp_UserInfo_Insert('Park', @UserID);
SELECT @UserID
CALL sp_UserInfo_Insert('Choi', @UserID);
SELECT @UserID
CALL sp_UserInfo_Insert('bahk', @UserID);
SELECT @UserID
CALL sp_UserInfo_Select(2);
CALL sp_UserInfo_Update(2, 'Choi-Update');
CALL sp_UserInfo_Select(2);
CALL sp_UserInfo_Delete(2);
CALL sp_UserInfo_Select_All();
