forked from xFFFFF/Gekko-Datasets
-
Notifications
You must be signed in to change notification settings - Fork 0
/
check_db.pl
41 lines (36 loc) · 1.43 KB
/
check_db.pl
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
# Its script scaning all databases for missed candles, and add command to import to sh file.
#!/usr/bin/perl -w
use strict;
use DBI;
use POSIX qw(strftime);
use File::chdir;
open my $fh, '<', 'pairs.conf';
chomp(my @pairs = <$fh>);
close $fh;
foreach (@pairs) {
my @exchange = split /-/, $_;
my $dbh = DBI->connect("dbi:SQLite:dbname=$_/history/$exchange[0]_0.1.db", "", "", { RaiseError => 0 });
my $stmt = qq(SELECT name FROM sqlite_master WHERE type='table' AND name LIKE '%candles%';);
my $sth = $dbh->prepare( $stmt );
my $rv = $sth->execute();
while (my @table = $sth->fetchrow_array()) {
my @table2 = split /_/, $table[0];
my $stmt = qq(SELECT start FROM @table ORDER BY start ASC;);
my $sth = $dbh->prepare( $stmt );
my $rv = $sth->execute() or die $DBI::errstr;
my $fmt='%Y-%m-%d %H:%M:%S';
my $expected;
while (my @row=$sth->fetchrow_array()) {
if (defined $expected && $row[0] != $expected) {
my $f = sprintf "%s", strftime($fmt, gmtime ($expected));
my $t = sprintf "%s", strftime($fmt, gmtime ($row[0]+60));
print "perl backtest.pl -i -p $exchange[0]:$table2[1]:$table2[2] -f $f -t $t\n";
local $CWD = "$_";
unlink 'backtest_missed.sh' if -e 'backtest_missed.sh';
print `echo "perl backtest.pl -i -p $exchange[0]:$table2[1]:$table2[2] -f \'$f\' -t \'$t\'" >> backtest_missed.sh`;
local $CWD = "..";
}
$expected=$row[0]+60
}
}
}