go 封装一个sqlx，供各个线程调用-Go服务器开发

下面是一个示例的Go代码，演示了如何封装sqlx并供多个线程调用：

package main
import (
	"fmt"
	"sync"
	"github.com/jmoiron/sqlx"
	_ "github.com/go-sql-driver/mysql"
)
type DBManager struct {
	db *sqlx.DB
	mu sync.Mutex
}
func NewDBManager() (*DBManager, error) {
	db, err := sqlx.Open("mysql", "user:password@tcp(localhost:3306)/database")
	if err != nil {
		return nil, err
	}
	err = db.Ping()
	if err != nil {
		return nil, err
	}
	return &DBManager{
		db: db,
	}, nil
}
func (m *DBManager) Query(query string, args ...interface{}) ([]map[string]interface{}, error) {
	rows, err := m.db.Queryx(query, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()
	columns, _ := rows.Columns()
	result := make([]map[string]interface{}, 0)
	for rows.Next() {
		row := make(map[string]interface{})
		values := make([]interface{}, len(columns))
		for i := range columns {
			values[i] = new(interface{})
		}
	
	err = rows.Scan(values...)
	if err != nil {
			return nil, err
	}
for i, colName := range columns {
			row[colName] = *(values[i].(*interface{}))
		
	result = append(result, row)
}
return result, nil
}
func main() {
	manager, err := NewDBManager()
	if err != nil {
	fmt.Println("Failed to create DB manager:", err)
	return
}
// 在多个线程中并发调用查询方法示例
var wg sync.WaitGroup
for i := 0; i < 10; i++ {
	wg.Add(1)
	go func() {
		defer wg.Done()
		result, err := manager.Query("SELECT * FROM table_name WHERE column = ?", value)
		if err != nil {
			fmt.Println("Error executing query:", err)
			return
		}
		fmt.Println(result) // 处理查询结果
	}()
}
wg.Wait()
// 关闭数据库连接
manager.db.Close()
}