DBI.lua

Fri, 05 Dec 2008 09:20:31 +0000

author
nrich@ii.net
date
Fri, 05 Dec 2008 09:20:31 +0000
changeset 16
318e5dfd03b8
parent 14
98192b7d4e89
child 17
21c4feaeafe7
permissions
-rw-r--r--

Bugfix: fix comment in connection

1
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
1 #!/usr/bin/lua
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
2
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
3 module('DBI', package.seeall)
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
4
2
c4f02fc67e5a Cleanup and commenting
nrich@ii.net
parents: 1
diff changeset
5 -- Driver to module mapping
1
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
6 local name_to_module = {
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
7 MySQL = 'dbdmysql',
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
8 PostgreSQL = 'dbdpostgresql',
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
9 SQLite3 = 'dbdsqlite3',
14
98192b7d4e89 Add DB2 driver module.
nrich@ii.net
parents: 4
diff changeset
10 DB2 = 'dbddb2',
1
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
11 }
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
12
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
13 local string = require('string')
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
14
2
c4f02fc67e5a Cleanup and commenting
nrich@ii.net
parents: 1
diff changeset
15 -- Returns a list of available drivers
c4f02fc67e5a Cleanup and commenting
nrich@ii.net
parents: 1
diff changeset
16 -- based on run time loading
1
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
17 local function available_drivers()
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
18 local available = {}
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
19
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
20 for driver, modulefile in pairs(name_to_module) do
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
21 local m, err = pcall(require, modulefile)
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
22
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
23 if m then
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
24 table.insert(available, driver)
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
25 end
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
26 end
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
27
2
c4f02fc67e5a Cleanup and commenting
nrich@ii.net
parents: 1
diff changeset
28 -- no drivers available
1
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
29 if table.maxn(available) < 1 then
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
30 return '(None)'
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
31 end
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
32
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
33 return table.concat(available, ',')
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
34 end
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
35
2
c4f02fc67e5a Cleanup and commenting
nrich@ii.net
parents: 1
diff changeset
36 -- High level DB connection function
c4f02fc67e5a Cleanup and commenting
nrich@ii.net
parents: 1
diff changeset
37 -- This should be used rather than DBD.{Driver}.New
1
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
38 function Connect(driver, name, username, password, host, port)
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
39 local modulefile = name_to_module[driver]
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
40
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
41 if not modulefile then
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
42 error(string.format("Driver '%s' not found. Available drivers are: %s", driver, available_drivers()))
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
43 end
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
44
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
45 local m, err = pcall(require, modulefile)
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
46
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
47 if not m then
2
c4f02fc67e5a Cleanup and commenting
nrich@ii.net
parents: 1
diff changeset
48 -- cannot load the module, we cannot continue
1
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
49 error(string.format('Cannot load driver %s. Available drivers are: %s', driver, available_drivers()))
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
50 end
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
51
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
52 local class_str = string.format('DBD.%s.Connection', driver)
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
53
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
54 local connection_class = package.loaded[class_str]
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
55
2
c4f02fc67e5a Cleanup and commenting
nrich@ii.net
parents: 1
diff changeset
56 -- Calls DBD.{Driver}.New(...)
1
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
57 return connection_class.New(name, username, password, host, port)
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
58 end
408291a6eb3e Initial import.
nrich@ii.net
parents:
diff changeset
59
4
c50b0e6f25d6 Clean up error messages for consistency.
nrich@ii.net
parents: 3
diff changeset
60 -- Help function to do prepare and execute in
c50b0e6f25d6 Clean up error messages for consistency.
nrich@ii.net
parents: 3
diff changeset
61 -- a single step
3
b61020ca4753 Cleanup and 'assert' error handling.
nrich@ii.net
parents: 2
diff changeset
62 function Do(dbh, sql, ...)
b61020ca4753 Cleanup and 'assert' error handling.
nrich@ii.net
parents: 2
diff changeset
63 local sth,err = dbh:prepare(sql)
b61020ca4753 Cleanup and 'assert' error handling.
nrich@ii.net
parents: 2
diff changeset
64
b61020ca4753 Cleanup and 'assert' error handling.
nrich@ii.net
parents: 2
diff changeset
65 if not sth then
b61020ca4753 Cleanup and 'assert' error handling.
nrich@ii.net
parents: 2
diff changeset
66 return false, err
b61020ca4753 Cleanup and 'assert' error handling.
nrich@ii.net
parents: 2
diff changeset
67 end
b61020ca4753 Cleanup and 'assert' error handling.
nrich@ii.net
parents: 2
diff changeset
68
b61020ca4753 Cleanup and 'assert' error handling.
nrich@ii.net
parents: 2
diff changeset
69 return sth:execute(...)
b61020ca4753 Cleanup and 'assert' error handling.
nrich@ii.net
parents: 2
diff changeset
70 end

mercurial