DBDriver

package module
v0.0.0-...-36c0a8b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 1, 2020 License: MIT Imports: 8 Imported by: 0

README

Package collectlinks is useful for only one task:

Given a response from http.Get it will use parse the page and return to you a slice of all the href links found.

Usage:

package main

import (
  "fmt"
  _ "github.com/go-sql-driver/mysql"
  "github.com/lichv/go-dbDriver/DBDriver"
)

func main() {
  postgreDriver := DBDriver.InitPostgreDriver("localhost",5432,"adminb","123456","data")
  insert, err2 := postgreDriver.Insert("article", map[string]interface{}{"title": "测试一个标题", "content": "测试一个内容"})
  if err2 != nil {
    fmt.Println(err2)
  }
  fmt.Println(insert)
}

Running that will output:

[http://twitter.com/thebarrytone http://txti.es]

Documentation

Overview

Package collectlinks is useful for only one task: 

Given a response from http.Get it will use parse the page and
return to you a slice of all the href links found.

Usage: 

package main

import (
	"fmt"
	_ "github.com/go-sql-driver/mysql"
	"github.com/lichv/go-dbDriver/DBDriver"
)

func main() {
	postgreDriver := DBDriver.InitPostgreDriver("localhost",5432,"adminb","123456","data")
	insert, err2 := postgreDriver.Insert("article", map[string]interface{}{"title": "测试一个标题", "content": "测试一个内容"})
	if err2 != nil {
		fmt.Println(err2)
	}
	fmt.Println(insert)
}

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CheckOrderBy 

func CheckOrderBy(orderBy string) bool

func GetInsertSql 

func GetInsertSql(tableName string, post map[string]interface{}, driverName string) (string, error)

func GetUpdateSQL 

func GetUpdateSQL(tableName string, post map[string]interface{}, query map[string]interface{}, driverName string) (string, error)

func IsSimpleType 

func IsSimpleType(a interface{}) bool

func NoSqlQuoteNeeded 

func NoSqlQuoteNeeded(a interface{}) bool

func ReturnListFromResults 

func ReturnListFromResults(rows *sql.Rows) ([]map[string]interface{}, error)

func ReturnMapFromResult 

func ReturnMapFromResult(rows *sql.Rows) (map[string]interface{}, error)

func SqlQuote 

func SqlQuote(x interface{}) string

func WhereFromQuery 

func WhereFromQuery(query map[string]interface{}) (string, error)

Types

type DBDriver 

type DBDriver interface {
	Open() error
	Close() error
	Query(string, ...interface{}) (*sql.Rows, error)
	Exec(string, ...interface{}) (sql.Result, error)
	ShowSql() error
	HideSql() error
	QueryMap(string, map[string]interface{}) (*sql.Rows, error)
	FindById(string, int64) (*sql.Rows, error)
	FindOne(string, map[string]interface{}, string) (*sql.Rows, error)
	Exists(string, map[string]interface{}) bool
	Count(string, map[string]interface{}) (int64, error)
	GetList(string, map[string]interface{}, string) (*sql.Rows, error)
	GetPage(string, map[string]interface{}, string, int64, int64) (*sql.Rows, *Page, error)
	Insert(string, map[string]interface{}) (int64, error)
	Update(string, map[string]interface{}, map[string]interface{}) (int64, error)
	Save(string, map[string]interface{}) (int64, error)
	Delete(string, map[string]interface{}) (int64, error)
	DeleteById(string, int64) (int64, error)
	Begin() error
	RollBack() error
	Commit() error
	QueryTX(string, ...interface{}) (*sql.Rows, error)
	ExecTX(string, ...interface{}) (sql.Result, error)
}

func CreateDBDriver 

func CreateDBDriver(driverName string, host string, port int, user, password, dbname string) DBDriver

type MysqlDriver 

type MysqlDriver struct {
	DriverName     string
	DataSourceName string
	Show           bool
	DB             *sql.DB
	SQLTX          *sql.Tx
}

func InitMysqlDriver 

func InitMysqlDriver(host string, port int, user, password, dbname string) *MysqlDriver

func (*MysqlDriver) Begin 

func (db *MysqlDriver) Begin() error

func (*MysqlDriver) Close 

func (db *MysqlDriver) Close() error

func (*MysqlDriver) Commit 

func (db *MysqlDriver) Commit() error

func (*MysqlDriver) Count 

func (db *MysqlDriver) Count(tableName string, query map[string]interface{}) (int64, error)

func (*MysqlDriver) Delete 

func (db *MysqlDriver) Delete(tableName string, query map[string]interface{}) (int64, error)

func (*MysqlDriver) DeleteById 

func (db *MysqlDriver) DeleteById(tableName string, id int64) (int64, error)

func (*MysqlDriver) Exec 

func (db *MysqlDriver) Exec(query string, args ...interface{}) (sql.Result, error)

func (*MysqlDriver) ExecTX 

func (db *MysqlDriver) ExecTX(query string, args ...interface{}) (sql.Result, error)

func (*MysqlDriver) Exists 

func (db *MysqlDriver) Exists(tableName string, query map[string]interface{}) bool

func (*MysqlDriver) FindById 

func (db *MysqlDriver) FindById(tableName string, id int64) (*sql.Rows, error)

func (*MysqlDriver) FindOne 

func (db *MysqlDriver) FindOne(tableName string, query map[string]interface{}, orderBy string) (*sql.Rows, error)

func (*MysqlDriver) GetList 

func (db *MysqlDriver) GetList(tableName string, query map[string]interface{}, orderBy string) (*sql.Rows, error)

func (*MysqlDriver) GetPage 

func (db *MysqlDriver) GetPage(tableName string, query map[string]interface{}, orderBy string, page, size int64) (*sql.Rows, *Page, error)

func (*MysqlDriver) HideSql 

func (db *MysqlDriver) HideSql() error

func (*MysqlDriver) Insert 

func (db *MysqlDriver) Insert(tableName string, post map[string]interface{}) (int64, error)

func (*MysqlDriver) Open 

func (db *MysqlDriver) Open() (err error)

func (*MysqlDriver) Query 

func (db *MysqlDriver) Query(query string, args ...interface{}) (*sql.Rows, error)

func (*MysqlDriver) QueryMap 

func (db *MysqlDriver) QueryMap(tableName string, query map[string]interface{}) (*sql.Rows, error)

func (*MysqlDriver) QueryTX 

func (db *MysqlDriver) QueryTX(query string, args ...interface{}) (*sql.Rows, error)

func (*MysqlDriver) RollBack 

func (db *MysqlDriver) RollBack() error

func (*MysqlDriver) Save 

func (db *MysqlDriver) Save(tableName string, post map[string]interface{}) (int64, error)

func (*MysqlDriver) ShowSql 

func (db *MysqlDriver) ShowSql() error

func (*MysqlDriver) Update 

func (db *MysqlDriver) Update(tableName string, post map[string]interface{}, query map[string]interface{}) (int64, error)

type Page 

type Page struct {
	First int64 `json:"first"`
	Prev  int64 `json:"prev"`
	Page  int64 `json:"page"`
	Next  int64 `json:"next"`
	Last  int64 `json:"last"`
	Size  int64 `json:"size"`
	Total int64 `json:"total"`
}

type PostgresDriver 

type PostgresDriver struct {
	DriverName     string
	DataSourceName string
	Show           bool
	DB             *sql.DB
	SQLTX          *sql.Tx
}

func InitPostgreDriver 

func InitPostgreDriver(host string, port int, user, password, dbname string) *PostgresDriver

func (*PostgresDriver) Begin 

func (db *PostgresDriver) Begin() error

func (*PostgresDriver) Close 

func (db *PostgresDriver) Close() error

func (*PostgresDriver) Commit 

func (db *PostgresDriver) Commit() error

func (*PostgresDriver) Count 

func (db *PostgresDriver) Count(tableName string, query map[string]interface{}) (int64, error)

func (*PostgresDriver) Delete 

func (db *PostgresDriver) Delete(tableName string, query map[string]interface{}) (int64, error)

func (*PostgresDriver) DeleteById 

func (db *PostgresDriver) DeleteById(tableName string, id int64) (int64, error)

func (*PostgresDriver) Exec 

func (db *PostgresDriver) Exec(query string, args ...interface{}) (sql.Result, error)

func (*PostgresDriver) ExecTX 

func (db *PostgresDriver) ExecTX(query string, args ...interface{}) (sql.Result, error)

func (*PostgresDriver) Exists 

func (db *PostgresDriver) Exists(tableName string, query map[string]interface{}) bool

func (*PostgresDriver) FindById 

func (db *PostgresDriver) FindById(tableName string, id int64) (*sql.Rows, error)

func (*PostgresDriver) FindOne 

func (db *PostgresDriver) FindOne(tableName string, query map[string]interface{}, orderBy string) (*sql.Rows, error)

func (*PostgresDriver) GetList 

func (db *PostgresDriver) GetList(tableName string, query map[string]interface{}, orderBy string) (*sql.Rows, error)

func (*PostgresDriver) GetPage 

func (db *PostgresDriver) GetPage(tableName string, query map[string]interface{}, orderBy string, page, size int64) (*sql.Rows, *Page, error)

func (*PostgresDriver) HideSql 

func (db *PostgresDriver) HideSql() error

func (*PostgresDriver) Insert 

func (db *PostgresDriver) Insert(tableName string, post map[string]interface{}) (int64, error)

func (*PostgresDriver) Open 

func (db *PostgresDriver) Open() (err error)

func (*PostgresDriver) Query 

func (db *PostgresDriver) Query(query string, args ...interface{}) (*sql.Rows, error)

func (*PostgresDriver) QueryMap 

func (db *PostgresDriver) QueryMap(tableName string, query map[string]interface{}) (*sql.Rows, error)

func (*PostgresDriver) QueryTX 

func (db *PostgresDriver) QueryTX(query string, args ...interface{}) (*sql.Rows, error)

func (*PostgresDriver) RollBack 

func (db *PostgresDriver) RollBack() error

func (*PostgresDriver) Save 

func (db *PostgresDriver) Save(tableName string, post map[string]interface{}) (int64, error)

func (*PostgresDriver) ShowSql 

func (db *PostgresDriver) ShowSql() error

func (*PostgresDriver) Update 

func (db *PostgresDriver) Update(tableName string, post map[string]interface{}, query map[string]interface{}) (int64, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.