Действия с базами данных

env = luasql.mysql()

MySQL = luasql.mysql();

Подключение к источнику данных указанного в sourcename используя username и password, если они заданы. Sourcename (имя источника) может изменяться соответственно типа каждой базы данных.
Для MySQL и PostgreSQL, также можно предоставлять дополнительные hostname и port:


Возвращает объект соединения, который представляет соединение с источником данных.

Закрывает среду баз данных. Успешно только если вначале закрываются все соединения, относящиеся к нему.

Возвращает истину (true) в случае успеха. Возвращает ложь (false), если объект уже закрыт.

Закрывает соединение. Успещно только в случае, если все курсоры, относящиеся к нему, были закрыты, а соединение осталось открытым.

Возвращает истину (true) в случае успеха.

Фиксирует (завершает) текущую транзакцию. Это свойство может не работать в системах баз данных, которые не выполняют транзакции.

Возвращает истину (true) в случае успеха. Возвращает ложь (false), если операция не может быть выполнена или не осуществлена.

Выполняет данную SQL инструкцию.

Если есть результат, возвращает объект курсора или, в другом случае, число рядов, затронутых командой.

Откат текущей транзакции. Это свойство может не работать в системах баз данных, которые не выполняют транзакции.

Возвращает истину (true) в случае успеха. Возвращает ложь (false), если операция не может быть выполнена или не осуществлена.

Включает или выключает режим "auto commit". Это свойство может не работать в системах баз данных, которые не выполняют транзакции.

Возвращает истину (true) в случае успеха. Возвращает ложь (false), если операция не может быть выполнена или не осуществлена.

Закрывает курсор.

Возвращает истину (true) в случае успеха. Возвращает ложь (false), если объект уже закрыт.

Возвращает следующую строку результата.

Если инструкция fetch вызвана без параметров, результаты будут возвращены непосредственно вызывающему. Если инструкция fetch вызвана с таблицей, результаты будут копированы в эту таблицу и измененная таблица будет возвращена. В этом случае, может быть использован дополнительный параметр modestring. Это просто строка, показывающая как должна быть построена результирующая таблица. Режим строки может содержать:

Числовые индексы являются позициями полей в инструкции SELECT; алфавитно-числовые индексы являются именами полей.

Дополнительный табличный параметр - это таблица, которая используется для хранения следующего ряда. Это позволяет использовать уникальную таблицу для множества выборок, которая может повысить общую производительность.

Гарантированных типов результата нет: они могут быть конвертированы драйвером, а могут и нет, в соответствующие Lua типы. В текущей реализации драйвера PostgreSQL и MySQL возвращают все значения как строки, в то время как драйверы ODBC и Oracle конвертируют их в Lua типы.

Возвращает таблицу данных, как показано выше, или нуль (ничто - nil), если рядов больше нет. Отметьте, что это действие может возвратить нуль (ничто - nil) в качестве истинного результата.

Возвращает таблицу имен столбцов.

Возвращает таблицу типов столбцов.

Возвращает количество строк в результате запроса.

SQLite3Connection, err = SQLite3:connect("test-db");

if not SQLite3Connection and err then
    Dialog.Message("Error", err);
end

SQLite3Connection:execute("DROP TABLE people");
SQLite3Connection:execute("CREATE TABLE people(name varchar(50), email varchar(50))");

-- add a few elements from a Lua table into the database table
-- добавляем несколько элементов из таблицы Lua в таблицу базы данных
list = {
    {name = "Jose das Couves", email = "jose@couves.com"},
    {name = "Manoel Joaquim", email = "manoel.joaquim@cafundo.com"},
    {name = "Maria das Dores", email = "maria@dores.com"}
};

for i, p in pairs(list) do
    SQLite3Connection:execute(string.format("INSERT INTO people VALUES ('%s', '%s')", p.name, p.email));
end

-- retrieve a cursor
-- получаем курсор
SQLite3Cursor = SQLite3Connection:execute("SELECT name, email from people");

-- print all the rows
-- печатаем все строки (ряды)
row = SQLite3Cursor:fetch({}, "a");
local s = "";
while row do
    s = s .. (string.format("Name: %s, Email: %s\n", row.name, row.email));

    -- get the next row, reusing the same table
    row = SQLite3Cursor:fetch(row, "a");
end
Dialog.Message("The 'people' table contains", s);

-- close everything
-- закрываем все
SQLite3Cursor:close();
SQLite3Connection:close();

Для MySQL, вышеупомянутый пример нужно немного изменить, так как MySQL в настоящее время не поддерживает дополнительные параметры fetch().

-- print all the rows
-- печатаем все строки (ряды)
local s = "";
for i = 1, MySQLCursor:numrows() do
    local name, email = MySQLCursor:fetch();
    s = s .. "Name: " .. name .. ", Email: " .. email .. "\n";
end

Dialog.Message("The 'people' table contains", s);

Также можно выполнить итерацию результатов при помощи функции итератора:

function rows(connection, sql_statement)
    local cursor = assert(connection:execute(sql_statement));
    return function()
        return cursor:fetch()
    end
end

MySQLConnection = MySQL:connect("mydatabase");
local s = "";
for name, email in rows(MySQLConnection, "select * from contacts") do
    s = s .. string.format("Name: %s, Email: %s\n", name, email);
end

Dialog.Message("The 'people' table contains", s);