Skip to content

Latest commit

 

History

History
494 lines (385 loc) · 9.73 KB

API_DOCUMENTATION.md

File metadata and controls

494 lines (385 loc) · 9.73 KB
Raw

go-ibm_db API Documentation

Database APIs

APIs for creating and dropping Database using Go application

Database APIs

  1. .Open(drivername,ConnectionString)
  2. .Prepare(sqlquery)
  3. .Query(sqlquery)
  4. .Exec(sqlquery)
  5. .Begin()
  6. .Close()
  7. .Commit()
  8. .Rollback()
  9. .QueryRow(sqlquery)
  10. .Columns()
  11. .Next()
  12. .Scan(options)
  13. .Init(N,connStr)
  14. .SetConnMaxLifetime(N)

1) .Open(drivername,ConnectionString)

open a connection to database

  • connectionString - The connection string for your database.
  • For distributed platforms, the connection string is typically defined as: DATABASE=dbname;HOSTNAME=hostname;PORT=port;PROTOCOL=TCPIP;UID=username;PWD=passwd
var connStr = flag.String("conn", "HOSTNAME=hostname;PORT=port;DATABASE=dbname;UID=uid;PWD=Pass", "connection string")

func dboper() error {
	fmt.Println("connecting to driver")
	db, err := sql.Open("drivername", *connStr)
	if err != nil {
		return err
	}

	defer db.Close()
}

2) .Prepare(sqlquery)

Prepare a statement for execution

  • sql - SQL string to prepare

Returns a ‘statement’ object

func oper() error {
	fmt.Println("connecting to go-ibm_db")
	db, err := sql.Open("go-ibm_db", *connStr)
	if err != nil {
		return err
	}

	defer db.Close()

	st, err := db.Prepare("select * from ak")
	if err != nil {
		return err
	}

	rows, err := st.Query()
	if err != nil {
		return err
	}

	defer rows.Close()
}

3) .Query(sqlquery)

Issue a SQL query to the database

If the query is executed then it will return the rows or it will return error

func oper() error {
	fmt.Println("connecting to go-ibm_db")
	db, err := sql.Open("go-ibm_db", *connStr)
	if err != nil {
		return err
	}

	defer db.Close()

	rows, err := db.Query("select * from ak")
	if err != nil {
		return err
	}

	defer rows.Close()
}

4) .Exec(sqlquery)

Execute a prepared statement.

Only DML commands are performed. No data is returned back.

func oper() error {
	fmt.Println("connecting to go-ibm_db")
	db, err := sql.Open("go-ibm_db", *connStr)
	if err != nil {
		return err
	}

	defer db.Close()

	_, err = db.Exec("create table ghh(a int, b float, c double,  d char, e varchar(30))")
	if err != nil {
		return err
	}
}

5) .Begin()

Begin a transaction.

func oper() error {
	fmt.Println("connecting to go-ibm_db")
	db, err := sql.Open("go-ibm_db", *connStr)
	if err != nil {
		return err
	}

	defer db.Close()

	bg, err := db.Begin()
	if err != nil {
		return err
	}

	return nil
}

6) .Close()

Close the currently opened database.

func dboper() error {
	fmt.Println("connecting to go-ibm_db")
	db, err := sql.Open("go-ibm_db", *connStr)
	if err != nil {
		return err
	}

	defer db.Close()
}

7) .Commit()

Commit a transaction.

func oper() error {
	fmt.Println("connecting to go-ibm_db")
	db, err := sql.Open("go-ibm_db", *connStr)
	if err != nil {
		return err
	}

	defer db.Close()

	bg, err := db.Begin()
	if err != nil {
		return err
	}

	_, err = bg.Exec("create table ghh(a int,b float,c double,d char,e varchar(30))")
	if err != nil {
		return err
	}

	err = bg.Commit()
	if err != nil {
		return err
	}

	return nil
}

8) .Rollback()

Rollback a transaction.

func oper() error {
	fmt.Println("connecting to go-ibm_db")
	db, err := sql.Open("go-ibm_db", *connStr)
	if err != nil {
		return err
	}

	defer db.Close()
	bg, err := db.Begin()
	if err != nil {
		return err
	}

	_, err = bg.Exec("create table ghh(a int,b float,c double,d char,e varchar(30))")
	if err != nil {
		return err
	}

	err = bg.Rollback()
	if err != nil {
		return err
	}

	return nil
}

9) .QueryRow(sqlquery)

QueryRow executes a query that is expected to return at most one row. If there are more rows then it will scan first and discards the rest.

func oper() error {
	id := 123
	var username string
	err := db.QueryRow("SELECT name FROM ak WHERE id=?", id).Scan(&username)
	if err != nil {
		return err
	}

	fmt.Printf("Username is %s\n", username)
	return nil
}

10) .Columns()

Returns the column names.

Returns error if the rows are closed.

func oper() error {
	fmt.Println("connecting to database")
	db, err := sql.Open("go-ibm_db", *connStr)
	if err != nil {
		return err
	}

	defer db.Close()

	st, err := db.Prepare("select * from ak")
	if err != nil {
		return err
	}

	rows, err := st.Query()
	if err != nil {
		return err
	}

	defer rows.Close()
	name11 := make([]string, 1)
	name11, err = rows.Columns()
	fmt.Printf("%v", name11)
	return nil
}

11) .Next()

Prepares the next result row for reading with the scan api.

func oper() error {
	fmt.Println("connecting to database")
	db, err := sql.Open("go-ibm_db", *connStr)
	if err != nil {
		return err
	}
	defer db.Close()

	rows, err := db.Query()
	if err != nil {
		return err
	}
	defer rows.Close()

	for rows.Next() {
		var t string
		var x string
		err = rows.Scan(&t, &x)
		if err != nil {
			return err
		}

		fmt.Printf("%v %v\n", t, x)
	}

	return nil
}

12) .Scan(options)

copies the columns in the current row into the values pointed.

func oper() error {
	fmt.Println("connecting to database")
	db, err := sql.Open("go-ibm_db", *connStr)
	if err != nil {
		return err
	}
	defer db.Close()

	rows, err := db.Query()
	if err != nil {
		return err
	}
	defer rows.Close()

	for rows.Next() {
		var t string
		var x string
		err = rows.Scan(&t, &x)
		if err != nil {
			return err
		}

		fmt.Printf("%v %v\n", t, x)
	}
	return nil
}

13) .Init(N,connStr)

Initialize Pool with N no of active connections using supplied connection string. It is a synchronous API. We do not need an asynchronous version of this API.

  • N - No of connections to be initialized.
  • connStr - The connection string for your database
func oper() error {
        fmt.Println("connecting to database")

	var ret = pool.init(5, connStr)
	if ret != true {
		fmt.Println(ret)
	}

        db := pool.Open(connStr, "SetConnMaxLifetime=10")
	for i:=0; i<20; i++ {
		db := pool.Open(con, "SetConnMaxLifetime=10")
                if db != nil {
                        st, err := db.Prepare("select * from SAMPLE")
                        if err != nil {
                                fmt.Println("Error: ", err)
                        } else {
                                go func() {
                                        ExecQuery(st)
                                        db.Close()
                                }()
                        }
                }
        }

        time.Sleep(30*time.Second)
        pool.Release()
        return nil
}
func ExecQuery(st *sql.Stmt) error {
        res, err := st5.Query()
        if err != nil {
             fmt.Println(err)
        }
        cols, _ := res.Columns()

        fmt.Printf("%s    %s   %s     %s\n", cols[0], cols[1], cols[2], cols[3])
        defer res.Close()
        for res.Next() {
                    var t, x, m, n string
                    err = res.Scan(&t, &x, &m, &n)
                    fmt.Printf("%v  %v   %v  %v\n", t, x, m, n)
        }
        return nil
}

14) .SetConnMaxLifetime(T)

Set the maximum length of time a connection can held open before it is closed.

  • T - Maximum lenght of time the connection can held open.
func oper() error {
        fmt.Println("connecting to database")a

  	pool.SetConnMaxLifetime(10)
        ret := pool.Init(3, con)
        if ret != true {
		fmt.Println(ret)
        }
        return nil
}

Create and Drop Database APIs

.CreateDb(dbName, connectionString, options...)

To create a database (dbName) through Go application.

  • dbName - The database name.
  • connectionString - The connection string for your database instance.
  • options - OPTIONAL - string type
    • codeset - Database code set information.
    • mode - Database logging mode (applicable only to "IDS data servers").
package main

import (
	"database/sql"
	"fmt"
	"github.com/ibmdb/go_ibm_db"
)

func main() {
	var conStr = "HOSTNAME=hostname;PORT=port;PROTOCOL=TCPIP;UID=username;PWD=password"
	var dbName = "Goo"
	res, err := go_ibm_db.CreateDb(dbName, conStr)
	// CreateDb with options
	//go_ibm_db.CreateDb(dbName, conStr, "codeset=UTF-8", "mode=value")
	if err != nil {
		fmt.Println("Error while creating database ", err)
	}
	if res {
		fmt.Println("Database created successfully.")
		conStr = conStr + ";" + "DATABASE=" + dbName
		db, err := sql.Open("go_ibm_db", conStr)
		if err = db.Ping(); err != nil {
			fmt.Println("Ping Error: ", err)
		}
		defer db.Close()
		fmt.Println("Connected: ok")
	}
}

.DropDb(dbName, connectionString)

To drop a database (dbName) through Go application.

  • dbName - The database name.
  • connectionString - The connection string for your database instance.
package main

import (
	"fmt"
	"github.com/ibmdb/go_ibm_db"
)

func main() {
	var conStr = "HOSTNAME=hostname;PORT=port;PROTOCOL=TCPIP;UID=username;PWD=password"
	var dbName = "Goo"
	res, err := go_ibm_db.DropDb(dbName, conStr)
	if err != nil {
		fmt.Println("Error while dropping database ", err)
	}
	if res {
		fmt.Println("Database dropped successfully.")
	}
}