mirror of
https://github.com/ultimatepp/ultimatepp.git
synced 2026-05-15 14:16:07 -06:00
46 lines
1.1 KiB
C++
46 lines
1.1 KiB
C++
#include <MySql/MySql.h>
|
|
|
|
using namespace Upp;
|
|
|
|
#define SCHEMADIALECT <MySql/MySqlSchema.h>
|
|
#define MODEL <SQL_MySql/schema.sch>
|
|
#include <Sql/sch_header.h>
|
|
#include <Sql/sch_source.h>
|
|
#include <Sql/sch_schema.h>
|
|
|
|
CONSOLE_APP_MAIN
|
|
{
|
|
MySqlSession session;
|
|
// edit the connection parameters if necessary
|
|
if(session.Connect("root", "Passw0rd", "test")) {
|
|
Cout() << "Connected\n";
|
|
SQL = session;
|
|
|
|
SqlSchema sch(MY_SQL);
|
|
All_Tables(sch);
|
|
// create the table if necessary
|
|
SqlPerformScript(sch.Upgrade());
|
|
SqlPerformScript(sch.Attributes());
|
|
SQL.ClearError();
|
|
|
|
try {
|
|
// insert some random data
|
|
SQL & Insert(TEST_TABLE)(VALUE, Uuid::Create().ToString());
|
|
// fetch some data
|
|
Sql sql;
|
|
sql * Select(ID, VALUE).From(TEST_TABLE)
|
|
.OrderBy(Descending(ID))
|
|
.Limit(5);
|
|
while(sql.Fetch())
|
|
Cout() << AsString(sql[0]) << ": " << AsString(sql[VALUE]) << "\n";
|
|
}
|
|
catch(SqlExc &ex) {
|
|
Cerr() << "ERROR: " << ex << "\n";
|
|
SetExitCode(1);
|
|
}
|
|
}
|
|
else {
|
|
Cerr() <<"ERROR: Unable to connect to database\n";
|
|
SetExitCode(1);
|
|
}
|
|
}
|