Código de Python - Clase para conectar con MySQL

Imágen de perfil

Clase para conectar con MySQLgráfica de visualizaciones


Python

estrellaestrellaestrellaestrellaestrella(3)
Actualizado el 25 de Agosto del 2017 por xve (Publicado el 20 de Enero del 2017)
4.282 visualizaciones desde el 20 de Enero del 2017. Una media de 56 por semana
Este código es una simple clase de Python para poder ejecutar query's contra MySQL utilizando MySQLdb.

Requerimientos

Python 2.x

Versión 1.0
estrellaestrellaestrellaestrellaestrella(1)

Actualizado el 06 de Abril del 2017 (Publicado el 20 de Enero del 2017)gráfica de visualizaciones de la versión: Versión 1.0
1.569 visualizaciones desde el 20 de Enero del 2017. Una media de 21 por semana

Versión 2.0
estrellaestrellaestrellaestrellaestrella(2)

Actualizado el 15 de Octubre del 2017 (Publicado el 25 de Agosto del 2017)gráfica de visualizaciones de la versión: Versión 2.0
2.714 visualizaciones desde el 25 de Agosto del 2017. Una media de 63 por semana
estrellaestrellaestrellaestrellaestrella
estrellaestrellaestrellaestrella
estrellaestrellaestrella
estrellaestrella
estrella

Se ha añadido la función para devolver el numero de registros afectados en las consultas SQL
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
#!/usr/bin/env python
# -*- coding: utf-8 -*-
 
import MySQLdb
import exceptions
 
class myMysql(object):
 
    def __init__(self):
        # Variable que determina si estamos conectados a MySQL...
        self.connected=0
        self.error=""
 
    def mysqlConnect(self,host,user,pw,database,port=3306):
        """
        Realiza la conexion con la base de datos
        Tiene que recibir:
            - host
            - user
            - pw => password
            - database => database name
        Puede recibir:
            - port
        Devuelve True o False
        """
        try:
            self.db = MySQLdb.connect(user=user, passwd=pw, host=host, db=database, port=port, charset="utf8", init_command="set names utf8")
            self.cursor = self.db.cursor()
            self.connected=1
            return True
        except Exception,e:
            self.error="Error: %s" % (e)
        except:
            self.error="Error desconocido"
        return False
 
    def prepare(self,query,params=None,execute=True):
        """
        Funcion que ejecuta una instruccion mysql
        Tiene que recibir:
            - query
        Puede recibir:
            - params => tupla con las variables
            - execute => devuelve los registros
        Devuelve False en caso de error
        """
        if self.connected:
            self.error=""
            try:
                self.cursor.execute(query,params)
                self.db.commit()
                if execute:
                    # convert de result to dictionary
                    result = []
                    columns = tuple([d[0].decode('utf8') for d in self.cursor.description])
                    for row in self.cursor:
                        result.append(dict(zip(columns, row)))
                    return result
                return True
            except Exception,e:
                self.error="Error: %s" % (e)
        return False
 
    def lastId(self):
        """
        Funcion que devuelve el ultimo id añadido
        """
        return self.cursor.lastrowid
 
    def affectedRows(self):
        return self.cursor.rowcount
 
    def mysqlClose(self):
        """
        Funcion para cerrar la conexion con la base de datos
        """
        self.connected=0
        try:
            self.cursor.close()
        except:pass
        try:
            self.cnx.close()
        except:pass
 
    def fetchOneAssoc(self,cursor) :
        data = cursor.fetchone()
        if data == None :
            return None
        desc = cursor.description
 
        dict = {}
 
        for (name, value) in zip(desc, data) :
            dict[name[0]] = value
 
        return dict
 
if __name__=="__main__":
    obj=myMysql()
    result=obj.mysqlConnect('localhost','usuario','pass','MiBaseDeDatos')
    if result:
 
        # ejeplo 1 - INSERT
        print obj.prepare("INSERT INTO tabla VALUES (null, now(), 'http')", None, False)
        print obj.lastId
 
        # ejemplo 2 - UPDATE
        query="UPDATE tabla SET Texto=%s WHERE id=%s"
        params=("XX",20)
        obj.prepare(query,params,False)
        if result:
            print result
        else:
            print obj.error
        print obj.affectedRows()
 
        # ejemplo 3 - SELECT
        result=obj.prepare("SELECT id,Texto FROM tabla WHERE id=%s", (20,))
        if result:
            print result
        else:
            print obj.error
 
        obj.mysqlClose()
    else:
        print obj.error



Comentarios sobre la versión: Versión 2.0 (2)

Imágen de perfil
kip
25 de Agosto del 2017
estrellaestrellaestrellaestrellaestrella
No ha dejado ningún comentario
Responder
Karen
02 de Abril del 2018
estrellaestrellaestrellaestrellaestrella
Muchas gracias, me ayudo mucho :)
Responder

Comentar la versión: Versión 2.0

Nombre
Correo (no se visualiza en la web)
Valoración
Comentarios
Es necesario revisar y aceptar las políticas de privacidad

http://lwp-l.com/s3840  
Revisar política de publicidad