备份一个数据库
fileName := fields.FileAlias setSqlHeader(fields, fileName) //设置导出文件说明 if flag.Tables { //如果表设置为真,导出表结构 err := exportTables(fileName, fields, flag) //具体算法请参照源代码 if err != nil { ch <- fmt.Sprintln("Error: ", fields.DbName, "\t export tables throw, \t", err) return } } if flag.Views { //如果视图设置为真,导出视图 err := exportViews(fileName, fields)//具体算法请参照源代码,或python算法 if err != nil { ch <- fmt.Sprintln("Error: ", fields.DbName, "\t export views throw, \t", err) return } } if flag.Funcs { //如果函数设置为真,导出函数和存储过程 err := exportFuncs(fileName, fields)//具体算法请参照源代码 if err != nil { ch <- fmt.Sprintln("Error: ", fields.DbName, "\t export funcs throw, \t", err) return } } //导出工作完成,向通道输入信息 ch <- fmt.Sprintln("Export ", fields.DbName, "\t success at \t", time.Now().Format("2006-01-02 15:04:05")) MysqlDao.go数据库查询通用封装,此工具只使用了ExecuteWithDbConn。灵活的使用map与interface{},将结果转化为键值对象返回。
func ExecuteWithDbConn(sql string, values []interface{}, fields common.DbConnFields) (map[string]interface{}, error) { rs := make(map[string]interface{}) dao, err := mysql.Open("mysql", fields.DbUser + ":"+fields.DbPass+"@tcp("+fields.DbHost+":"+ strconv.Itoa(fields.DbPort)+")/"+fields.DbName+"?charset="+fields.DbCharset) defer dao.Close() if err != nil { rs["code"] = 204 return rs, err } stmt, err := dao.Prepare(sql) if err != nil { rs["code"] = 204 return rs, err } rows, err := stmt.Query(values...) if err != nil { rs["code"] = 204 return rs, err } columns, err := rows.Columns() //取出字段名称 vs := make([]mysql.RawBytes, len(columns)) scans := make([]interface{}, len(columns)) for i := range vs { //预设取值地址 scans[i] = &vs[i] } var result []map[string]interface{} for rows.Next() { _ = rows.Scan(scans...) //塡入一列值 each := make(map[string]interface{}) for i, col := range vs { if col != nil { each[columns[i]] = FilterHolder(string(col)) //过滤/xfffd }else{ each[columns[i]] = nil } } result = append(result, each) } rs["code"] = 200 //data, _ := json.Marshal(result) rs["rows"] = result return rs, err } 项目地址 https://github.com/zhoutk/goTools 使用方法 git clone https://github.com/zhoutk/goTools cd goTools go get go run main.go go buid main.go ./main #export all things of database ./main table #export tables ./main data #export tables & data ./main views #export views ./main funcs #export funcs & stored procedures 小结熟悉了golang语言,了解了一种全新的并发编程模式,给自己生成了一个方便的工具。