setAttribute(PDO::ATTR_EMULATE_PREPARES, false); // DB 関連エラーは例外を発生させる $dbh->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION); // タイムゾーンを JST に $dbh->query("SET SESSION time_zone='Asia/Tokyo'"); // トランザクション開始 $dbh->beginTransaction(); // アカウントID を決定。Cookie にあればそれを使う。なければ 1 とする。 if ( isset($_COOKIE['account_id']) && $_COOKIE['account_id'] != '' ){ $account_id = $_COOKIE['account_id']; } else { $account_id = 1; } // Redis 接続 $redis = new Redis(); $redis->connect('myredis.gh65zs.0001.use2.cache.amazonaws.com', 6379); // XSS 対策。& < > " ' などを実体参照化。 function myesc($str) { return htmlspecialchars($str, ENT_QUOTES, 'UTF-8'); } // フォローまたはフォロー解除処理 if ( isset($_REQUEST['account_id_followee']) && $_REQUEST['account_id_followee'] != '' ){ $follow_mode = $_REQUEST['follow_mode']; $account_id_followee = $_REQUEST['account_id_followee']; if ( $follow_mode == 'follow' ){ // フォロー処理 $sql = "insert ignore into follow (account_id_followee, account_id_follower) values (?, ?)"; $stmt = $dbh->prepare($sql); $stmt->execute(array($account_id_followee, $account_id)); $dbh->commit(); } else if ( $follow_mode == 'unfollow' ){ // フォロー解除処理 $sql = "delete from follow where account_id_followee = ? and account_id_follower = ?"; $stmt = $dbh->prepare($sql); $stmt->execute(array($account_id_followee, $account_id)); $dbh->commit(); } // 被フォロワーの Redis キーを削除 $redis->delete("follow_count_$account_id"); } // 新規メッセージがあれば if ( isset($_REQUEST['new_message']) && $_REQUEST['new_message'] != '' ){ // 先頭30バイトを取得 $new_message = mb_substr($_REQUEST['new_message'], 0, 30); // レコード INSERT。 $sql = "INSERT INTO tweet (account_id, message) VALUES (:account_id, :message)"; $stmt = $dbh->prepare($sql); $stmt->bindParam(':account_id', $account_id, PDO::PARAM_INT); $stmt->bindParam(':message', $new_message, PDO::PARAM_STR); $res = $stmt->execute(); $dbh->commit(); // Redis からツィート数に関するキーを削除 $redis->delete("tweet_count_$account_id"); } ?>
account_id = myesc($account_id) ?>
ツイート数 = myesc($tweet_count) ?> (= myesc($tweet_count_debug_message) ?>)
フォロー数 = myesc($follow_count) ?> (= myesc($follow_count_debug_message) ?>)
フォロワー数 = myesc($follower_count) ?>
SERVER_ADDR: = myesc(getenv('SERVER_ADDR')) ?>