我的代码:
122 #
123 my $hfpDbh = undef;
124 unless (
125 $hfpDbh = DBI->connect("dbi:Pg:host=....")#removed something
128 ) {
129 Log( ERROR, "" );
130 Exit( 1 )
131 }
132 $hfpDbh->{RaiseError} = 1;
133 $hfpDbh->{AutoCommit} = 0;
134
135 ( my $mydata, $msg ) = load_data( $hfpDbh, $DatFile );
136 unless ( defined($mydata) )
137 {
138 Log(INFO, "Calling exit...2");
139 }
140 #$hfpDbh->disconnect();
141 Exit( 0 );
142 Log(INFO, "Calling exit...4");
143
144
145 sub load_data
146 {
147 my ( $dbh, $DatFile ) = @_;
148 my $msg = '';
149 unless ( $dbh ) {
150 $msg = 'cannot load data, no DB handle';
151 Log( ERROR, $msg );
152 }
153 Log(INFO, "Call load_data...");
154 my $q = "SELECT ip as ip FROM rules WHERE active = 'true' AND isGood = 'true';";
155 my $stmt = undef;
156 unless ( $stmt = $dbh->prepare( $q ) ) {
157 $msg = "unable to prepare SQL query: $q";
158 Log( ERROR, $msg );
159 }
160
161 eval { $stmt->execute() };
162 if ( $@ ) {
163 $msg = "failed to execute SQL query: $@";
164 Log( ERROR, $msg );
165 }
166
167 my $data = {};
168 while ( my $row = $stmt->fetchrow_hashref() ) {
169 #Log(INFO, "testing row");
170 }
171 $stmt->finish();
172 return $data, $msg;
173 }
警告是:
Issuing rollback() due to DESTROY without explicit disconnect() of DBD::Pg::db handle
如果我在第 171 行之后添加"$dbh->commit()",上面的警告就会消失。
如果我没有在第 171 行之后添加 "$dbh->commit()",而是在第 140 行中调用 "$hfpDbh->disconnect();",上面的警告也消失了。
我的问题是:警告表示存在未提交的事务?这就是为什么我需要显式提交或断开连接以修复警告的原因。但是代码中只有 SELECT 操作。我错过了什么?
谢谢。
-
由于您根本不要修改数据库,因此不需要启用事务,因此不要将
AutoCommit
设置为零。这样也无需在任何地方调用commit
,并且当句柄离开 dcope 时,数据库将自动断开连接 -
由于您自己处理错误,因此不应将
RaiseError
设置为 1。如果发生任何错误,这将导致您的程序立即死亡,并且您自己的处理代码将无法执行 -
没有必要打电话给
finish
.它在这里不会造成任何伤害,但它也是毫无意义的,几乎永远没有必要
警告表示存在未提交的事务?
由于您请求使用事务,因此存在未提交的事务,但警告实际上通知您隐式执行了回滚。它告诉您这一点,因为这可能会导致信息丢失。显然,在这种情况下,它不会导致信息丢失,但检查还不够聪明,无法意识到这一点。
我错过了什么?
$hfpDbh->disconnect();
或$hfpDbh->rollback();