neo4j

README

MySQL配置

mysql配置必须在[sdk]段落下, 同时必须包含[sdk.log], 日志能力[sdk.log]的配置是最基本需求的配置，不管使用sdk的时候是否具有其他能力, 日志配置信息必须要包含

1. 数据库连接类型

• default: 缺省的数据库
• master: 主数据库
• slave: 从数据库
• other: 额外数据库

1. 配置示例

[sdk.mysql]
    [sdk.mysql.default]
        database = "mysql"      <--- 要连接的数据库的名字
        user = "root"           <--- 数据库连接用户名
        password = "password"   <--- 数据库连接密码
        host = "127.0.0.1"      <--- 数据库主机
        port = 3306             <--- 数据库端口
    [sdk.mysql.master]
        database = "mysql"
        user = "root"
        password = "password"
        host = "127.0.0.1"
        port = 3306
    [[sdk.mysql.slaves]]
        database = "mysql"
        user = "root"
        password = "password"
        host = "127.0.0.1"
        port = 3306
    [[sdk.mysql.slaves]]
        ...
    [[sdk.mysql.items]]
        name = "extra1"       <--- 额外的数据库连接的名字，用来区分不同的数据库连接
        database = "mysql"
        user = "root"
        password = "password"
        host = "127.0.0.1"
        port = 3306
    [[sdk.mysql.items]]
        name = "extra2"
        database = "mysql"
        user = "root"
        password = "password"
        host = "127.0.0.1"
        port = 3306

1. 数据库能力配置中的name只有在使用other的时候才需要指定
2. 在配置slave和other类型的时候需要注意用[[和]], 另外名字后需要加s, e,g: slave的配置为[[sdk.db.slaves]]

MySQL使用指南

获取数据库连接

• 获取缺省数据库连接: sdk.Db.My()
• 获取主数据库连接: sdk.Db.Master()
• 获取第几个从数据库连接: sdk.Db.Slave(int)
• 获取指定名字的数据库连接: sdk.Db.By(string)

数据库接口

• 将?占位符的查询语句转换成数据库driver对应的bindvar类型

  func Rebind(query string) string

• 查询获取一行并且将结果集中的指定字段的值防止到结果中，参考：https://pkg.go.dev/github.com/jmoiron/sqlx#Get

  func Get(q Queryer, dest interface{}, query string, args ...interface{}) error

• 查询数据库并返回*sqlx.Rows, query字符串中的?占位符会被提供的参数填入

  func Queryx(query string, args ...interface{}) (*Rows, error)

• 执行query语句

  func Exec(query string, args ...interface{}) sql.Result

其他支持接口请参考： https://pkg.go.dev/github.com/jmoiron/sqlx

示例

    // 组装In参数
    query, args, err := sqlx.In(query, ...)
	if err != nil {
		return err
	}

    // Rebind并执行查询
    query = sdk.Mysql.My().Rebind(query)
	rows, err := sdk.Mysql.Default().Queryx(query, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

    // 处理查询集，将每一行的row结果转换为某个结构值
	for rows.Next() {
        var v SomeStruct
   		err := rows.StructScan(&v)
        if err != nil {
            return err
        }
        // processing v
    }

Documentation

Overview

Package neo4j @Title log capability of zerolog @Description zerolog implementation of log capability @Author Ryan Fan 2021-06-09 @Update Ryan Fan 2021-06-09

Index

• type ConfigNeo4j
• type Neo4jProvider
  • func (np *Neo4jProvider) Exec(workFuncs []neo4j.TransactionWork, bookmarks ...string) (string, error)
  • func (np *Neo4jProvider) Get(cypher string, args ...interface{}) (interface{}, error)
  • func (np *Neo4jProvider) Init(rootConfiger types.Configer, logger types.LogProvider, args ...interface{}) error
  • func (np *Neo4jProvider) Read(cypher string, params map[string]interface{}, bookmarks ...string) neo4j.Session
  • func (np *Neo4jProvider) Reader(bookmarks ...string) neo4j.Session
  • func (np *Neo4jProvider) Select(cypher string, args ...interface{}) ([]interface{}, error)
  • func (np *Neo4jProvider) Writer(bookmarks ...string) neo4j.Session
• type Neo4jServerConf

Types

type ConfigNeo4j

type ConfigNeo4j struct {
	VirtualUri  string             `mapstructure:"virtual_uri"`
	Username    string             `mapstructure:"username"`
	Password    string             `mapstructure:"password"`
	Servers     []*Neo4jServerConf `mapstructure:"servers"`
	MaxPoolSize int                `mapstructure:"max_pool_size"`
}

type Neo4jProvider

type Neo4jProvider struct {
	graph.BaseGraphProvider
	Log types.LogProvider
	// contains filtered or unexported fields
}

func (*Neo4jProvider) Exec

func (np *Neo4jProvider) Exec(workFuncs []neo4j.TransactionWork, bookmarks ...string) (string, error)

func (*Neo4jProvider) Get

func (np *Neo4jProvider) Get(cypher string, args ...interface{}) (interface{}, error)

func (*Neo4jProvider) Init

func (np *Neo4jProvider) Init(rootConfiger types.Configer, logger types.LogProvider, args ...interface{}) error

Init implements types.Provider interface, used to initialize the capability @author Ryan Fan (2021-06-09) @param baseconf.Configer root config interface to extract config info @return error

func (*Neo4jProvider) Read

func (np *Neo4jProvider) Read(cypher string, params map[string]interface{}, bookmarks ...string) neo4j.Session

func (*Neo4jProvider) Reader

func (np *Neo4jProvider) Reader(bookmarks ...string) neo4j.Session

func (*Neo4jProvider) Select

func (np *Neo4jProvider) Select(cypher string, args ...interface{}) ([]interface{}, error)

func (*Neo4jProvider) Writer

func (np *Neo4jProvider) Writer(bookmarks ...string) neo4j.Session

type Neo4jServerConf

type Neo4jServerConf struct {
	Host string `mapstructure:"host"`
	Port int    `mapstructure:"port"`
}