CẬP NHẬT MySQL với các biến

Biến được sử dụng để lưu trữ dữ liệu hoặc thông tin trong quá trình thực hiện chương trình. Đó là một cách gán nhãn dữ liệu với một tên thích hợp giúp người đọc hiểu chương trình rõ ràng hơn. Mục đích chính của biến là lưu trữ dữ liệu trong bộ nhớ và có thể sử dụng trong suốt chương trình

MySQL có thể sử dụng các biến theo ba cách khác nhau, được đưa ra dưới đây

1. Biến do người dùng xác định
2. Biến cục bộ
3. Biến hệ thống

Biến do người dùng xác định

Đôi khi, chúng tôi muốn chuyển các giá trị từ câu lệnh này sang câu lệnh khác. Biến do người dùng định nghĩa cho phép chúng ta lưu trữ một giá trị trong một câu lệnh và sau đó có thể tham chiếu giá trị đó đến một câu lệnh khác. MySQL cung cấp câu lệnh SET và SELECT để khai báo và khởi tạo biến. Tên biến do người dùng định nghĩa bắt đầu bằng ký hiệu @

Các biến do người dùng xác định không phân biệt chữ hoa chữ thường, chẳng hạn như @name và @NAME; . Biến do người dùng định nghĩa được khai báo bởi một người không thể hiển thị cho người khác. Chúng ta có thể gán biến do người dùng định nghĩa thành các loại dữ liệu giới hạn như số nguyên, số float, số thập phân, chuỗi hoặc NULL. Biến do người dùng xác định có thể dài tối đa 64 ký tự

cú pháp

Cú pháp sau đây được sử dụng để khai báo một biến do người dùng định nghĩa

1. Bằng cách sử dụng câu lệnh SET

GHI CHÚ. Chúng ta có thể sử dụng '=' hoặc '. =' toán tử gán với câu lệnh SET

2. Bằng cách sử dụng câu lệnh SELECT

Ví dụ 1

Ở đây, chúng ta sẽ gán giá trị cho một biến bằng cách sử dụng câu lệnh SET

Sau đó, chúng ta có thể hiển thị giá trị trên bằng cách sử dụng câu lệnh SELECT

đầu ra

ví dụ 2

Hãy để chúng tôi tạo bảng sinh viên trong cơ sở dữ liệu MySQL, như hình dưới đây

Chạy câu lệnh sau để lấy tuổi tối đa của học sinh trong bảng 'students' và gán tuổi cho biến do người dùng xác định @maxage

Nó sẽ cho đầu ra sau

Bây giờ, hãy chạy câu lệnh SELECT sử dụng biến @maxage để trả về tuổi tối đa của học sinh

Sau khi thực hiện thành công câu lệnh trên ta sẽ được kết quả như sau

Ví dụ3

Nếu chúng ta truy cập vào biến không được khai báo, nó sẽ cho đầu ra NULL

đầu ra

Biến cục bộ

Nó là một loại biến không có tiền tố là ký hiệu @. Biến cục bộ là biến được gõ mạnh. Phạm vi của biến cục bộ nằm trong khối chương trình được lưu trữ trong đó nó được khai báo. MySQL sử dụng từ khóa DECLARE để chỉ định biến cục bộ. Câu lệnh DECLARE cũng kết hợp mệnh đề DEFAULT để cung cấp giá trị mặc định cho một biến. Nếu bạn không cung cấp mệnh đề DEFAULT, nó sẽ cho giá trị ban đầu là NULL. Nó chủ yếu được sử dụng trong chương trình thủ tục được lưu trữ

cú pháp

Chúng ta có thể sử dụng câu lệnh DECLARE với cú pháp sau

Chúng ta hãy xem ví dụ sau để sử dụng biến cục bộ

Thí dụ

Chúng ta cũng có thể định nghĩa hai hoặc nhiều biến có cùng kiểu dữ liệu bằng cách sử dụng một câu lệnh DECLARE

Ví dụ dưới đây giải thích cách chúng ta có thể sử dụng câu lệnh DECLARE trong một thủ tục được lưu trữ

Sau khi thực hiện thành công hàm trên, gọi hàm thủ tục lưu sẵn như bên dưới

Nó sẽ cho đầu ra sau

Biến hệ thống

Biến hệ thống là một lớp đặc biệt cho tất cả các đơn vị chương trình, chứa các biến được xác định trước. MySQL chứa các biến hệ thống khác nhau cấu hình hoạt động của nó và mỗi biến hệ thống chứa một giá trị mặc định. Chúng ta có thể tự động thay đổi một số biến hệ thống bằng cách sử dụng câu lệnh SET khi chạy. Nó cho phép chúng tôi sửa đổi hoạt động của máy chủ mà không cần dừng và khởi động lại nó. Biến hệ thống cũng có thể được sử dụng trong các biểu thức

Máy chủ MySQL cung cấp một loạt các biến hệ thống, chẳng hạn như các loại GLOBAL, SESSION hoặc MIX. Chúng ta có thể thấy biến GLOBAL trong suốt vòng đời của máy chủ, trong khi biến SESSION chỉ hoạt động cho một phiên cụ thể

Lưu ý mệnh đề WHERE trong cú pháp UPDATE. Mệnh đề WHERE chỉ định bản ghi hoặc bản ghi nào sẽ được cập nhật. Nếu bạn bỏ qua mệnh đề WHERE, tất cả các bản ghi sẽ được cập nhật

Để tìm hiểu thêm về SQL, vui lòng truy cập hướng dẫn SQL của chúng tôi

Hãy nhìn vào bảng "MyGuests"

idfirstnamelastnameemailreg_date1JohnDoejohn@example. com2014-10-22 14. 26. 152MaryDoemary@ví dụ. com2014-10-23 10. 22. 30

Bài viết này trình bày cách thực hiện truy vấn CẬP NHẬT MySQL từ Python để sửa đổi dữ liệu của bảng MySQL

Mục tiêu của bài học này. Bạn sẽ tìm hiểu các thao tác CẬP NHẬT MySQL sau đây từ Python bằng cách sử dụng mô-đun 'Trình kết nối MySQL'

• Cập nhật một hàng và nhiều hàng, một và nhiều cột
• Sử dụng biến Python trong truy vấn được tham số hóa để cập nhật các hàng của bảng
• Ngoài ra, Cập nhật cột có giá trị ngày giờ và dấu thời gian
• Vai trò của commit và rollback trong hoạt động cập nhật

Đọc thêm

• Giải bài tập Python MySQL
• Đọc Hướng dẫn Python MySQL (Hướng dẫn đầy đủ)

Mục lục

Điều kiện tiên quyết

Trước khi thực hiện chương trình sau, hãy đảm bảo rằng bạn đã có những thứ sau đây -

• Tên người dùng và mật khẩu mà bạn cần để kết nối MySQL
• Tên bảng cơ sở dữ liệu MySQL mà bạn muốn cập nhật

Đối với bài viết này, tôi đang sử dụng bảng Máy tính xách tay có trong máy chủ MySQL của mình

Nếu một bảng không có trong máy chủ MySQL của bạn, bạn có thể tham khảo bài viết của chúng tôi để tạo một bảng MySQL từ Python

Bạn cũng có thể tải xuống tệp truy vấn SQL chứa các truy vấn SQL để tạo bảng và dữ liệu để bạn có thể sử dụng bảng này cho các hoạt động CẬP NHẬT của mình

Ví dụ để cập nhật một hàng của Bảng MySQL

Để thực hiện truy vấn SQL UPDATE từ Python, bạn cần làm theo các bước sau. –

Cách cập nhật bảng MySQL trong Python

1. Kết nối với MySQL từ Python

   Tham khảo kết nối cơ sở dữ liệu MySQL trên Python để kết nối với cơ sở dữ liệu MySQL từ Python bằng mô-đun MySQL Connector

2. Chuẩn bị truy vấn cập nhật SQL

   Chuẩn bị truy vấn câu lệnh cập nhật với dữ liệu cần cập nhật. VÍ dụ,

   Before updating a row
   (1, 'Lenovo ThinkPad P71', 6459.0, datetime.date(2019, 8, 14))
   Record Updated successfully 
   
   After updating row
   (1, 'Lenovo ThinkPad P71', 7000.0, datetime.date(2019, 8, 14))
   MySQL connection is closed

   1

3. Thực hiện truy vấn CẬP NHẬT, sử dụng con trỏ. hành hình()

   Thực hiện truy vấn CẬP NHẬT bằng phương pháp

   Before updating a row
   (1, 'Lenovo ThinkPad P71', 6459.0, datetime.date(2019, 8, 14))
   Record Updated successfully 
   
   After updating row
   (1, 'Lenovo ThinkPad P71', 7000.0, datetime.date(2019, 8, 14))
   MySQL connection is closed

   2. Phương thức này thực thi thao tác được lưu trữ trong truy vấn CẬP NHẬT

4. Cam kết thay đổi của bạn

   Thực hiện sửa đổi liên tục vào cơ sở dữ liệu bằng cách sử dụng

   Before updating a row
   (1, 'Lenovo ThinkPad P71', 6459.0, datetime.date(2019, 8, 14))
   Record Updated successfully 
   
   After updating row
   (1, 'Lenovo ThinkPad P71', 7000.0, datetime.date(2019, 8, 14))
   MySQL connection is closed

   3 của lớp kết nối

5. Trích xuất số hàng bị ảnh hưởng

   Sau khi thao tác cập nhật thành công, hãy sử dụng phương pháp

   Before updating a row
   (1, 'Lenovo ThinkPad P71', 6459.0, datetime.date(2019, 8, 14))
   Record Updated successfully 
   
   After updating row
   (1, 'Lenovo ThinkPad P71', 7000.0, datetime.date(2019, 8, 14))
   MySQL connection is closed

   4 để lấy số lượng hàng bị ảnh hưởng. Số lượng phụ thuộc vào số lượng hàng bạn đang cập nhật

6. Xác minh kết quả bằng truy vấn SQL SELECT

   Thực hiện truy vấn chọn MySQL từ Python để xem các thay đổi mới

7. Đóng đối tượng con trỏ và đối tượng kết nối cơ sở dữ liệu

   sử dụng phương pháp

   Before updating a row
   (1, 'Lenovo ThinkPad P71', 6459.0, datetime.date(2019, 8, 14))
   Record Updated successfully 
   
   After updating row
   (1, 'Lenovo ThinkPad P71', 7000.0, datetime.date(2019, 8, 14))
   MySQL connection is closed

   5 và

   Before updating a row
   (1, 'Lenovo ThinkPad P71', 6459.0, datetime.date(2019, 8, 14))
   Record Updated successfully 
   
   After updating row
   (1, 'Lenovo ThinkPad P71', 7000.0, datetime.date(2019, 8, 14))
   MySQL connection is closed

   6 để đóng các kết nối mở sau khi công việc của bạn hoàn thành

Hãy xem chương trình ngay bây giờ. Trong chương trình này, chúng tôi đang cập nhật bảng Máy tính xách tay bằng cách thay đổi cột giá của hàng đầu tiên

import mysql.connector

try:
    connection = mysql.connector.connect(host='localhost',
                                         database='electronics',
                                         user='pynative',
                                         password='pynative@#29')
    cursor = connection.cursor()

    print("Before updating a record ")
    sql_select_query = """select * from Laptop where id = 1"""
    cursor.execute(sql_select_query)
    record = cursor.fetchone()
    print(record)

    # Update single record now
    sql_update_query = """Update Laptop set Price = 7000 where id = 1"""
    cursor.execute(sql_update_query)
    connection.commit()
    print("Record Updated successfully ")

    print("After updating record ")
    cursor.execute(sql_select_query)
    record = cursor.fetchone()
    print(record)

except mysql.connector.Error as error:
    print("Failed to update table record: {}".format(error))
finally:
    if connection.is_connected():
        connection.close()
        print("MySQL connection is closed")

đầu ra

Before updating a row
(1, 'Lenovo ThinkPad P71', 6459.0, datetime.date(2019, 8, 14))
Record Updated successfully 

After updating row
(1, 'Lenovo ThinkPad P71', 7000.0, datetime.date(2019, 8, 14))
MySQL connection is closed

Ghi chú

• Đừng quên đóng con trỏ và các đối tượng kết nối cơ sở dữ liệu và Nắm bắt mọi ngoại lệ SQL có thể xảy ra trong quá trình này
• Chúng tôi cũng đã sử dụng phương thức commit() và rollback(). cam kết () để thực hiện các thay đổi liên tục trong cơ sở dữ liệu và khôi phục () hoàn nguyên các thay đổi nếu xảy ra bất kỳ lỗi cơ sở dữ liệu nào

Sử dụng một biến Python trong truy vấn Cập nhật MySQL

Đôi khi chúng tôi cần đầu vào từ người dùng, chẳng hạn như khi người dùng cập nhật mật khẩu của họ hoặc bất kỳ chi tiết nào khác thông qua Giao diện người dùng. Hoặc khi bạn muốn cập nhật chi tiết động bằng cách chuyển các biến Python vào một truy vấn. Chẳng hạn như cài đặt giá trị cột bằng cách sử dụng biến

Cách tốt nhất là sử dụng truy vấn được tham số hóa và câu lệnh chuẩn bị sẵn, tôi. e. , trình giữ chỗ (

Before updating a row
(1, 'Lenovo ThinkPad P71', 6459.0, datetime.date(2019, 8, 14))
Record Updated successfully 

After updating row
(1, 'Lenovo ThinkPad P71', 7000.0, datetime.date(2019, 8, 14))
MySQL connection is closed

Hãy xem chương trình ví dụ ngay bây giờ

import mysql.connector

def update_laptop_price(id, price):
    try:
        connection = mysql.connector.connect(host='localhost',
                                             database='electronics',
                                             user='roo',
                                             password='pynative@#29')

        cursor = connection.cursor()
        sql_update_query = """Update laptop set price = %s where id = %s"""
        input_data = (price, id)
        cursor.execute(sql_update_query, input_data)
        connection.commit()
        print("Record Updated successfully ")

    except mysql.connector.Error as error:
        print("Failed to update record to database: {}".format(error))
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()
            print("MySQL connection is closed")

update_laptop_price(7500, 1)
update_laptop_price(5000, 2)

đầu ra. –

Record Updated successfully 
MySQL connection is closed
Record Updated successfully 
MySQL connection is closed

Hãy hiểu chương trình trên. –

• Chúng tôi đã sử dụng câu lệnh đã chuẩn bị để chấp nhận đầu vào của người dùng bằng cách sử dụng trình giữ chỗ, tôi. e. , chúng tôi đặt hai trình giữ chỗ trong truy vấn cập nhật, một cho cột "Giá" và một cho cột "id"
• Tiếp theo, chúng tôi đã thêm giá trị hai cột đó ở định dạng bộ dữ liệu theo thứ tự tuần tự và chuyển truy vấn cập nhật SQL và bộ dữ liệu đầu vào cho phương thức

  Before updating a row
  (1, 'Lenovo ThinkPad P71', 6459.0, datetime.date(2019, 8, 14))
  Record Updated successfully 
  
  After updating row
  (1, 'Lenovo ThinkPad P71', 7000.0, datetime.date(2019, 8, 14))
  MySQL connection is closed

  2. Hãy nhớ bộ dữ liệu chứa dữ liệu người dùng theo thứ tự tuần tự của trình giữ chỗ
• Cuối cùng, chúng tôi cam kết các thay đổi của mình đối với cơ sở dữ liệu bằng cách sử dụng

  Before updating a row
  (1, 'Lenovo ThinkPad P71', 6459.0, datetime.date(2019, 8, 14))
  Record Updated successfully 
  
  After updating row
  (1, 'Lenovo ThinkPad P71', 7000.0, datetime.date(2019, 8, 14))
  MySQL connection is closed

  9

Cập nhật nhiều hàng của bảng MySQL bằng Python

Có thể cập nhật nhiều hàng trong một Truy vấn SQL. Bạn cũng có thể gọi nó là cập nhật hàng loạt. Sử dụng phương thức

import mysql.connector

def update_laptop_price(id, price):
    try:
        connection = mysql.connector.connect(host='localhost',
                                             database='electronics',
                                             user='roo',
                                             password='pynative@#29')

        cursor = connection.cursor()
        sql_update_query = """Update laptop set price = %s where id = %s"""
        input_data = (price, id)
        cursor.execute(sql_update_query, input_data)
        connection.commit()
        print("Record Updated successfully ")

    except mysql.connector.Error as error:
        print("Failed to update record to database: {}".format(error))
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()
            print("MySQL connection is closed")

update_laptop_price(7500, 1)
update_laptop_price(5000, 2)

Cú pháp của phương thức execmany()

cursor.executemany(operation, seq_of_params)

Phương thức này thực thi

import mysql.connector

def update_laptop_price(id, price):
    try:
        connection = mysql.connector.connect(host='localhost',
                                             database='electronics',
                                             user='roo',
                                             password='pynative@#29')

        cursor = connection.cursor()
        sql_update_query = """Update laptop set price = %s where id = %s"""
        input_data = (price, id)
        cursor.execute(sql_update_query, input_data)
        connection.commit()
        print("Record Updated successfully ")

    except mysql.connector.Error as error:
        print("Failed to update record to database: {}".format(error))
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()
            print("MySQL connection is closed")

update_laptop_price(7500, 1)
update_laptop_price(5000, 2)

import mysql.connector

def update_laptop_price(id, price):
    try:
        connection = mysql.connector.connect(host='localhost',
                                             database='electronics',
                                             user='roo',
                                             password='pynative@#29')

        cursor = connection.cursor()
        sql_update_query = """Update laptop set price = %s where id = %s"""
        input_data = (price, id)
        cursor.execute(sql_update_query, input_data)
        connection.commit()
        print("Record Updated successfully ")

    except mysql.connector.Error as error:
        print("Failed to update record to database: {}".format(error))
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()
            print("MySQL connection is closed")

update_laptop_price(7500, 1)
update_laptop_price(5000, 2)

import mysql.connector

try:
    connection = mysql.connector.connect(host='localhost',
                                         database='electronics',
                                         user='pynative',
                                         password='pynative@#29')

    cursor = connection.cursor()
    sql_update_query = """Update Laptop set Price = %s where id = %s"""

    # multiple records to be updated in tuple format
    records_to_update = [(3000, 3), (2750, 4)]
    cursor.executemany(sql_update_query, records_to_update)
    connection.commit()

    print(cursor.rowcount, "Records of a laptop table updated successfully")

except mysql.connector.Error as error:
    print("Failed to update records to database: {}".format(error))
finally:
    if connection.is_connected():
        connection.close()
        print("MySQL connection is closed")

đầu ra

2 Records of a laptop table updated successfully
connection is closed

Hãy hiểu chương trình trên

• Chúng tôi đã xác định truy vấn cập nhật SQL với hai trình giữ chỗ (“Cột Giá” và “Id” ). và chuẩn bị một danh sách các bản ghi sẽ được cập nhật. Danh sách này chứa một bộ cho mỗi hàng. Ở đây chúng tôi đã tạo hai bộ dữ liệu, vì vậy chúng tôi được cập nhật hai hàng
• Chúng tôi đã sử dụng phương pháp

  import mysql.connector
  
  def update_laptop_price(id, price):
      try:
          connection = mysql.connector.connect(host='localhost',
                                               database='electronics',
                                               user='roo',
                                               password='pynative@#29')
  
          cursor = connection.cursor()
          sql_update_query = """Update laptop set price = %s where id = %s"""
          input_data = (price, id)
          cursor.execute(sql_update_query, input_data)
          connection.commit()
          print("Record Updated successfully ")
  
      except mysql.connector.Error as error:
          print("Failed to update record to database: {}".format(error))
      finally:
          if connection.is_connected():
              cursor.close()
              connection.close()
              print("MySQL connection is closed")
  
  update_laptop_price(7500, 1)
  update_laptop_price(5000, 2)

  0 để cập nhật nhiều hàng của bảng cơ sở dữ liệu
• Sử dụng

  Before updating a row
  (1, 'Lenovo ThinkPad P71', 6459.0, datetime.date(2019, 8, 14))
  Record Updated successfully 
  
  After updating row
  (1, 'Lenovo ThinkPad P71', 7000.0, datetime.date(2019, 8, 14))
  MySQL connection is closed

  4, chúng tôi có thể tìm thấy có bao nhiêu hàng được cập nhật thành công

Python cập nhật nhiều Cột của bảng MySQL

Chúng tôi cũng có thể cập nhật nhiều cột của bảng MySQL trong một truy vấn. Sử dụng truy vấn được tham số hóa bằng trình giữ chỗ để cập nhật nhiều cột. Hãy xem điều này với một chương trình ví dụ

import mysql.connector

try:
    connection = mysql.connector.connect(host='localhost',
                                         database='electronics',
                                         user='pynative',
                                         password='pynative@#29')

    cursor = connection.cursor()
    sql_update_query = """Update Laptop set Name = %s, Price = %s where id = %s"""

    name = "HP Pavilion"
    price = 2200
    id = 4
    input = (name, price, id)

    cursor.execute(sql_update_query, input)
    connection.commit()
    print("Multiple columns updated successfully ")

except mysql.connector.Error as error:
    print("Failed to update columns of table: {}".format(error))

finally:
    if connection.is_connected():
        connection.close()
        print("MySQL connection is closed")

đầu ra

Multiple column updated successfully
MySQL connection is closed

Cập nhật cột ngày giờ và dấu thời gian của bảng MySQL từ Python

Giả sử bạn có một cột ngày trong bảng MySQL và bạn muốn cập nhật một đối tượng

import mysql.connector

def update_laptop_price(id, price):
    try:
        connection = mysql.connector.connect(host='localhost',
                                             database='electronics',
                                             user='roo',
                                             password='pynative@#29')

        cursor = connection.cursor()
        sql_update_query = """Update laptop set price = %s where id = %s"""
        input_data = (price, id)
        cursor.execute(sql_update_query, input_data)
        connection.commit()
        print("Record Updated successfully ")

    except mysql.connector.Error as error:
        print("Failed to update record to database: {}".format(error))
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()
            print("MySQL connection is closed")

update_laptop_price(7500, 1)
update_laptop_price(5000, 2)

import mysql.connector

def update_laptop_price(id, price):
    try:
        connection = mysql.connector.connect(host='localhost',
                                             database='electronics',
                                             user='roo',
                                             password='pynative@#29')

        cursor = connection.cursor()
        sql_update_query = """Update laptop set price = %s where id = %s"""
        input_data = (price, id)
        cursor.execute(sql_update_query, input_data)
        connection.commit()
        print("Record Updated successfully ")

    except mysql.connector.Error as error:
        print("Failed to update record to database: {}".format(error))
    finally:
        if connection.is_connected():
            cursor.close()
            connection.close()
            print("MySQL connection is closed")

update_laptop_price(7500, 1)
update_laptop_price(5000, 2)

from datetime import datetime

import mysql.connector

try:
    connection = mysql.connector.connect(host='localhost',
                                         database='electronics',
                                         user='pynative',
                                         password='pynative@#29')

    cursor = connection.cursor()
    sql_update_query = """Update Laptop set Purchase_date = %s where id = %s"""

    current_Date = datetime.now()
    formatted_date = current_Date.strftime('%Y-%m-%d %H:%M:%S')
    id = 2
    input = (formatted_date, id)
    cursor.execute(sql_update_query, input)
    connection.commit()
    print("Purchased Date Updated successfully ")

except mysql.connector.Error as error:
    print("Failed to update purchased date {}".format(error))

finally:
    if connection.is_connected():
        connection.close()
        print("connection is closed")

Bạn sẽ nhận được kết quả sau khi thực thi đoạn mã trên

Before updating a row
(1, 'Lenovo ThinkPad P71', 6459.0, datetime.date(2019, 8, 14))
Record Updated successfully 

After updating row
(1, 'Lenovo ThinkPad P71', 7000.0, datetime.date(2019, 8, 14))
MySQL connection is closed

Bước tiếp theo

Để thực hành những gì bạn đã học trong bài học này, hãy giải một project Bài tập cơ sở dữ liệu Python để thực hành và thành thạo các thao tác Cơ sở dữ liệu Python

Làm cách nào để CẬP NHẬT các biến toàn cục trong MySQL?

Làm cách nào để CẬP NHẬT các giá trị trong MySQL?

Làm cách nào để chuyển các giá trị động trong truy vấn MySQL?

Làm cách nào để sử dụng các biến trong truy vấn MySQL?