Как импортировать данные из базы данных SQL? - PullRequest
Новая
       11

Как импортировать данные из базы данных SQL?

0 голосов
/ 17 сентября 2018

Я подключаю локальную базу данных к приложению, затем хочу снова перенести эти данные в приложение для редактирования.Это мой код 

import sys
import os
import time

from PyQt5 import QtCore, QtGui, QtWidgets, uic
import mysql.connector
from mysql.connector import errorcode

FORM_CLASS, _ = uic.loadUiType(os.path.join(os.path.dirname(__file__),"mahmoudtarek.ui"))

class Main(QtWidgets.QMainWindow, FORM_CLASS):
    def __init__(self,parent=None):
        super(Main,self).__init__(parent)
        self.setupUi(self)
        self.InitUI()
        self.conn = None

        self.handle_buttons()
        self.handle_db_connections()

    def InitUI(self):
        ## changes in the run time
        pass

    def handle_buttons(self):
          ## all buttons in the app
        self.pushButton.clicked.connect(self.add_mahmoud_friends)
        self.pushButton_3.clicked.connect(self.update_mahmoud_friends)
        self.pushButton_2.clicked.connect(self.delete_mahmoud_friends)
        self.pushButton_6.clicked.connect(self.search_mahmoud_friends)


    def handle_db_connections(self):
        try:
            self.conn = mysql.connector.connect(
                host='127.0.0.1',
                database='mydb',
                user='root',
                password='134668691011',
                use_pure=True)  # use_pure is set to true

            if self.conn.is_connected():
                db_Info = self.conn.get_server_info()
                print("Connected to MySQL database using C extension... MySQL Server version on ", db_Info)
        except mysql.connector.Error as err:
            print("Error while connecting to MySQL using C extension", err)

    def add_mahmoud_friends(self):
        mth_friends = self.lineEdit.text()
        mth_search = self.lineEdit_4.text()
        if self.conn:
            c = self.conn.cursor()
            try:
                c.execute('''INSERT INTO ahmed (mth_friends,mth_search) values (%s,%s)''', (mth_friends,mth_search))
                self.conn.commit()
                self.lineEdit.setText('')
                self.lineEdit_4.setText('')
                self.statusBar.showMessage('ok mahmoud')


            except mysql.connector.Error as err:
                print("Error: ", err)

    def update_mahmoud_friends(self):
        pass

    def delete_mahmoud_friends(self):
        pass
    def search_mahmoud_friends(self):

        sql = '''SELECT * FROM ahmed WHERE mth_search = %s'''
        mth_search = self.lineEdit_3.text()
        self.conn.cursor.execute(sql , [(mth_search)])
        data = self.conn.fetchall()
        for row in data :
            print(row)

    def closeEvent(self, event):
        if self.conn:
            self.conn.close()
        super(Main, self).closeEvent(event)


def main():
    app= QtWidgets.QApplication(sys.argv)
    window =Main()
    window.show()
    app.exec_()

if __name__ == '__main__':
    main()

Ошибка появляется здесь, когда я импортирую данные, печатая строку в моей базе данных SQL.

Ошибка

Подключено к базе данных MySQL с помощью Cрасширение ... Версия MySQL Server для 8.0.12 Traceback (последний вызов был последним): файл "/Users/mahmoudtarek/Desktop/mth1/index.py", строка 73, в файле search_mahmoud_friends self.conn.cursor.execute (sql,[(mth_search)]) AttributeError: у объекта 'function' нет атрибута 'execute'

, так что, это можно решить или есть другой метод?

Ответы [ 3 ]

0 голосов
/ 17 сентября 2018

Может быть, вы можете попробовать что-то вроде ниже 

import pymssql
cnxn = pymssql.connect(server='Server_name',user='UID', password='Password', database='Db Name')
cursor = cnxn.cursor()    
cmd = (r"<Your Query>")
cursor.execute(cmd)
query_results = cursor.fetchall()
cursor.close()

Результат будет доступен в query_results

0 голосов
/ 17 сентября 2018

Я решил это спасибо всем вам 

  def search_mahmoud_friends(self):
        if self.conn:
            c = self.conn.cursor()

            try:

                sql = '''SELECT * FROM ahmed WHERE mth_search = %s'''
                mth_search = self.lineEdit_3.text()
                c.execute(sql, [(mth_search)])
                data = c.fetchall()
                for row in data :
                    print(row)

            except mysql.connector.Error as err:
              print("Error: ", err)
0 голосов
/ 17 сентября 2018

Попробуйте изменить строку 73 на 

self.conn.cursor().execute(sql , [(mth_search)])
...