필요한 패키지를 가져온 다음 데이터베이스의 tb_student 테이블 예와 동일한 스키마로 구조체를 준비합니다. 나중에 이 구조체는 쿼리 결과의 컨테이너로 사용됩니다. 데이터 형식.

package main
import "fmt"
import "database/sql"
import _ "github.com/go-sql-driver/mysql"


type student struct {
 id string,
 name string,
 age int,
 grade int,
}

사용된 데이터베이스 드라이버는 _ 기호를 사용하여 가져와야 합니다. 데이터베이스/sql 패키지에 필요하더라도 드라이버와 직접 상호 작용하지 않기 때문입니다.

다음으로 데이터베이스에 연결하는 함수를 만듭니다.

func connect() (*sql.DB, error) {
 db, err := sql.Open("mysql","root:@tcp(127.0.0.1:3306)/db_learn_go")
 if err != nil {
  return nil, err
 }
 return db, nil
}

우리가 사용하는 mysql 드라이버의 연결 문자열 체계는 매우 독특합니다. 아래의 root@tcp(127.0.0.1:3306)/db_learn_go는 이동 중에도 사용할 수 있는 연결 문자열 체계입니다. MYSQL 드라이버 드라이버를 사용하는 경우 또 다른 mysql의 경우, 사용하는 드라이버에 따라 연결 방식이 다를 수 있습니다.

user:password@tcp(host:port)/dbname
user@tcp(host:port)/dbname

다음은 connect() 함수에서 사용하는 연결 문자열에 대한 설명입니다.

root@tcp(127.0.0.1:3306)/db_learn_go
// user => root
// password =>
// host => 127.0.0.1 atau localhost
// port => 3306
// dbname => db_learn_go

데이터베이스와의 연결을 위한 기능이 생성되었으면 이제 데이터베이스 서버에서 데이터를 읽어오는 과정을 실습해보겠습니다. 기능 준비
sqlQuery()를 다음 코드로 실행합니다.

func sqlQuery() {
 db, err := connect()
 if err != nil {
 fmt.Println(err.Error())
 return
 }
 defer db.Close()
 var age = 27
 rows, err := db.Query("select id, name, grade from tb_student where age = ?
 if err != nil {
 fmt.Println(err.Error())
 return
 }
 defer rows.Close()
 var result []student
 for rows.Next() {
 var each = student{}
 var err = rows.Scan(&each.id, &each.name, &each.grade)
 if err != nil {
 fmt.Println(err.Error())
 return
 }
 result = append(result, each)
 }
 if err = rows.Err(); err != nil {
 fmt.Println(err.Error())
 return
 }
 for _, each := range result {
 fmt.Println(each.name)
 }
}

새 연결이 생성될 때마다 항상 연결 인스턴스를 닫는 것을 잊지 마세요. 위 코드와 같이 defer 키워드를 사용할 수 있습니다. defer
db.Close() .
db.Query() 함수는 SQL 쿼리를 실행하는 데 사용됩니다. 함수의 두 번째 매개변수는 가변이므로 비워둘 수 있습니다. 위 코드에서 where 절 중 하나의 값이 물음표(?)인 것을 확인할 수 있습니다.

그러면 기호는 그 뒤의 매개변수 값(연령 변수 값)으로 대체됩니다. SQL 삽입을 방지하려면 이러한 유형의 쿼리 작성 기술을 적극 권장합니다. 이 함수는 더 이상 사용되지 않을 때 닫아야 하는 sql.*Rows 유형의 인스턴스를 생성합니다( deferrows.Close() ). 다음으로, 요소 유형이 struct Student인 배열이 result라는 이름으로 준비됩니다. 나중에 쿼리 결과가 변수에 저장됩니다. 그런 다음 조건 참조가rows.Next() 인 루프가 수행됩니다. 이 루프는 첫 번째 레코드부터 끝까지 순차적으로 하나씩 총 레코드 수만큼 수행됩니다. sql.Rows의 Scan() 메서드는 반복되는 레코드의 값을 검색하여 포인터 변수에 저장하는 함수입니다. 레코드 필드를 저장하는 데 사용되는 변수는 쿼리에서 선택한 필드에 따라 가변 매개변수로 순차적으로 작성됩니다. 자세한 내용은 아래 비교를 확인해주세요. // 쿼리
ID, 이름, 학년 선택...
// 스캔
행.스캔(&each.id, &each.name, &each.grade ...
그런 다음 얻은 레코드 데이터는
문을 통해 결과 조각에 추가됩니다. 결과 = 추가(결과, 각) .
좋습니다. 이제 main 에서 sqlQuery() 함수를 호출한 다음 프로그램을 실행하세요.

func main() {
sqlQuery()
}

저는 평범한 블로그 작가입니다. 아직 부족한 부분이 많다면 양해 부탁드립니다.