mirror of
https://github.com/fusionpbx/fusionpbx.git
synced 2026-01-13 12:08:24 +00:00
423e0ab503
To configure use `database.backend` option
It can be a string value like `database.backend = 'native'`.
So it will always use same backend.
Or it can be a table value like
```Lua
database.backend = {
main = 'native';
base64 = '';
}
```
Role `database.backend.main` is predefined and it equal to `native` if not set.
If there no role when Database class creates or role unknown role `main` is used
```Lua
dbh = Database.new('system') -- uses role `main`
dbh = Database.new('system', 'main') -- same as previews
dbh = Database.new('system', 'base64') -- uses role `base64`
dbh = Database.new('system', 'test') -- uses role `main`
```
63 lines
1.3 KiB
Lua
63 lines
1.3 KiB
Lua
--
|
|
-- Native backend to FusionPBX database class
|
|
--
|
|
|
|
local log = require "resources.functions.log".database
|
|
|
|
assert(freeswitch, "Require FreeSWITCH environment")
|
|
|
|
-----------------------------------------------------------
|
|
local FsDatabase = {} do
|
|
|
|
require "resources.functions.file_exists"
|
|
require "resources.functions.database_handle"
|
|
|
|
FsDatabase.__index = FsDatabase
|
|
FsDatabase._backend_name = 'native'
|
|
|
|
function FsDatabase.new(name)
|
|
local dbh = assert(name)
|
|
if type(name) == 'string' then
|
|
if name == 'switch' and file_exists(database_dir.."/core.db") then
|
|
dbh = freeswitch.Dbh("sqlite://"..database_dir.."/core.db")
|
|
else
|
|
dbh = database_handle(name)
|
|
end
|
|
end
|
|
assert(dbh:connected())
|
|
|
|
local self = setmetatable({
|
|
_dbh = dbh;
|
|
}, FsDatabase)
|
|
|
|
return self
|
|
end
|
|
|
|
function FsDatabase:query(sql, fn)
|
|
if fn then
|
|
return self._dbh:query(sql, fn)
|
|
end
|
|
return self._dbh:query(sql)
|
|
end
|
|
|
|
function FsDatabase:affected_rows()
|
|
if self._dbh then
|
|
return self._dbh:affected_rows()
|
|
end
|
|
end
|
|
|
|
function FsDatabase:release()
|
|
if self._dbh then
|
|
self._dbh:release()
|
|
self._dbh = nil
|
|
end
|
|
end
|
|
|
|
function FsDatabase:connected()
|
|
return self._dbh and self._dbh:connected()
|
|
end
|
|
|
|
end
|
|
-----------------------------------------------------------
|
|
|
|
return FsDatabase |