<?php
echo "** MySQL接続 ***********\n";
$server = "localhost";
$user = "root";
$pass = "root";
$db = mysql_connect($server,$user,$pass);
if (!$db) {
die("接続失敗\n" . mysql_error());
return;
}
else {
echo "接続成功.\n";
}
$seldbflg = mysql_select_db("test",$db);
if(!$seldbflg){
die("データベース選択失敗\n");
mysql_close($db);
return;
}
else{
echo "データベース選択成功..\n";
}
$sql = "select * from emp";
$result = mysql_query($sql, $db);
if (!$result) {
die("$sql::失敗\n" . mysql_error());
}
else{
while ($row = mysql_fetch_array($result)){
print $row[0].",".$row[1].",".$row[2].",";
print $row['ID'].",".$row['EMP_NO'].",".$row['EMP_NAME'].",";
print "\n";
}
}
echo "★insert文\n";
$sql = "insert into emp (emp_no,emp_name,mgr_id,hiredate,sal,dept_id,version_no) values (7985,'YUM',2,'2008-04-25',3000,2,1)";
$result = mysql_query($sql);
if(!$result){
die("$sql::失敗\n" . mysql_error());
return;
}
else{
print "insert成功..\n";
}
echo "★update文\n";
$id = mysql_insert_id($db);
$query = "update emp set emp_name = '%s' where id = %d";
$sql = sprintf($query, mysql_real_escape_string("WWC",$db), $id);
$result = mysql_query($sql);
if(!$result){
die("$sql::失敗\n" . mysql_error());
return;
}
echo "★テーブル結合\n";
$sql = "select e.id, e.emp_no, e.emp_name,d.dept_no, d.dept_name from emp e join dept d where e.dept_id = d.id order by e.id";
$result = mysql_query($sql);
if(!$result){
die("$sql::失敗\n" . mysql_error());
return;
}
else{
while ($row = mysql_fetch_array($result,MYSQL_ASSOC)){
print $row['id'].",".$row['emp_no'].",".$row['emp_name'].",".$row['dept_no'].",".$row['dept_name'].";;";
print "\n";
}
}
mysql_close($db);
echo "** MySQL接続終了.. ***********\n";
?>