holm/egroupware
1
1
Fork 0
forked from extern/egroupware
Code Issues Pull Requests Packages Projects Releases Wiki Activity

delete db entry again, if we are not able to open a new(!) file in filesystem

Browse Source
This commit is contained in:
Ralf Becker 2010-06-14 20:13:38 +00:00
parent 0aacf11b43
commit 9310a2b0d8
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
phpgwapi/inc/class.sqlfs_stream_wrapper.inc.php
View File

@ -187,6 +187,7 @@ class sqlfs_stream_wrapper implements iface_stream_wrapper
return false; return false;
} }
// new file --> create it in the DB // new file --> create it in the DB
$new_file = true;
$stmt = self::$pdo->prepare($query='INSERT INTO '.self::TABLE.' (fs_name,fs_dir,fs_mode,fs_uid,fs_gid,fs_created,fs_modified,fs_creator,fs_mime,fs_size'. $stmt = self::$pdo->prepare($query='INSERT INTO '.self::TABLE.' (fs_name,fs_dir,fs_mode,fs_uid,fs_gid,fs_created,fs_modified,fs_creator,fs_mime,fs_size'.
') VALUES (:fs_name,:fs_dir,:fs_mode,:fs_uid,:fs_gid,:fs_created,:fs_modified,:fs_creator,:fs_mime,:fs_size)'); ') VALUES (:fs_name,:fs_dir,:fs_mode,:fs_uid,:fs_gid,:fs_created,:fs_modified,:fs_creator,:fs_mime,:fs_size)');
$values = array( $values = array(
@ -263,11 +264,17 @@ class sqlfs_stream_wrapper implements iface_stream_wrapper
//echo 'gettype($this->opened_stream)='; var_dump($this->opened_stream); //echo 'gettype($this->opened_stream)='; var_dump($this->opened_stream);
} }
} }
// do we operate directly on the filesystem // do we operate directly on the filesystem --> open file from there
if ($this->operation == self::STORE2FS) if ($this->operation == self::STORE2FS)
{ {
if (self::LOG_LEVEL > 1) error_log(__METHOD__." fopen (may create a directory? mkdir) ($this->opened_fs_id,$mode,$options)"); if (self::LOG_LEVEL > 1) error_log(__METHOD__." fopen (may create a directory? mkdir) ($this->opened_fs_id,$mode,$options)");
$this->opened_stream = fopen(self::_fs_path($this->opened_fs_id),$mode); if (!($this->opened_stream = fopen(self::_fs_path($this->opened_fs_id),$mode)) && $new_file)
{
// delete db entry again, if we are not able to open a new(!) file
unset($stmt);
$stmt = self::$pdo->prepare('DELETE FROM '.self::TABLE.' WHERE fs_id=:fs_id');
$stmt->execute(array('fs_id' => $this->opened_fs_id));
}
} }
if ($mode[0] == 'a') // append modes: a, a+ if ($mode[0] == 'a') // append modes: a, a+
{ {