Twitter APIで呼び出したつぶやき（スクリーンネーム・日時・本文）をデータベース（MySQL）に格納するときのPHPコード

2014年11月24日2017年12月2日

Twitter APIでおもしろいつぶやきを集めて、アクセス数を稼ごうとと思っても、おのずと限界があります。なぜならTwitter APIにはレート制限が存在し、一定時間内にアクセスできる回数が決まっているからです。

レートリミットに関わらず、アクセスしてもらおうと思うと、自前でデータベースを用意する必要があります。

そこで今回は、Twitter APIのGET statuses/user_timelineで取得したつぶやきデータを、データベース(MySQL)に挿入してみようと思います。

MySQLのクエリ文とPHPのコード

今回は、スクリーンネーム、つぶやき本文、日時を取得します。まずMySQLのテーブルを作成するためのクエリ文です

テーブル作成のためのクエリ文

create table tweet (
	id int(11) not null auto_increment primary key,
	tw_screen varchar(16),
	tw_date varchar(25),
	tw_txt text
);

PDOクラスを使用したPHPコード

try catch文と、PDOクラスはドットインストールのコードを参考にして、try catch文おります。そのtry catch文を、foreach文で回すという体裁です。

[php]
<?php
require_once("twitteroauth/twitteroauth.php");

$consumerKey = "MYCONSUMERKEY";
$consumerSecret = "MYCONSUMERSECRET";
$accessToken = "MYACCESSTOKEN";
$accessTokenSecret = "MYACCESSTOKENSECRET";

$twObj = new TwitterOAuth($consumerKey,$consumerSecret,$accessToken,$accessTokenSecret);

$request = $twObj->OAuthRequest(‘https://api.twitter.com/1.1/statuses/user_timeline.json’,’GET’,
array(
‘count’=>’10’,
‘screen_name’ => ‘echizenya_yota’,
));
$results = json_decode($request);

if(isset($results) && empty($results->errors)){
foreach($results as $tweet){
// データベースの接続
try {
$dbh = new PDO(‘mysql:host=localhost;dbname=tweet1;charset=utf8’, ‘myusername’,’mypassword’);
} catch(PDOException $e) {
var_dump($e->getMessage());
exit;
}
// 処理
$stmt = $dbh->prepare("insert into tweet (tw_screen, tw_date, tw_txt) values (:tw_screen, :tw_date, :tw_txt)");

$stmt->bindParam(":tw_screen", $tw_screen);
$stmt->bindParam(":tw_date", $tw_date);
$stmt->bindParam(":tw_txt", $tw_txt);

$tw_screen = $tweet->user->screen_name;
$tw_date = date(‘Y-m-d H:i:s’, strtotime($tweet->created_at));
$tw_txt = $tweet->text;

$stmt->execute();
// 切断
$dbh = null;
}
}else{
echo "関連したつぶやきがありません。";
}

?>
[/php]