Public/fhem-mirror
1
0
Fork 0
mirror of https://github.com/fhem/fhem-mirror.git synced 2025-05-04 22:19:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

configDB:

Browse Source 
changed: all files will be imported as binary
changed: all existing textfiles will be moved to binary automatically
removed: command binfileimport
added: sorted write and read of configuration data


git-svn-id: https://svn.fhem.de/fhem/trunk/fhem@5836 2b470e98-0d58-463d-a4d8-8e2adae1ed80
This commit is contained in:
betateilchen 2014-05-12 21:21:58 +00:00
parent 4d66984d31
commit c91fdf5574
2 changed files with 135 additions and 109 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
FHEM/98_configdb.pm
View File

@ -13,14 +13,14 @@ my @pathname;
sub configdb_Initialize($$) { sub configdb_Initialize($$) {
my %hash = ( Fn => "CommandConfigdb", my %hash = ( Fn => "CommandConfigdb",
Hlp => "info|list|diff|uuid| Hlp => "help ,access additional functions from configDB" );
reorg|recover|backup ,access additional functions from configDB" );
$cmds{configdb} = \%hash; $cmds{configdb} = \%hash;
} }
##################################### #####################################
sub _configdb_rM($$) { sub _configdb_rM($$) {
# read moddir
my ($modpath,$backupdir) = @_; my ($modpath,$backupdir) = @_;
my $msg; my $msg;
my $ret; my $ret;
@ -43,6 +43,7 @@ sub _configdb_rM($$) {
} }
sub _configdb_cA($) { sub _configdb_cA($) {
# create archive
my $backupdir = shift; my $backupdir = shift;
my $backupcmd = (!defined($attr{global}{backupcmd}) ? undef : $attr{global}{backupcmd}); my $backupcmd = (!defined($attr{global}{backupcmd}) ? undef : $attr{global}{backupcmd});
my $symlink = (!defined($attr{global}{backupsymlink}) ? "no" : $attr{global}{backupsymlink}); my $symlink = (!defined($attr{global}{backupsymlink}) ? "no" : $attr{global}{backupsymlink});
@ -205,25 +206,25 @@ sub CommandConfigdb($$) {
$ret = _cfgDB_Fileexport $filename; $ret = _cfgDB_Fileexport $filename;
} }
when ('fileimport') { # when ('fileimport') {
return "\n Syntax: configdb fileimport <pathToFile>" if @a != 2; # return "\n Syntax: configdb fileimport <pathToFile>" if @a != 2;
my $filename; # my $filename;
if($param1 =~ m,^[./],) { # if($param1 =~ m,^[./],) {
$filename = $param1; # $filename = $param1;
} else { # } else {
$filename = $attr{global}{modpath}; # $filename = $attr{global}{modpath};
$filename .= "/$param1"; # $filename .= "/$param1";
} # }
if ( -r $filename ) { # if ( -r $filename ) {
$ret = _cfgDB_Fileimport $filename; # $ret = _cfgDB_Fileimport $filename;
} elsif ( -e $filename) { # } elsif ( -e $filename) {
$ret = "\n Read error on file $filename"; # $ret = "\n Read error on file $filename";
} else { # } else {
$ret = "\n File $filename not found."; # $ret = "\n File $filename not found.";
} # }
} # }
when ('binfileimport') { when ('fileimport') {
return "\n Syntax: configdb fileimport <pathToFile>" if @a != 2; return "\n Syntax: configdb fileimport <pathToFile>" if @a != 2;
my $filename; my $filename;
if($param1 =~ m,^[./],) { if($param1 =~ m,^[./],) {
@ -242,6 +243,10 @@ sub CommandConfigdb($$) {
} }
} }
when ('binfileimport') {
return "\n configdb binfileimport is deprecated.\n Please use configdb fileimport.";
}
when ('filelist') { when ('filelist') {
return _cfgDB_Filelist; return _cfgDB_Filelist;
} }
@ -319,7 +324,6 @@ sub CommandConfigdb($$) {
$ret = "\n Syntax:\n". $ret = "\n Syntax:\n".
" configdb attr [attribute] [value]\n". " configdb attr [attribute] [value]\n".
" configdb backup\n". " configdb backup\n".
" configDB binfileimport <pathToFilename>\n".
" configdb diff <device> <version>\n". " configdb diff <device> <version>\n".
" configDB filedelete <pathToFilename>\n". " configDB filedelete <pathToFilename>\n".
" configDB fileimport <pathToFilename>\n". " configDB fileimport <pathToFilename>\n".
@ -541,14 +545,6 @@ compare device: telnetPort in current version 0 (left) to version: 1 (right)
<br/> <br/>
<br/> <br/>
<li><code>configdb binfileimport &lt;sourceFilename&gt;</code></li><br/>
Imports specified binary file from from filesystem into database.<br/>
Example:<br/>
<br/>
<code>configdb binfileimport www/images/bla.png</code><br/>
<br/>
<br/>
<li><code>configdb filelist</code></li><br/> <li><code>configdb filelist</code></li><br/>
Show a list with all filenames stored in database.<br/> Show a list with all filenames stored in database.<br/>
<br/> <br/>
@ -876,14 +872,6 @@ compare device: telnetPort in current version 0 (left) to version: 1 (right)
<br/> <br/>
<br/> <br/>
<li><code>configdb binfileimport &lt;quellDatei&gt;</code></li><br/>
Liest die angegbene Bin&auml;rdatei aus dem Dateisystem und schreibt den Inhalt in die Datenbank.<br/>
Beispiel:<br/>
<br/>
<code>configdb binfileimport www/images/bla.png</code><br/>
<br/>
<br/>
<li><code>configdb filelist</code></li><br/> <li><code>configdb filelist</code></li><br/>
Liefert eine Liste mit allen Namen der gespeicherten Dateien.<br/> Liefert eine Liste mit allen Namen der gespeicherten Dateien.<br/>
<br/> <br/>

182
configDB.pm
View File

@ -73,6 +73,11 @@
# #
# 2014-04-27 - added new functions for binfile handling # 2014-04-27 - added new functions for binfile handling
# #
# 2014-05-11 - removed binfileimport
# changed store all files as binary
# added _cfgDB_move to move all files from text
# to binary filesave on first load of configDB
#
############################################################################## ##############################################################################
# #
@ -93,7 +98,7 @@ sub GlobalAttr($$$$);
# #
sub _cfgDB_Connect; sub _cfgDB_Connect;
sub _cfgDB_InsertLine($$$); sub _cfgDB_InsertLine($$$$);
sub _cfgDB_Execute($@); sub _cfgDB_Execute($@);
sub _cfgDB_ReadCfg(@); sub _cfgDB_ReadCfg(@);
sub _cfgDB_ReadState(@); sub _cfgDB_ReadState(@);
@ -102,6 +107,7 @@ sub _cfgDB_Uuid;
sub _cfgDB_Info; sub _cfgDB_Info;
sub _cfgDB_Filelist(;$); sub _cfgDB_Filelist(;$);
sub _cfgDB_Reorg(;$$); sub _cfgDB_Reorg(;$$);
sub _cfgDB_move();
################################################## ##################################################
# Read configuration file for DB connection # Read configuration file for DB connection
@ -162,29 +168,47 @@ if($cfgDB_dbconn =~ m/pg:/i) {
$fhem_dbh->commit(); $fhem_dbh->commit();
my $uuid = _cfgDB_Uuid; my $uuid = _cfgDB_Uuid;
$fhem_dbh->do("INSERT INTO fhemversions values (0, '$uuid')"); $fhem_dbh->do("INSERT INTO fhemversions values (0, '$uuid')");
_cfgDB_InsertLine($fhem_dbh, $uuid, '#created by cfgDB_Init'); _cfgDB_InsertLine($fhem_dbh, $uuid, '#created by cfgDB_Init',0);
_cfgDB_InsertLine($fhem_dbh, $uuid, 'attr global logfile ./log/fhem-%Y-%m-%d.log'); _cfgDB_InsertLine($fhem_dbh, $uuid, 'attr global logfile ./log/fhem-%Y-%m-%d.log',1);
_cfgDB_InsertLine($fhem_dbh, $uuid, 'attr global modpath .'); _cfgDB_InsertLine($fhem_dbh, $uuid, 'attr global modpath .',2);
_cfgDB_InsertLine($fhem_dbh, $uuid, 'attr global userattr devStateIcon devStateStyle icon sortby webCmd'); _cfgDB_InsertLine($fhem_dbh, $uuid, 'attr global userattr devStateIcon devStateStyle icon sortby webCmd',3);
_cfgDB_InsertLine($fhem_dbh, $uuid, 'attr global verbose 3'); _cfgDB_InsertLine($fhem_dbh, $uuid, 'attr global verbose 3',4);
_cfgDB_InsertLine($fhem_dbh, $uuid, 'define telnetPort telnet 7072 global'); _cfgDB_InsertLine($fhem_dbh, $uuid, 'define telnetPort telnet 7072 global',5);
_cfgDB_InsertLine($fhem_dbh, $uuid, 'define WEB FHEMWEB 8083 global'); _cfgDB_InsertLine($fhem_dbh, $uuid, 'define WEB FHEMWEB 8083 global',6);
_cfgDB_InsertLine($fhem_dbh, $uuid, 'define Logfile FileLog ./log/fhem-%Y-%m-%d.log fakelog'); _cfgDB_InsertLine($fhem_dbh, $uuid, 'define Logfile FileLog ./log/fhem-%Y-%m-%d.log fakelog',7);
} }
# create TABLE fhemstate if nonexistent # create TABLE fhemstate if nonexistent
$fhem_dbh->do("CREATE TABLE IF NOT EXISTS fhemstate(stateString TEXT)"); $fhem_dbh->do("CREATE TABLE IF NOT EXISTS fhemstate(stateString TEXT)");
# create TABLE fhemfilesave if nonexistent
$fhem_dbh->do("CREATE TABLE IF NOT EXISTS fhemfilesave(filename TEXT, line TEXT)");
# create TABLE fhembinfilesave if nonexistent # create TABLE fhembinfilesave if nonexistent
$fhem_dbh->do("CREATE TABLE IF NOT EXISTS fhembinfilesave(filename TEXT, content BLOB)"); $fhem_dbh->do("CREATE TABLE IF NOT EXISTS fhembinfilesave(filename TEXT, content BLOB)");
$fhem_dbh->commit();
# check if we need to move files from text to binary
my $needmove;
if($cfgDB_dbtype eq "SQLITE") {
$needmove = $fhem_dbh->selectrow_array( "SELECT count(1) FROM sqlite_master WHERE name='fhemfilesave'" );
}
if($cfgDB_dbtype eq "MYSQL") {
my $result = $fhem_dbh->do("SHOW TABLES LIKE 'fhemfilesave'");
$needmove = ($result > 0) ? 1 : 0;
}
if($cfgDB_dbtype eq "POSTGRESQL") {
$needmove = $fhem_dbh->selectrow_array("SELECT count(1) from pg_catalog.pg.tables where tablename = 'fhemfilesave'");
}
# close database connection # close database connection
$fhem_dbh->commit(); $fhem_dbh->commit();
$fhem_dbh->disconnect(); $fhem_dbh->disconnect();
# move all files from text filesave to binary if not already done
_cfgDB_move if($needmove);
return; return;
} }
@ -215,27 +239,30 @@ if($cfgDB_dbconn =~ m/pg:/i) {
sub cfgDB_FileRead($) { sub cfgDB_FileRead($) {
my ($filename) = @_; my ($filename) = @_;
my ($err, @ret, $counter);
my $fhem_dbh = _cfgDB_Connect; my $fhem_dbh = _cfgDB_Connect;
my $sth = $fhem_dbh->prepare( "SELECT line FROM fhemfilesave WHERE filename LIKE '$filename'" ); my $sth = $fhem_dbh->prepare( "SELECT content FROM fhembinfilesave WHERE filename LIKE '$filename'" );
$sth->execute(); $sth->execute();
my @outfile; my $blobContent = $sth->fetchrow_array();
while (my @line = $sth->fetchrow_array()) {
push @outfile, "$line[0]";
}
$sth->finish(); $sth->finish();
$fhem_dbh->disconnect(); $fhem_dbh->disconnect();
return (int(@outfile)) ? @outfile : undef; $counter = length($blobContent);
if($counter) {
@ret = split(/\n/,$blobContent);
$err = "";
} else {
@ret = undef;
$err = "Error on reading $filename from database!";
}
return ($err, @ret);
} }
sub cfgDB_FileWrite($@) { sub cfgDB_FileWrite($@) {
my ($filename,@content) = @_; my ($filename,@content) = @_;
my $fhem_dbh = _cfgDB_Connect; my $fhem_dbh = _cfgDB_Connect;
$fhem_dbh->do("delete from fhemfilesave where filename = '$filename'"); $fhem_dbh->do("delete from fhembinfilesave where filename = '$filename'");
my $sth = $fhem_dbh->prepare('INSERT INTO fhemfilesave values (?, ?)'); my $sth = $fhem_dbh->prepare('INSERT INTO fhembinfilesave values (?, ?)');
foreach (@content){ $sth->execute($filename,join("\n", @content));
$sth->execute($filename,rtrim($_));
}
$sth->finish(); $sth->finish();
$fhem_dbh->commit(); $fhem_dbh->commit();
$fhem_dbh->disconnect(); $fhem_dbh->disconnect();
@ -245,7 +272,7 @@ if($cfgDB_dbconn =~ m/pg:/i) {
sub cfgDB_FileUpdate($) { sub cfgDB_FileUpdate($) {
my ($filename) = @_; my ($filename) = @_;
my $fhem_dbh = _cfgDB_Connect; my $fhem_dbh = _cfgDB_Connect;
my $id = $fhem_dbh->selectrow_array("SELECT filename from fhemfilesave where filename = '$filename'"); my $id = $fhem_dbh->selectrow_array("SELECT filename from fhembinfilesave where filename = '$filename'");
$fhem_dbh->disconnect(); $fhem_dbh->disconnect();
if($id) { if($id) {
_cfgDB_Fileimport($filename,1) if $id; _cfgDB_Fileimport($filename,1) if $id;
@ -328,7 +355,11 @@ if($cfgDB_dbconn =~ m/pg:/i) {
$t = localtime; $t = localtime;
$out = "#created $t"; $out = "#created $t";
push @rowList, $out; push @rowList, $out;
foreach (@rowList) { _cfgDB_InsertLine($fhem_dbh, $uuid, $_); } my $counter = 0;
foreach (@rowList) {
_cfgDB_InsertLine($fhem_dbh, $uuid, $_, $counter);
$counter++;
}
$fhem_dbh->commit(); $fhem_dbh->commit();
$fhem_dbh->disconnect(); $fhem_dbh->disconnect();
my $maxVersions = AttrVal('configdb','maxversions',0); my $maxVersions = AttrVal('configdb','maxversions',0);
@ -412,7 +443,7 @@ if($cfgDB_dbconn =~ m/pg:/i) {
sub cfgDB_Read99() { sub cfgDB_Read99() {
my $ret; my $ret;
my $fhem_dbh = _cfgDB_Connect; my $fhem_dbh = _cfgDB_Connect;
my $sth = $fhem_dbh->prepare( "SELECT filename FROM fhemfilesave WHERE filename like '%/99_%.pm' group by filename" ); my $sth = $fhem_dbh->prepare( "SELECT filename FROM fhembinfilesave WHERE filename like '%/99_%.pm' group by filename" );
$sth->execute(); $sth->execute();
while (my $line = $sth->fetchrow_array()) { while (my $line = $sth->fetchrow_array()) {
$line =~ m,^(.*)/([^/]*)$,; # Split into dir and file $line =~ m,^(.*)/([^/]*)$,; # Split into dir and file
@ -427,14 +458,11 @@ if($cfgDB_dbconn =~ m/pg:/i) {
# return SVN Id from file stored in database # return SVN Id from file stored in database
sub cfgDB_Fileversion($$) { sub cfgDB_Fileversion($$) {
my ($file,$ret) = @_; my ($file,$ret) = @_;
my $fhem_dbh = _cfgDB_Connect; my ($err,@in) = cfgDB_FileRead($file);
my $id = $fhem_dbh->selectrow_array("SELECT line from fhemfilesave where filename = '$file' and line like '%\$Id:%'"); foreach(@in){ $ret = $_ if($_ =~ m/# \$Id:/); }
$fhem_dbh->disconnect();
$ret = ($id) ? $id : "$file - no SVN Id found!";
return $ret; return $ret;
} }
################################################## ##################################################
# Basic functions needed for DB configuration # Basic functions needed for DB configuration
# but not called from fhem.pl directly # but not called from fhem.pl directly
@ -452,11 +480,11 @@ sub _cfgDB_Connect {
} }
# add configuration entry into fhemconfig # add configuration entry into fhemconfig
sub _cfgDB_InsertLine($$$) { sub _cfgDB_InsertLine($$$$) {
my ($fhem_dbh, $uuid, $line) = @_; my ($fhem_dbh, $uuid, $line, $counter) = @_;
my ($c,$d,$p1,$p2) = split(/ /, $line, 4); my ($c,$d,$p1,$p2) = split(/ /, $line, 4);
my $sth = $fhem_dbh->prepare('INSERT INTO fhemconfig values (?, ?, ?, ?, ?, ?)'); my $sth = $fhem_dbh->prepare('INSERT INTO fhemconfig values (?, ?, ?, ?, ?, ?)');
$sth->execute($c, $d, $p1, $p2, -1, $uuid); $sth->execute($c, $d, $p1, $p2, $counter, $uuid);
return; return;
} }
@ -483,7 +511,7 @@ sub _cfgDB_ReadCfg(@) {
# using a join would be much nicer, but does not work due to sort of join's result # using a join would be much nicer, but does not work due to sort of join's result
my $uuid = $fhem_dbh->selectrow_array('SELECT versionuuid FROM fhemversions WHERE version = 0'); my $uuid = $fhem_dbh->selectrow_array('SELECT versionuuid FROM fhemversions WHERE version = 0');
$sth = $fhem_dbh->prepare( "SELECT * FROM fhemconfig WHERE versionuuid = '$uuid' and device <>'configdb'" ); $sth = $fhem_dbh->prepare( "SELECT * FROM fhemconfig WHERE versionuuid = '$uuid' and device <>'configdb' order by version" );
$sth->execute(); $sth->execute();
while (@line = $sth->fetchrow_array()) { while (@line = $sth->fetchrow_array()) {
@ -611,10 +639,10 @@ sub _cfgDB_Info {
push @r, $l; push @r, $l;
# count files stored in database # count files stored in database
$row = $fhem_dbh->selectall_arrayref("SELECT filename from fhemfilesave group by filename"); # $row = $fhem_dbh->selectall_arrayref("SELECT filename from fhemfilesave group by filename");
$count = @$row; # $count = @$row;
$row = $fhem_dbh->selectall_arrayref("SELECT filename from fhembinfilesave group by filename"); $row = $fhem_dbh->selectall_arrayref("SELECT filename from fhembinfilesave group by filename");
$count += @$row; $count = @$row;
$count = ($count)?$count:'No'; $count = ($count)?$count:'No';
$f = ("$count" ne '1') ? "s" : ""; $f = ("$count" ne '1') ? "s" : "";
$row = " filesave: $count file$f stored in database"; $row = " filesave: $count file$f stored in database";
@ -775,7 +803,7 @@ sub _cfgDB_AttrTypeSet($$){
sub _cfgDB_Filefind($) { sub _cfgDB_Filefind($) {
my ($filename) = @_; my ($filename) = @_;
my $fhem_dbh = _cfgDB_Connect; my $fhem_dbh = _cfgDB_Connect;
my @dbtable = ('fhemfilesave','fhembinfilesave'); my @dbtable = ('fhembinfilesave');
my $retfile; my $retfile;
foreach (@dbtable) { foreach (@dbtable) {
$retfile = $_; $retfile = $_;
@ -790,14 +818,14 @@ sub _cfgDB_Filefind($) {
# delete file from database # delete file from database
sub _cfgDB_Filedelete($) { sub _cfgDB_Filedelete($) {
my ($filename) = @_; my ($filename) = @_;
my $dbtable = _cfgDB_Filefind($filename); # my $dbtable = _cfgDB_Filefind($filename);
return "File $filename not found in database." if(!$dbtable); # return "File $filename not found in database." if(!$dbtable);
my $fhem_dbh = _cfgDB_Connect; my $fhem_dbh = _cfgDB_Connect;
my $ret = $fhem_dbh->do("delete from $dbtable where filename = '$filename'"); my $ret = $fhem_dbh->do("delete from fhembinfilesave where filename = '$filename'");
$fhem_dbh->commit(); $fhem_dbh->commit();
$fhem_dbh->disconnect(); $fhem_dbh->disconnect();
if($ret > 0) { if($ret > 0) {
$ret = "File $filename deleted from database ($ret lines)"; $ret = "File $filename deleted from database.";
} else { } else {
$ret = "File $filename not found in database."; $ret = "File $filename not found in database.";
} }
@ -841,32 +869,8 @@ sub _cfgDB_Fileexport($) {
return "$counter $sunit written from database into file $filename"; return "$counter $sunit written from database into file $filename";
} }
# import text-file into database # import file into database
sub _cfgDB_Fileimport($;$) { sub _cfgDB_binFileimport($$;$) {
my ($filename,$doDelete) = @_;
$doDelete = (defined($doDelete)) ? 1 : 0;
my $counter = 0;
my $fhem_dbh = _cfgDB_Connect;
$fhem_dbh->do("delete from fhemfilesave where filename = '$filename'");
my $sth = $fhem_dbh->prepare('INSERT INTO fhemfilesave values (?, ?)');
open (in,"<$filename") || die $!;
while (<in>){
$counter++;
my $line = $_;
$line =~ s/\n//;
# my $line = substr($_,0,length($_)-1);
$sth->execute($filename, $line);
}
close in;
$sth->finish();
$fhem_dbh->commit();
$fhem_dbh->disconnect();
unlink($filename) if($attr{configdb}{deleteimported} || $doDelete );
return "$counter lines written from file $filename to database";
}
# import bin-file into database
sub _cfgDB_binFileimport($;$) {
my ($filename,$filesize,$doDelete) = @_; my ($filename,$filesize,$doDelete) = @_;
$doDelete = (defined($doDelete)) ? 1 : 0; $doDelete = (defined($doDelete)) ? 1 : 0;
@ -894,7 +898,7 @@ sub _cfgDB_Filelist(;$) {
"------------------------------------------------------------\n"; "------------------------------------------------------------\n";
$ret = "" if $notitle; $ret = "" if $notitle;
my $fhem_dbh = _cfgDB_Connect; my $fhem_dbh = _cfgDB_Connect;
my @dbtable = ('fhemfilesave','fhembinfilesave'); my @dbtable = ('fhembinfilesave');
foreach (@dbtable) { foreach (@dbtable) {
my $sth = $fhem_dbh->prepare( "SELECT filename FROM $_ group by filename order by filename" ); my $sth = $fhem_dbh->prepare( "SELECT filename FROM $_ group by filename order by filename" );
$sth->execute(); $sth->execute();
@ -907,6 +911,40 @@ sub _cfgDB_Filelist(;$) {
return $ret; return $ret;
} }
#######################################
#
# temporary inserted funktions
# for data migration
#
#######################################
sub _cfgDB_move() {
my $fhem_dbh = _cfgDB_Connect;
my $sth = $fhem_dbh->prepare( "select filename from fhemfilesave group by filename" );
$sth->execute();
while (my @file = $sth->fetchrow_array()) {
my @in = ();
Log3(undef, 1, "configDB: Moving $file[0] to binary filesave");
my $sth2 = $fhem_dbh->prepare( "SELECT * FROM fhemfilesave WHERE filename LIKE '$file[0]'" );
$sth2->execute();
while (my @line = $sth2->fetchrow_array()) {
push @in, "$line[1]";
}
$sth2->finish();
$fhem_dbh->do("delete from fhembinfilesave where filename LIKE '$file[0]'");
$fhem_dbh->commit();
my $content = join("\n", @in);
my $sth3 = $fhem_dbh->prepare( 'INSERT INTO fhembinfilesave values (?, ?)' );
$sth3->execute($file[0],$content);
$sth3->finish();
$fhem_dbh->do("delete from fhemfilesave where filename = '$file[0]'");
$fhem_dbh->commit();
}
$fhem_dbh->do("drop table fhemfilesave");
$fhem_dbh->commit();
$fhem_dbh->disconnect();
return;
}
####################################### #######################################
# #
@ -934,7 +972,7 @@ sub _cfgDB_Writefile($$) {
sub _cfgDB_Updatefile($) { sub _cfgDB_Updatefile($) {
my ($filename) = @_; my ($filename) = @_;
my $fhem_dbh = _cfgDB_Connect; my $fhem_dbh = _cfgDB_Connect;
my $id = $fhem_dbh->selectrow_array("SELECT filename from fhemfilesave where filename = '$filename'"); my $id = $fhem_dbh->selectrow_array("SELECT filename from fhembinfilesave where filename = '$filename'");
$fhem_dbh->disconnect(); $fhem_dbh->disconnect();
if($id) { if($id) {
_cfgDB_Fileimport($filename,1) if $id; _cfgDB_Fileimport($filename,1) if $id;