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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69

<?php
#TODO: test on sqlite

if ($adapter=="pdo_mysql")
{
    try {
        Jf::$Db=new PDO("mysql:host={$host};dbname={$dbname}",$user,$pass);
    }
    catch (PDOException $e)
    {
        if ($e->getCode()==1049) //database not found
            installPdoMysql($host,$user,$pass,$dbname);
        else
            throw $e;
    }
}
elseif ($adapter=="pdo_sqlite")
{
    if (!file_exists($dbname))
        installPdoSqlite($host,$user,$pass,$dbname);
    else
        Jf::$Db=new PDO("sqlite:{$dbname}",$user,$pass);
//         Jf::$Db=new PDO("sqlite::memory:",$user,$pass);
}
else # default to mysqli
{
    @Jf::$Db=new mysqli($host,$user,$pass,$dbname);
    if(jf::$Db->connect_errno==1049)
        installMysqli($host,$user,$pass,$dbname);
}
function getSqls($dbms)
{
    $sql=file_get_contents(dirname(dirname(dirname(__DIR__))) . "/database/{$dbms}.sql");
    $sql=str_replace("PREFIX_",Jf::tablePrefix(),$sql);
    return explode(";",$sql);
}
function installPdoMysql($host,$user,$pass,$dbname)
{
    $sqls=getSqls("mysql");
    $db=new PDO("mysql:host={$host};",$user,$pass);
    $db->query("CREATE DATABASE {$dbname}");
    $db->query("USE {$dbname}");
    if (is_array($sqls))
        foreach ($sqls as $query)
        $db->query($query);
    Jf::$Db=new PDO("mysql:host={$host};dbname={$dbname}",$user,$pass);
    Jf::$Rbac->reset(true);
}
function installPdoSqlite($host,$user,$pass,$dbname)
{
    Jf::$Db=new PDO("sqlite:{$dbname}",$user,$pass);
    $sqls=getSqls("sqlite");
    if (is_array($sqls))
        foreach ($sqls as $query)
        Jf::$Db->query($query);
    Jf::$Rbac->reset(true);
}
function installMysqli($host,$user,$pass,$dbname)
{
    $sqls=getSqls("mysql");
    $db=new mysqli($host,$user,$pass);
    $db->query("CREATE DATABASE {$dbname}");
    $db->select_db($dbname);
    if (is_array($sqls))
        foreach ($sqls as $query)
        $db->query($query);
    Jf::$Db=new mysqli($host,$user,$pass,$dbname);
    Jf::$Rbac->reset(true);
}