MySQL 서버에서 데이터 읽기

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

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

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

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

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

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

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

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

func 메인() {
sqlQuery()
}

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

위 내용은 MySQL 서버에서 데이터 읽기의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!