[Golang] Mysql Insert, Update, Delete 사용하기

MySql에서 DML  즉 데이터를 조작하는 방법으로 Insert, Update, Delete 를 사용한다. 

Golang에서는 DML을 사용하기 위해 Exec 함수를 사용한다.

함수의 정보는 아래와 같다.

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

Exec 함수에서 첫번 째 인자로 안에 SQL문을 작성하여 넣어주면 되고 두번 째 인자부터는 SQL안에 들어갈 값을 등록하면 된다. 실행한 후 리턴 값으로는 Result와 error 객체를 리턴한다.

SQL문으로 insert 할 경우

conn.Exec("insert into person (name, phone, address) value ('이순신','02-xxx-yyyy', '서울시 통인동')");

 

SQL문에 들어갈 인자 등록 할 경우

conn.Exec("insert into person (name, phone, address) value (?, ?, ?)", "이순신", "02-xxxx-yyyy", "서울시 통인동");

 

Insert 예제

 

package main

import (
	"database/sql"
	"fmt"
	"os"
	_ "github.com/go-sql-driver/mysql"
)

func main() {
	//conn, err := sql.Open("mysql", "계정명:계정패스워드@tcp(DB주소:DB포트)/데이터베이스명")
	conn, err := sql.Open("mysql", "testuser:test1234@tcp(localhost:3306)/mydb")
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}

	result, err := conn.Exec("insert into person (name, phone, address) value ('이순신','02-xxxx-yyyy', '서울시 통인동')")
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}

	//RowsAffected() 함수를 통해 insert 한 갯수를 확인한다.
	nRow, err := result.RowsAffected()
	fmt.Println("insert count : ", nRow)

	conn.Close()
}

결과

insert count : 1

update와 delete를 할 때도 동일하게 하면 된다.

Update 예제

package main

import (
	"database/sql"
	"fmt"
	"os"
	_ "github.com/go-sql-driver/mysql"
)

func main() {
	//conn, err := sql.Open("mysql", "계정명:계정패스워드@tcp(DB주소:DB포트)/데이터베이스명")
	conn, err := sql.Open("mysql", "testuser:test1234@tcp(localhost:3306)/mydb")
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}

	result, err := conn.Exec("update person set name = '강감찬' where name='이순신'")
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}

	//RowsAffected() 함수를 통해 update 한 갯수를 확인한다.
	nRow, err := result.RowsAffected()
	fmt.Println("update count : ", nRow)

	conn.Close()
}

결과

update count : 1

Delete 예제

package main

import (
	"database/sql"
	"fmt"
	"os"
	_ "github.com/go-sql-driver/mysql"
)

func main() {
	//conn, err := sql.Open("mysql", "계정명:계정패스워드@tcp(DB주소:DB포트)/데이터베이스명")
	conn, err := sql.Open("mysql", "testuser:test1234@tcp(localhost:3306)/mydb")
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}

	result, err := conn.Exec("delete from person where name='강감찬'")
	if err != nil {
		fmt.Println(err)
		os.Exit(1)
	}

	//RowsAffected() 함수를 통해 update 한 갯수를 확인한다.
	nRow, err := result.RowsAffected()
	fmt.Println("delete count : ", nRow)

	conn.Close()
}

결과

delete count : 1

Exec 함수가 아닌 Query()함수를 이용해서도 가능하며 insert/update/delete 한 갯수를 확인 할 수 없다.

이 때에는 리턴 받은 객체를 이용해 close함수를 호출하고 끝낸다.