python: mysql DB query 요청

안녕하세요. 제이콥입니다.

이번 글에서는 python으로 mysql db에 접근, query를 요청하는 것에 대해 정리를 해봤습니다.

다른걸로 공부하시다 이렇게 사용할 수 있구나 정도.. 보시면 될 것 같습니다.

이전 글에서는 mysql-workbench를 설치했었습니다.

mysql-workbench를 설치하고 싶다면 아래 글을 봐보세요.

-> https://busy.org/@jacobyu/1535-mysql-db-workbench-setup-vultr-ubuntu

설치를 한 후, schema와 table을 생성해야하는데요.

이 생성과정은 mysql-workbench에서 하면 아주 편합니다.

UI에서 테이블 이름, 필드 이름, 타입 등을 넣어주면 됩니다.

그러면 자동으로 mysql query 문이 생성됩니다.

이제 파이썬으로 mysql을 다뤄보겠습니다.

먼저 pymysql 라이브러리를 설치합니다.

pip install pymysql

설치 다하셨나요? ㅎㅎ

제가 작성한 코드로 설명해보겠습니다.

저는 object map라는 테이블을 만들었고 object를 테이블에 넣고 지우고 업데이트하고 가져오는 작업을 해봤습니다.

먼저 특정 db의 schema에 연결을 합니다.

연결이 되면 이 conn이라는 객체를 이용해서 여러 query를 수행합니다.

DB가 설치된 서버 host name,

DB에 접근할 user명, 비밀번호,

Schema 등을 입력합니다.

    def initDB(self):
        conn = pymysql.connect(
        host= ‘test.net’,
        user= ‘test’,
        password= ‘test_pw’,
        db= ‘your_schema’,
        charset= ‘utf8mb4’)
        return conn

아래 함수는 select로 테이블 내의 값들을 가져와서

Object라는 객체에 값을 채워넣는 일을 합니다.

이 코드에서는 처음에 정의한 initDB로 connection을 한 후, 쿼리를 수행하는 것을 볼 수 있습니다.

    def loadObjectMap(self):
        conn = self.initDB()
        result = None
        try:
            with conn.cursor() as cursor:
                sql = 'SELECT * FROM ObjectMap'
                cursor.execute(sql)
                result = cursor.fetchall()
                # print(result)
        except Exception as e:
            print('I got error on search table')
            conn.close()
        conn.close()
        objectArray = []
        for object_quary in result:
            obj = Object()
            obj.id = object_quary[0] # auto id
            obj.tag = object_quary[2]
            obj.tagName = object_quary[3]
            obj.directionX = object_quary[4]
            obj.directionY = object_quary[5]
            obj.directionZ = object_quary[6]
            objectArray.append(obj)
        return objectArray

아래 함수들은 물체를 지우고, 넣고, 업데이트 하는 함수들입니다.

    def delete_object(self, auto_id): #delete an object which has auto_id
        pass # DELETE FROM athena.ObjectMap WHERE AI_ID=’15’;
        conn = self.initDB()
        try:
            with conn.cursor() as cursor:
                sql = ‘DELETE FROM ObjectMap WHERE AI_ID = %s’
                cursor.execute(sql, (auto_id))
            conn.commit()
            print(‘I successed on deleting ID’)
        except Exception as e:
            print(‘I got error on deleting ID’)
            print(e)
            conn.close()
        conn.close()

    def insert_object(self, obj): # insert new object to DB
        # obj.id, obj.tag, obj.tagName, obj.directionX, obj.directionY, obj.directionZ
        conn = self.initDB()
        try:
            with conn.cursor() as cursor:
                # print obj
                sql = ‘INSERT INTO ObjectMap (objectMapID, tagID, name, directionX, directionY, directionZ) VALUES (%s, %s, %s, %s, %s, %s)’
                cursor.execute(sql, (obj.id, obj.tag, obj.tagName, obj.directionX, obj.directionY, obj.directionZ))
            conn.commit()
            print(‘I successed on inserting ID’)
        except Exception as e:
            print(‘I got error on inserting ID’)
            print(e)
            conn.close()
            return 0
        conn.close()
        return 1

    def update_object(self, updateID, obj): # update obj info to another object which has updateID.
        # self.update_object(obj.id, obj.directionX, obj.directionY, obj.directionZ)
        conn = self.initDB()
        try:
            with conn.cursor() as cursor:
                sql = ‘UPDATE ObjectMap SET tagID = %s, name = %s, directionX = %s, directionY = %s, directionZ = %s WHERE AI_ID = %s’
                cursor.execute(sql, (obj.tag, obj.tagName, obj.directionX, obj.directionY, obj.directionZ, updateID))
            conn.commit()
            print(‘I successed on updating ID’)
        except Exception as e:
            print(‘I got error on updating ID’)
            print(e)
            conn.close()
        conn.close()

끝!

감사합니다.

This page is synchronized from the post: ‘python: mysql DB query 요청’