<?
$strDriver = "{SQL Native Client}";
$strTarget = "NIGHT_TCP";	// 別名
$strDB = "lightbox";
$strUser = "sa";
$strPass = "passwordpassword";

// **********************************************************
// Windows 用動的ロード
// **********************************************************
if ( !extension_loaded( "pdo" ) ) {
	dl("php_pdo.dll");
}
if ( !extension_loaded( "pdo_odbc" ) ) {
	dl("php_pdo_odbc.dll");
}

// **********************************************************
// 接続
// **********************************************************
$Cn = new PDO(
	"odbc:Driver=$strDriver;Server=$strTarget;" .
	"Database=$strDB;Uid=$strUser;Pwd=$strPass;");
$Cn2 = new PDO(
	"odbc:Driver=$strDriver;Server=$strTarget;" .
	"Database=$strDB;Uid=$strUser;Pwd=$strPass;");


$Query = "select * from [社員マスタ]";

// **********************************************************
// レコードセット
// ※ メタデータは取得できませんでした
// **********************************************************
$handle = fopen( ".\\社員マスタ.csv", "w" );

$Rs = $Cn->Query( $Query );

$nFields = $Rs->columnCount();
$hbuffer = "";
$update_cnt = 0;
while( $result = $Rs->fetch(PDO::FETCH_ASSOC) ) {
	if ( $hbuffer == "" ) {
		$field_names = array_keys($result);
		for( $i = 0; $i < $nFields; $i++ ) {
			if ( $hbuffer != "" ) {
				$hbuffer .= ",";
			}
			$hbuffer .= $field_names[$i];
		}
		fwrite( $handle, $hbuffer . "\n" );
	}

	$buffer = "";
	for( $i = 0; $i < $nFields; $i++ ) {
		if ( $buffer != "" ) {
			$buffer .= ",";
		}
		$buffer .= $result[$field_names[$i]];
	}
	fwrite( $handle, $buffer . "\n" );

	// 更新( 別接続 )
	$day = ($update_cnt % 5) + 1;
	$Query = "update [社員マスタ] set [生年月日] = '2005/01/0$day'";
	$Query .= " where [社員コード] = '{$result['社員コード']}'";
	$Cn2->exec( $Query );
	// false がエラーです。 0 は、実行が成功しても対象が無かった場合に返ってきます
	// ですから、if ( !$ret ) は正しくありません
	if ($ret===false) {
		print_r( $Cn->errorInfo() );
	}

	$update_cnt++;

}

// **********************************************************
// ファイルクローズ
// **********************************************************
fclose( $handle );
// **********************************************************
// 接続解除
// **********************************************************
$Cn2 = null;
$Cn = null;
?>

<?
// **********************************************************
// SQLExpress 2005 / OLE DB / 純正接続
// COM(ADO) : 読み込みと更新
// **********************************************************
$Cn = new COM( "ADODB.Connection" );
$Cn->CursorLocation = 3;
$Rs = new COM( "ADODB.Recordset" );
				
$strTarget = "NIGHT_TCP";	// 別名
$strDB = "lightbox";
$strUser = "sa";
$strPass = "passwordpassword";

// **********************************************************
// 接続文字列
// **********************************************************
$ConnectionString =
	"Provider=SQLOLEDB;" .
	"Data Source=$strTarget;" .
	"Initial Catalog=$strDB;" .
	"User ID=$strUser;" .
	"Password=$strPass;";

/*
// ODBC 接続 / {SQL Server}
$strDriver = "{SQL Server}";
// SQL Server は、TCP/IP と 名前付きパイプで接続されました
$ConnectionString =
	"Provider=MSDASQL;" .
	"Driver=$strDriver;" .
	"SERVER=$strTarget;" .
	"DATABASE=$strDB;" .
	"USER=$strUser;" .
	"PWD=$strPass;";
*/

/*
// ODBC 接続 / {SQL Native Client}
$strDriver = "{SQL Native Client}";
// TCP/IP で接続するのに、Trusted_Connection=yes; が必要でした
// http://technet.microsoft.com/ja-jp/library/ms130822(SQL.90).aspx
// 上記指定が無い場合、名前付きパイプでは接続されました
// $strTarget = "lbox";	// 名前付きパイプの別名
$ConnectionString =
	"Provider=MSDASQL;Trusted_Connection=yes;" .
	"Driver=$strDriver;" .
	"SERVER=$strTarget;" .
	"DATABASE=$strDB;" .
	"USER=$strUser;" .
	"PWD=$strPass;";
*/

// **********************************************************
// 接続
// **********************************************************
$Cn->Open( $ConnectionString );

$Query = "select * from [社員マスタ]";

// **********************************************************
// レコードセット
// **********************************************************
$handle = fopen( ".\\社員マスタ.csv", "w" );

// レコードセットが開いていたら、閉じておく
if ( $Rs->State >= 1 ) {
	$Rs->Close();
}
$Rs->Open( $Query, $Cn );

$nFields = $Rs->Fields->Count;
$hbuffer = "";
$update_cnt = 0;
while( !$Rs->EOF ) {
	if ( $hbuffer == "" ) {
		for( $i = 0; $i < $nFields; $i++ ) {
			if ( $hbuffer != "" ) {
				$hbuffer .= ",";
			}
			$hbuffer .= $Rs->Fields[$i]->Name;
		}
		fwrite( $handle, $hbuffer . "\n" );
	}

	$buffer = "";
	for( $i = 0; $i < $nFields; $i++ ) {
		if ( $buffer != "" ) {
			$buffer .= ",";
		}
		$buffer .= $Rs->Fields[$i]->Value . "";

		// 日本語名称で直接参照できないので、連想配列を作成
		$Column[$Rs->Fields[$i]->name] = $Rs->Fields[$i]->value;

	}
	fwrite( $handle, $buffer . "\n" );

	// 更新( 別接続 )
	$day = ($update_cnt % 6) + 1;
	$Query = "update [社員マスタ] set [生年月日] = '2005/01/0$day'";
	// 連想配列で値を参照
	$Query .= " where [社員コード] = '{$Column["社員コード"]}'";
	$Cn->execute( $Query );

	$Rs->MoveNext();
	$update_cnt++;

}

// **********************************************************
// ファイルクローズ
// **********************************************************
fclose( $handle );
// **********************************************************
// 接続解除
// **********************************************************
@$Cn->Close();
?>