概要

  • mysql でも prepare でプレースホルダとして ? じゃなく名前で指定できるようにする。
  • 同じ名前を繰り返し使ってもエラーにならない。
  • こっちより CPAN:DBIx-Custom の方が柔軟で高機能だなー。どうしたもんか。
  • CPAN:DBIx-NamedBinding に比べると、bind_param_ex の1回でバインドできるのと型指定できる点が勝ってるかな。

使用法

スカラーのバインド

  • 「:名前-型」でスカラー値を bind する。
    my $sql_insert = qq{
    	INSERT INTO `Users` ( `ID`, `Name`, `Status`, `RegDate` )
    	VALUES ( NULL, :Name-VARCHAR, :State-INTEGER, :RegDate-DATETIME );
    };
    $sth_insert = $dbh->prepare_ex( $sql_insert ) or die( "$DBI::errstr\n" );
    $sth_insert->bind_param_ex( { 'Name' => 'リオ', 'State' => 1, 'RegDate' => '2011-02-21 10:00' } );
    $sth_insert->execute() or die( "$DBI::errstr\n" );

配列(個数指定あり)のバインド

  • 「:名前{個数}-型」で配列値を個数個分 bind する。
    my $sql_select = qq{
    	SELECT `ID`, `Name`, `Status`, `RegDate`
    	FROM `Users`
    	WHERE `Status` in ( :State{4}-INTEGER );
    };
    $sth_select = $dbh->prepare_ex( $sql_select ) or die( "$DBI::errstr\n" );
    $sth_select->bind_param_ex( { 'State' => [ 1,2,4,8 ] } );
    $sth_select->execute() or die( "$DBI::errstr\n" );

配列(個数指定なし)のバインド

  • 「:名前+-型」で配列値を配列要素個分 bind する。
    prepare_exの引数としてSQL文と共に割り当てるハッシュを指定する必要がある。
    my $sql_select = qq{
    	SELECT `ID`, `Name`, `Status`, `RegDate`
    	FROM `Users`
    	WHERE `Status` in ( :State+-INTEGER );
    };
    $sth_select = $dbh->prepare_ex( $sql_select, { 'State' => [ 1,2,4,8 ] } ) 
    	or die( "$DBI::errstr\n" );
    $sth_select->execute() or die( "$DBI::errstr\n" );

デバッグログの採取

  • プレースホルダの解析結果、解析後の SQL 文、バインドされる値をログファイルに書き出します。
  • ファイル名を省略すると、ホームディレクトリ(Linux: 環境変数 HOME, Windows: 環境変数 USERPROFILE)にログファイル(DBIx-NamedParams.log)が作られます。
    DBIx::NamedParams::debug_log( 'testNamedParams.log' );

DBD のデータタイプに対応する SQL タイプのハッシュ

my %DrvTypeToSQLType = $dbh->driver_typename_map();

変更履歴

0.0.5 / 2011/09/28

  • driver_typename_map メソッドが返すハッシュを調整。DB が MS SQL Server の場合、datetime および smalldatetime に対して DATE ではなく WVARCHAR を割り当てるようにした。

0.0.4 / 2011/09/17

  • driver_typename_map メソッド追加。その DBD で使用できるデータタイプに対応する SQL タイプ名のハッシュを返す。
  • デバッグログのファイル名を指定できるようにした。ログの体裁の調整。
  • MS SQL Server 版のサンプルを作成。datetime 型にバインドするのに DATETIME じゃなくて WVARCHAR(VARCHAR) 使わなくちゃいけないなんて、そんなん考慮しとらんよ…。

0.0.3 / 2011/04/17

  • 機能面での追加・変更はなし。
  • 「use base;」を「use parent;」に変更。
  • import にて、継承元である DBI の import を呼び出すようにしたけど、不要かも?
  • ソース内の関数の順序を呼び出し元と呼び出し先が近くになるように変更。
  • _parse_ex にて、$repeat の既定値を '' から 0 に変更。
  • bind_param_ex にて、「no warnings;」を「no warnings 'uninitialized';」に変更。
  • bind_param_ex にて、$ref_hash が HASH であることを確認するようにした。

0.0.2 / 2011/03/07

  • prepare_ex のときに @_NamedParams をクリアするようにした。

ソース

NamedParams.pm

# DBI::db::prepare, DBI::st::bind_param を拡張する。
# http://www.TakeAsh.net/wiki/?Perl/DBIx-NamedParams
#
# prepare_ex では「:名前-型」形式のようにプレースホルダを書く。
# bind_param_ex では名前と値の対応を示すハッシュを渡す。

package DBIx::NamedParams;

use strict;
use warnings;
use utf8;
use Encode;
use Carp qw( croak );
use parent qw( DBI );
use DBI::Const::GetInfoType;
use Log::Dispatch;
use POSIX qw( strftime );

use version; our $VERSION = qv( '0.0.5' );

( $ENV{'LANG'} || '' ) =~ /\.(.*)$/;	# ja_JP.UTF-8
my $charsetConsole	= $1 || 'CP932';
my $charsetFile		= 'UTF-8';

my $_default_log_filename = ( $ENV{'HOME'} || $ENV{'USERPROFILE'} );
$_default_log_filename =~ s#\\#/#g;
$_default_log_filename .= '/DBIx-NamedParams.log';

my %_SQL_TypeRefs = ();
my %_SQL_TypeInvs = ();
my $_SQL_Types = "";
my @_NamedParams = ();
my $_index;
my $_log = undef;

sub import {
	DBI->import();	# 不要か?
	_init();
	*{DBI::db::driver_typename_map}	= \&driver_typename_map;
	*{DBI::db::prepare_ex}			= \&prepare_ex;
	*{DBI::st::bind_param_ex}		= \&bind_param_ex;
}

sub _init
{
	foreach( @{ $DBI::EXPORT_TAGS{sql_types} } ){
		my $refFunc = \&{"DBI::$_"};
		if ( /^SQL_(.*)$/i ){
			$_SQL_TypeRefs{ $1 } = &{ $refFunc };
			$_SQL_TypeInvs{ &{ $refFunc } } = $1;
		}
	}
	$_SQL_Types = all_sql_types();
}

sub debug_log
{
	my( $filename ) = @_;
	$filename = encode( $charsetConsole, ( $filename || $_default_log_filename ) );
	$_log = Log::Dispatch->new( 
		outputs => [ [ 
			'File', 
			min_level	=> 'debug', 
			filename	=> $filename, 
			binmode		=> ":encoding($charsetFile)", 
			permissions	=> 0666, 
			newline		=> 1,
		], ], 
	);
	$_log->info( _thisFuncName(), strftime( "%Y-%m-%d %H:%M:%S", localtime ) );
}

sub _thisFuncName
{
	( caller( 1 ) )[3] =~ /([^:]+)$/;
	return $1;
}

sub all_sql_types
{
	return wantarray 
		? sort( keys( %_SQL_TypeRefs ) ) 
		: join( "|", sort( keys( %_SQL_TypeRefs ) ) );
}
sub driver_typename_map
{
	my( $self ) = @_;
	my %map = ();
	foreach my $refType ( $self->type_info() ){
		my $datatype = $refType->{ 'SQL_DATA_TYPE' } 	# MS SQL Server
			|| $refType->{ 'SQL_DATATYPE' };			# MySQL
		$map{ $refType->{ 'TYPE_NAME' } } = $_SQL_TypeInvs{ $datatype } || 'WVARCHAR';
	}
	if ( $self->get_info( $GetInfoType{ 'SQL_DBMS_NAME' } ) eq 'Microsoft SQL Server' ){
		$map{ 'datetime' } = 'WVARCHAR';
		$map{ 'smalldatetime' } = 'WVARCHAR';
	}
	return %map;
}

sub prepare_ex
{
	my( $self, $sqlex, $refHash ) = @_;
	my $ret = undef;
	my $validHash = defined( $refHash ) && ref( $refHash ) eq 'HASH';
	if ( $sqlex =~ /\:([\w]+)\+-($_SQL_Types)\b/ ){
		if ( $validHash ){
			$sqlex =~ s/\:([\w]+)\+-($_SQL_Types)\b/_parse_ex1($refHash,$1,$2);/ge;
		} else {
			croak( "prepare_ex need a hash reference when SQL is variable length.\n" );
		}
	}
	@_NamedParams = ();
	$_index = 1;
	$sqlex =~ s/\:([\w]+)(?:\{(\d+)\})?-($_SQL_Types)\b/_parse_ex2($1,$2,$3);/ge;
	if ( $_log ){
		$_log->info( _thisFuncName(), 'sql_raw', "{{$sqlex}}" );
	}
	$ret = $self->prepare( $sqlex ) or croak( "$DBI::errstr" );
	if ( $validHash ){
		$ret->bind_param_ex( $refHash );
	}
	return $ret;
}

sub _parse_ex1
{
	my( $refHash, $name, $type ) = @_;
	return ":${name}{" . scalar( @{ $refHash->{ $name } } ) . "}-$type";
}

sub _parse_ex2
{
	my $name	= shift || '';
	my $repeat	= shift || 0;
	my $type	= shift || '';
	my $ret = '';
	# '' や 0 も有効値として使いたい場合 (Perl 5.9 以降)
	# my $param = shift // -1;
	if ( $_log ){
		$_log->info( 
			_thisFuncName(), 
			"[$_index]", 
			"\"$name\"", 
			(!$repeat) ? "scalar" : "array[$repeat]", 
			$type 
		);
	}
	if ( !$repeat ){
		# scalar
		$_NamedParams[ $_index++ ] = { 
			Name	=> $name, 
			Type	=> $_SQL_TypeRefs{ $type }, 
			Array	=> -1,
		};
		$ret = '?';
	} else {
		# array
		for( my $i=0; $i<$repeat; ++$i ){
			$_NamedParams[ $_index++ ] = { 
				Name	=> $name, 
				Type	=> $_SQL_TypeRefs{ $type }, 
				Array	=> $i,
			};
		}
		$ret = substr( '?,' x $repeat, 0, -1 );
	}
	return $ret;
}

sub bind_param_ex
{
	no warnings 'uninitialized';
	my( $self, $refHash ) = @_;
	if ( !defined( $refHash ) || ref( $refHash ) ne 'HASH' ){
		croak( "bind_param_ex need a hash reference.\n" );
	}
	my $thisFunc = _thisFuncName();
	for( my $i=1; $i<@_NamedParams; ++$i ){
		my $idx = $_NamedParams[ $i ]{ 'Array' };
		my $value1 = $refHash->{ $_NamedParams[ $i ]{ 'Name' } };
		my $value2 = ( $idx < 0 || ref( $value1 ) ne 'ARRAY' ) 
			? $value1 
			: @{ $value1 }[ $idx ];
		my $datatype = $_NamedParams[ $i ]{ 'Type' };
		if ( $_log ){
			$_log->info( 
				$thisFunc, "[$i]", "\"$value2\"", $_SQL_TypeInvs{ $datatype } 
			);
		}
		$self->bind_param( $i, $value2 , { TYPE => $datatype } ) 
			or croak( "$DBI::errstr\n" );
	}
	return $self;
}

1;

# EOF

testNamedParams_MySQL.pl

#!/usr/bin/perl
# DBIx::NamedParams のテスト

use strict;
use warnings;
use utf8;
use Encode;
use YAML::Syck;
use POSIX qw( strftime );
use FindBin::libs;
use lib qw( /home/Shared/lib );
use DBIx::NamedParams;

( $ENV{'LANG'} || '' ) =~ /\.(.*)$/;	# ja_JP.UTF-8
my $charsetConsole	= $1 || 'CP932';
my $charsetFile		= 'UTF-8';

binmode( STDIN,  ":encoding($charsetConsole)" );
binmode( STDOUT, ":encoding($charsetConsole)" );
binmode( STDERR, ":encoding($charsetConsole)" );

$YAML::Syck::ImplicitUnicode = 1;

my $path = $FindBin::RealBin . '/';
my $yaml = $path . 'DB_Connect_MySQL.yml';
my $input = $path . 'InputData.yml';

my $DB_Info = YAML::Syck::LoadFile( $yaml ) or die( "$yaml: $!\n" );
foreach( keys( %{$DB_Info} ) ){
	$DB_Info->{'DSN'} =~ s/_${_}_/$DB_Info->{$_}/;
}

my $dbh = DBI->connect( 
	'DBI:' . $DB_Info->{'DSN'}, 
	$DB_Info->{'User'}, 
	$DB_Info->{'Password'}, 
	$DB_Info->{'Options'}
) or die( "$DBI::errstr\n" );

#DBIx::NamedParams::debug_log( 'testNamedParams.log' );

#my %DrvTypeToSQLType = $dbh->driver_typename_map();
#print Dump( \%DrvTypeToSQLType );

my $sql_insert = qq{
	INSERT INTO 
		`Users` 
		( `Name`, `Status`, `RegDate` ) 
	VALUES 
		( :Name-VARCHAR, :State-INTEGER, :Now-DATETIME );
};

my $sth_insert = $dbh->prepare_ex( $sql_insert ) or die( "$DBI::errstr\n" );

my $users = YAML::Syck::LoadFile( $input ) or die( "$input: $!\n" );
#print Dump( $users );
#exit;

foreach( @{$users} ){
	$_->{'Now'} = strftime( "%Y-%m-%d %H:%M:%S", localtime );
	print Dump( $_ );
	$sth_insert->bind_param_ex( $_ );
	$sth_insert->execute() or die( "$DBI::errstr\n" );
	sleep( 1 );
}
$sth_insert->finish;

my $sql_select = qq{
	SELECT
		`ID`, `Name`, `Status`, `RegDate` 
	FROM
		`Users` 
	WHERE
		`Status` in ( :State+-INTEGER );
};

my $sth_select = $dbh->prepare_ex( $sql_select, { 'State' => [ 1,2,5 ] } ) 
	or die( "$DBI::errstr\n" );
$sth_select->execute() or die( "$DBI::errstr\n" );
do {
	no warnings 'uninitialized';
	while( my @a = $sth_select->fetchrow_array ){
		printf( "%s\n", join( "\t", @a ) );
	}
}while( $sth_select->{odbc_more_results} );
$sth_select->finish;

$dbh->disconnect;

exit;

# EOF

DB_Connect_MySQL.yml

# DB接続情報
Driver:   mysql
Server:   localhost
Port:     3306
User:     TestUser
Password: "Test"  # 記号を含む場合は""で括る
DB:       TestDB
Options:
    mysql_enable_utf8: 1
DSN:      "_Driver_:database=_DB_; host=_Server_; port=_Port_;"  # Linux
#DSN:      "_Driver_:database=_DB_:host=_Server_"                 # Windows

createUsers_MySQL.sql

SET SQL_MODE="NO_AUTO_VALUE_ON_ZERO";

CREATE TABLE `Users` (
  `ID` int(11) NOT NULL AUTO_INCREMENT,
  `Name` varchar(40) NOT NULL,
  `Status` int(11) NOT NULL DEFAULT '0',
  `RegDate` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`ID`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 AUTO_INCREMENT=1 ;

InputData.yml (MySQL/MSSQL 共通)

--- 
- { Name: リオ,     State: 1 }
- { Name: ミント,   State: 2 }
- { Name: ローザ,   State: 3 }
- { Name: リンダ,   State: 4 }
- { Name: リナ,     State: 5 }
- { Name: アーニャ, State: 6 }

testNamedParams_MSSQL.pl

#!/usr/bin/perl
# DBIx::NamedParams のテスト

use strict;
use warnings;
use utf8;
use Encode;
use YAML::Syck;
use POSIX qw( strftime );
use FindBin::libs;
use lib qw( /home/Shared/lib );
use DBIx::NamedParams;

( $ENV{'LANG'} || '' ) =~ /\.(.*)$/;	# ja_JP.UTF-8
my $charsetConsole	= $1 || 'CP932';
my $charsetFile		= 'UTF-8';

binmode( STDIN,  ":encoding($charsetConsole)" );
binmode( STDOUT, ":encoding($charsetConsole)" );
binmode( STDERR, ":encoding($charsetConsole)" );

$YAML::Syck::ImplicitUnicode = 1;

my $path = $FindBin::RealBin . '/';
my $yaml = $path . 'DB_Connect_MSSQL.yml';
my $input = $path . 'InputData.yml';

my $DB_Info = YAML::Syck::LoadFile( $yaml ) or die( "$yaml: $!\n" );
foreach( keys( %{$DB_Info} ) ){
	$DB_Info->{'DSN'} =~ s/_${_}_/$DB_Info->{$_}/;
}

my $dbh = DBI->connect( 
	'DBI:' . $DB_Info->{'DSN'}, 
	$DB_Info->{'User'}, 
	$DB_Info->{'Password'}, 
	$DB_Info->{'Options'}
) or die( "$DBI::errstr\n" );

#DBIx::NamedParams::debug_log( 'testNamedParams.log' );

#my %DrvTypeToSQLType = $dbh->driver_typename_map();
#print Dump( \%DrvTypeToSQLType );

my $sql_insert = qq{
	INSERT INTO 
		[Users] 
		( [Name], [Status], [RegDate] ) 
	VALUES 
		( :Name-WVARCHAR, :State-INTEGER, :Now-WVARCHAR );
};

my $sth_insert = $dbh->prepare_ex( $sql_insert ) or die( "$DBI::errstr\n" );

my $users = YAML::Syck::LoadFile( $input ) or die( "$input: $!\n" );
#print Dump( $users );
#exit;

foreach( @{$users} ){
	$_->{'Now'} = strftime( "%Y-%m-%d %H:%M:%S", localtime );
	print Dump( $_ );
	$sth_insert->bind_param_ex( $_ );
	$sth_insert->execute() or die( "$DBI::errstr\n" );
	sleep( 1 );
}
$sth_insert->finish;

my $sql_select = qq{
	SELECT
		[ID], [Name], [Status], [RegDate] 
	FROM
		[Users] 
	WHERE
		[Status] in ( :State+-INTEGER );
};

my $sth_select = $dbh->prepare_ex( $sql_select, { 'State' => [ 1,2,5 ] } ) 
	or die( "$DBI::errstr\n" );
$sth_select->execute() or die( "$DBI::errstr\n" );
do {
	no warnings 'uninitialized';
	while( my @a = $sth_select->fetchrow_array ){
		printf( "%s\n", join( "\t", @a ) );
	}
}while( $sth_select->{odbc_more_results} );
$sth_select->finish;

$dbh->disconnect;

exit;

# EOF

DB_Connect_MSSQL.yml

# DB接続情報
Driver:   ODBC
Server:   localhost\SQLExress,1433  # <サーバ名>\<インスタンス名>[,<ポート>]
User:     TestUser
Password: "Test"  # 記号を含む場合は""で括る
DB:       TestDB
Options:
    LongTruncOk: 1
    LongReadLen: 8192
DSN:      _Driver_:Driver={SQL Server}; Server={_Server_}; Database=_DB_;

createUsers_MSSQL.sql

USE [TestDB]
GO

SET ANSI_NULLS ON
GO

SET QUOTED_IDENTIFIER ON
GO

CREATE TABLE [dbo].[Users](
	[ID] [int] IDENTITY(1,1) NOT NULL,
	[Name] [nvarchar](40) NOT NULL,
	[Status] [int] NOT NULL,
	[RegDate] [datetime] NULL,
	CONSTRAINT [PK_Users] PRIMARY KEY CLUSTERED 
	(
		[ID] ASC
	) WITH (
		PAD_INDEX  = OFF, 
		STATISTICS_NORECOMPUTE  = OFF, 
		IGNORE_DUP_KEY = OFF, 
		ALLOW_ROW_LOCKS  = ON, 
		ALLOW_PAGE_LOCKS  = ON
	) ON [PRIMARY]
) ON [PRIMARY]
GO

ALTER TABLE [dbo].[Users] 
ADD CONSTRAINT [DF_Users_RegDate] 
DEFAULT (getdate()) FOR [RegDate]
GO

SQLTypes

getSQLTypes.pl

# SQLタイプ一覧

use strict;
use warnings;
use utf8;
use Encode;
use POSIX qw( strftime );
use FindBin::libs;
use lib qw( /home/Shared/lib );
use DBIx::NamedParams;

print "Perl version: " . $] . "\n";
print "DBI version: " . $DBI::VERSION . "\n";
print strftime( "%Y-%m-%d %H:%M:%S\n\n", localtime );
print join( "\n", DBIx::NamedParams::all_sql_types() ) . "\n";

# EOF

出力

Perl version: 5.010001
DBI version: 1.616
2011-06-17 00:37:32

ALL_TYPES
ARRAY
ARRAY_LOCATOR
BIGINT
BINARY
BIT
BLOB
BLOB_LOCATOR
BOOLEAN
CHAR
CLOB
CLOB_LOCATOR
DATE
DATETIME
DECIMAL
DOUBLE
FLOAT
GUID
INTEGER
INTERVAL
INTERVAL_DAY
INTERVAL_DAY_TO_HOUR
INTERVAL_DAY_TO_MINUTE
INTERVAL_DAY_TO_SECOND
INTERVAL_HOUR
INTERVAL_HOUR_TO_MINUTE
INTERVAL_HOUR_TO_SECOND
INTERVAL_MINUTE
INTERVAL_MINUTE_TO_SECOND
INTERVAL_MONTH
INTERVAL_SECOND
INTERVAL_YEAR
INTERVAL_YEAR_TO_MONTH
LONGVARBINARY
LONGVARCHAR
MULTISET
MULTISET_LOCATOR
NUMERIC
REAL
REF
ROW
SMALLINT
TIME
TIMESTAMP
TINYINT
TYPE_DATE
TYPE_TIME
TYPE_TIMESTAMP
TYPE_TIMESTAMP_WITH_TIMEZONE
TYPE_TIME_WITH_TIMEZONE
UDT
UDT_LOCATOR
UNKNOWN_TYPE
VARBINARY
VARCHAR
WCHAR
WLONGVARCHAR
WVARCHAR

MySQLのデータタイプ

--- 
bigint: BIGINT
bigint auto_increment: BIGINT
bigint unsigned: BIGINT
bigint unsigned auto_increment: BIGINT
bit: BIT
bit auto_increment: BIT
blob: LONGVARBINARY
char: CHAR
date: DATE
datetime: TIMESTAMP
decimal: NUMERIC
double: DOUBLE
double auto_increment: DOUBLE
enum: ALL_TYPES
float: FLOAT
float auto_increment: FLOAT
int: INTEGER
int auto_increment: INTEGER
int unsigned: INTEGER
int unsigned auto_increment: INTEGER
integer: INTEGER
integer auto_increment: INTEGER
integer unsigned: INTEGER
integer unsigned auto_increment: INTEGER
long varbinary: LONGVARBINARY
long varchar: LONGVARCHAR
longblob: LONGVARBINARY
mediumblob: LONGVARBINARY
mediumint: INTEGER
mediumint auto_increment: INTEGER
mediumint unsigned: INTEGER
mediumint unsigned auto_increment: INTEGER
mediumtext: LONGVARCHAR
numeric: NUMERIC
set: ALL_TYPES
smallint: SMALLINT
smallint auto_increment: SMALLINT
smallint unsigned: SMALLINT
smallint unsigned auto_increment: SMALLINT
text: LONGVARCHAR
time: TIME
timestamp: TIMESTAMP
tinyblob: VARBINARY
tinyint: TINYINT
tinyint auto_increment: TINYINT
tinyint unsigned: TINYINT
tinyint unsigned auto_increment: TINYINT
varchar: VARCHAR
year: SMALLINT

MS SQL Server のデータタイプ

--- 
bigint: BIGINT
bigint identity: BIGINT
binary: BINARY
bit: BIT
char: CHAR
date: WVARCHAR
datetime: WVARCHAR
datetime2: WVARCHAR
datetimeoffset: WVARCHAR
decimal: DECIMAL
decimal() identity: DECIMAL
float: FLOAT
image: LONGVARBINARY
int: INTEGER
int identity: INTEGER
money: DECIMAL
nchar: WCHAR
ntext: WLONGVARCHAR
numeric: NUMERIC
numeric() identity: NUMERIC
nvarchar: WVARCHAR
real: REAL
smalldatetime: WVARCHAR
smallint: SMALLINT
smallint identity: SMALLINT
smallmoney: DECIMAL
sql_variant: WVARCHAR
sysname: WVARCHAR
text: LONGVARCHAR
time: WVARCHAR
timestamp: BINARY
tinyint: TINYINT
tinyint identity: TINYINT
uniqueidentifier: GUID
varbinary: VARBINARY
varchar: VARCHAR
xml: WLONGVARCHAR

リンク