db

TinyPHP-DB

package main

import (
	"github.com/kimkit/tinyphp"
	"github.com/kimkit/tinyphp-db"
	"github.com/kimkit/tinyphp/std"
)

func init() {
    db.RegisterDB()
    db.AddDB("local", &db.DBConfig{DriverName: "mysql", DSN: "root:123456@tcp(localhost)/"})
}

func main() {
	src := `
$db = get_db("local")->ok();
$list = $db->query("show databases");
var_dump(json_encode($list));

$db->exec("drop database if exists a");
$db->exec("create database a");
$db->exec("create table a.b (c int, d int)");
$rowsAffected = $db->exec("insert into a.b values (?, ?)", 1, 2)->ok();
var_dump($rowsAffected);
$lastInsertId = $db->insert("insert into a.b values (?, ?)", 3, 4)->ok();
var_dump($lastInsertId);
$list = $db->query("select * from a.b");
var_dump(json_encode($list));

$tx = $db->begin()->ok();
$list = $tx->query("select * from a.b");
var_dump(json_encode($list));
$rowsAffected = $tx->exec("insert into a.b values (?, ?)", 1, 2)->ok();
var_dump($rowsAffected);
$lastInsertId = $tx->insert("insert into a.b values (?, ?)", 3, 4)->ok();
var_dump($lastInsertId);
var_dump($tx->commit()->ok()); // $tx->rollback();
    `
	stmts, err := tinyphp.ParseSrc(src)
	if err != nil {
		panic(err)
	}
	store := tinyphp.NewStore(std.Funcs, std.Methods)
	if _, err := tinyphp.RunStmts(stmts, store); err != nil {
		panic(err)
	}
}