为什么GOLANG的MySQL驱动在UPDATE和DELETE SQL中返回”bad connection”错误?

huangapple go评论81阅读模式
英文:

Why GOLANG MySQL Driver Return "bad connection" in UPDATE & DELETE SQL?

问题

我正在尝试使用GO语言(1.18)和MySQL(5.7)进行我的第一个CRUD操作,但是在使用UPDATE和DELETE时出现错误,CREATE和READ SQL没有返回错误。我搜索了一下,似乎是关于连接的配置出了问题,但我不知道如何跟踪它。

MySQL驱动程序:github.com/go-sql-driver/mysql v1.6.0

我的存储库:https://github.com/ramadoiranedar/GO_REST_API

错误信息如下

[mysql] 2022/09/22 00:04:44 connection.go:299: invalid connection
driver: bad connection

我有以下SQL函数:

  • CONNECTION
func NewDB() *sql.DB {
	db, err := sql.Open("mysql", "MY_USERNAME:MY_PASSWORD@tcp(localhost:3306)/go_restful_api")
	helper.PanicIfError(err)

	db.SetMaxIdleConns(5)
	db.SetMaxIdleConns(20)
	db.SetConnMaxLifetime(60 * time.Minute)
	db.SetConnMaxIdleTime(10 * time.Minute)

	return db
}
  • UPDATE
func (repository *CategoryRepositoryImpl) Update(ctx context.Context, tx *sql.Tx, category domain.Category) domain.Category {
   SQL := "update category set name = ? where id = ?"
   _, err := tx.ExecContext(ctx, SQL, category.Name, category.Id)
   helper.PanicIfError(err)
   return category
}
  • DELETE
func (repository *CategoryRepositoryImpl) Delete(ctx context.Context, tx *sql.Tx, category domain.Category) {
   SQL := "delete from category where id = ?"
   _, err := tx.ExecContext(ctx, SQL, category.Name, category.Id)
   helper.PanicIfError(err)
}
  • CREATE
func (repository *CategoryRepositoryImpl) Create(ctx context.Context, tx *sql.Tx, category domain.Category) domain.Category {
SQL := "insert into category (name) values (?)"
   result, err := tx.ExecContext(ctx, SQL, category.Name)
   helper.PanicIfError(err)

   id, err := result.LastInsertId()
   if err != nil {
	   panic(err)
   }
   category.Id = int(id)
		
   return category
}
  • READ
func (repository *CategoryRepositoryImpl) FindAll(ctx context.Context, tx *sql.Tx) []domain.Category {
	SQL := "select id, name from category"
	rows, err := tx.QueryContext(ctx, SQL)
	helper.PanicIfError(err)

	var categories []domain.Category
	for rows.Next() {
		category := domain.Category{}
		err := rows.Scan(
			&category.Id,
			&category.Name,
		)
		helper.PanicIfError(err)
		categories = append(categories, category)
	}
	return categories
}
func (repository *CategoryRepositoryImpl) FindById(ctx context.Context, tx *sql.Tx, categoryId int) (domain.Category, error) {
	SQL := "select id, name from category where id = ?"
	rows, err := tx.QueryContext(ctx, SQL, categoryId)
	helper.PanicIfError(err)

	category := domain.Category{}
	if rows.Next() {
		err := rows.Scan(&category.Id, &category.Name)
		helper.PanicIfError(err)
		return category, nil
	} else {
		return category, errors.New("CATEGORY IS NOT FOUND")
	}
}

为什么GOLANG的MySQL驱动在UPDATE和DELETE SQL中返回”bad connection”错误?

英文:

i'm getting Stuck as TRY my first CRUD with MySQL (5.7) using GO lang (1.18). CREATE & READ SQL not return the error, but in UPDATE & DELETE return the error. I was searching and looks like about bad or wrong configuration for connection...but i dont know how to trace it.

Driver MySQL: github.com/go-sql-driver/mysql v1.6.0

My Repo: https://github.com/ramadoiranedar/GO_REST_API

The Error is:

[mysql] 2022/09/22 00:04:44 connection.go:299: invalid connection
driver: bad connection

And i have functions SQL look likes this:

  • CONNECTION
func NewDB() *sql.DB {
	db, err := sql.Open("mysql", "MY_USERNAME:MY_PASSWORD@tcp(localhost:3306)/go_restful_api")
	helper.PanicIfError(err)

	db.SetMaxIdleConns(5)
	db.SetMaxIdleConns(20)
	db.SetConnMaxLifetime(60 * time.Minute)
	db.SetConnMaxIdleTime(10 * time.Minute)

	return db
}
  • UPDATE
func (repository *CategoryRepositoryImpl) Update(ctx context.Context, tx *sql.Tx, category domain.Category) domain.Category {
   SQL := "update category set name = ? where id = ?"
   _, err := tx.ExecContext(ctx, SQL, category.Name, category.Id)
   helper.PanicIfError(err)
   return category
}
  • DELETE
func (repository *CategoryRepositoryImpl) Delete(ctx context.Context, tx *sql.Tx, category domain.Category) {
   SQL := "delete from category where id = ?"
   _, err := tx.ExecContext(ctx, SQL, category.Name, category.Id)
   helper.PanicIfError(err)
}
  • CREATE
func (repository *CategoryRepositoryImpl) Create(ctx context.Context, tx *sql.Tx, category domain.Category) domain.Category {
SQL := "insert into category (name) values (?)"
   result, err := tx.ExecContext(ctx, SQL, category.Name)
   helper.PanicIfError(err)

   id, err := result.LastInsertId()
   if err != nil {
	   panic(err)
   }
   category.Id = int(id)
		
   return category
}
  • READ
func (repository *CategoryRepositoryImpl) FindAll(ctx context.Context, tx *sql.Tx) []domain.Category {
	SQL := "select id, name from category"
	rows, err := tx.QueryContext(ctx, SQL)
	helper.PanicIfError(err)

	var categories []domain.Category
	for rows.Next() {
		category := domain.Category{}
		err := rows.Scan(
			&category.Id,
			&category.Name,
		)
		helper.PanicIfError(err)
		categories = append(categories, category)
	}
	return categories
}
func (repository *CategoryRepositoryImpl) FindById(ctx context.Context, tx *sql.Tx, categoryId int) (domain.Category, error) {
	SQL := "select id, name from category where id = ?"
	rows, err := tx.QueryContext(ctx, SQL, categoryId)
	helper.PanicIfError(err)

	category := domain.Category{}
	if rows.Next() {
		err := rows.Scan(&category.Id, &category.Name)
		helper.PanicIfError(err)
		return category, nil
	} else {
		return category, errors.New("CATEGORY IS NOT FOUND")
	}
}

为什么GOLANG的MySQL驱动在UPDATE和DELETE SQL中返回”bad connection”错误?

答案1

得分: 1

长话短说:你在不应该使用数据库事务的地方使用了它们

将它们保留用于必须成功的写入操作组。

我建议重新定义你的仓库及其实现。分层的整个思想是独立于仓库实现,并能够从MySQL切换到MongoDB或PostgreSQL等。

//category_controller.go
type CategoryRepository interface {
	Create(ctx context.Context, category domain.Category) domain.Category
	Update(ctx context.Context, category domain.Category) domain.Category
	Delete(ctx context.Context, category domain.Category)
	FindById(ctx context.Context, categoryId int) (domain.Category, error)
	FindAll(ctx context.Context) []domain.Category
}
//category_repository_impl.go
type CategoryRepositoryImpl struct {
	db *sql.DB 
}

func NewCategoryRepository(db *sql.DB) CategoryRepository {
	return &CategoryRepositoryImpl{db: db}
}

请参考以下修改后的代码文件的Gist链接:
https://gist.github.com/audrenbdb/94660f707a206d385c42f64ceb93a4aa

英文:

Long story short: you are using database transactions where you should not.

Keep them for group of writing operations that must succeed.

I would suggest you to redefine your repository and its implementation. The whole idea of splitting layers is to be independant of a repository implementation and to be able to switch from mysql to mongo to postgres, or w/e.

//category_controller.go
type CategoryRepository interface {
	Create(ctx context.Context, category domain.Category) domain.Category
	Update(ctx context.Context, category domain.Category) domain.Category
	Delete(ctx context.Context, category domain.Category)
	FindById(ctx context.Context, categoryId int) (domain.Category, error)
	FindAll(ctx context.Context) []domain.Category
}
//category_repository_impl.go
type CategoryRepositoryImpl struct {
	db *sql.DB 
}

func NewCategoryRepository(db *sql.DB) CategoryRepository {
	return &CategoryRepositoryImpl{db: db}
}

Please see following gists with modified version of your code files:
https://gist.github.com/audrenbdb/94660f707a206d385c42f64ceb93a4aa

huangapple
  • 本文由 发表于 2022年9月22日 02:02:41
  • 转载请务必保留本文链接:https://go.coder-hub.com/73805159.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定