mysql插入数据,获取最新插入的ID(自增列)的思路和python获取MySQL自增ID代码三种实现

怼烎@ 2022-05-17 10:49 320阅读 0赞

### mysql插入数据，获取最新插入的ID（自增列）的思路和**python获取MySQL自增ID代码三种实现** ###

*mysql本身有一个列可以做自增长字段，mysql在插入一条数据后，如何能获得到这个自增id的值呢？*

**（1）方法一 是使用last\_insert\_id**

mysql> SELECT LAST\_INSERT\_ID();

产生的ID 每次连接后保存在服务器中。这意味着函数向一个给定客户端返回的值是该客户端产生对影响AUTO\_INCREMENT列的最新语句第一个 AUTO\_INCREMENT值的。这个值不能被其它客户端影响，即使它们产生它们自己的 AUTO\_INCREMENT值。这个行为保证了你能够找回自己的 ID 而不用担心其它客户端的活动，而且不需要加锁或处理。

每次mysql\_query操作在mysql服务器上可以理解为一次“原子”操作, 写操作常常需要锁表的， 是mysql应用服务器锁表不是我们的应用程序锁表。

***值得注意的是，如果你一次插入了多条记录，这个函数返回的是第一个记录的ID值。***

因为LAST\_INSERT\_ID是基于Connection的，只要每个线程都使用独立的Connection对象，LAST\_INSERT\_ID函数将返回该Connection对AUTO\_INCREMENT列最新的insert or update\*作生成的第一个record的ID。这个值不能被其它客户端（Connection）影响，保证了你能够找回自己的 ID 而不用担心其它客户端的活动，而且不需要加锁。使用单INSERT语句插入多条记录, LAST\_INSERT\_ID返回一个列表。

LAST\_INSERT\_ID 是与table无关的，如果向表a插入数据后，再向表b插入数据，LAST\_INSERT\_ID会改变。

**（2）方法二是使用max(id)**

使用last\_insert\_id是基础连接的，如果换一个窗口的时候调用则会一直返回10

如果不是频繁的插入我们也可以使用这种方法来获取返回的id值

select max(id) from stu\_info;

这个方法的缺点是不适合高并发。如果同时插入的时候返回的值可能不准确。

在MySQL中，使用auto\_increment类型的id字段作为表的主键。通常的做法，是通过“select max(id) from tablename”的做法，但是显然这种做法需要考虑并发的情况，需要在事务中对主表以“X锁“，待获得max(id)的值以后，再解锁。

这种做法需要的步骤比较多，有些麻烦，而且并发性也不好。有没有更简单的做法呢？答案之一是通过select LAST\_INSERT\_ID()这个操作。乍一看，它和select max(id)很象，但实际上它是线程安全的。也就是说它是基于数据库连接的，基于数据库连接是什么意义呢？举例说明：

1)、在连接1中向A表插入一条记录，A表包含一个auto\_increment类型的id。

2)、在连接2中向A表再插入一条记录。

3)、结果：在连接1中执行select LAST\_INSERT\_ID()得到的结果和连接2中执行select LAST\_INSERT\_ID()的结果是不同的；而在两个连接中执行select max(id)的结果是相同的。

**（4）python获取MySQL自增ID代码三种实现：**

Python通过MySQLdb向MySQL读写数据，如果表中含有自增主键，想要获取本次插入数据的ID代码如下：

>     # -*- coding: UTF-8 -*-
>     import sys
>     reload(sys)
>     sys.setdefaultencoding("utf-8")
>     import MySQLdb
>     import json
>     class Mysql():
>         def return_id(self):
>             conn = MySQLdb.connect(host=self.__my_host, user=self.__my_user, passwd=self.__my_passwd,
>                                    db=self.__my_db, port=int(self.__my_port), charset=self.__my_charset)
>             cursor = conn.cursor()
>     
>             # 代码块A
>             user_id = 10010
>             name = "Tom"
>             sql_insert = "insert spark_db.stu_info(user_id,name) values ('%s','%s')" % (str(user_id), str(name))
>             rs = cursor.execute(sql_insert)
>     
>             # # 代码块B
>             # sql_update = "update spark_db.stu_info set  name ='%s',user_id= '%s' where id = 40 " % (str('张三'),str(2000) )
>             # rs = cursor.execute(sql_update)
>     
>             print "此次操作影响的行数为: rs", rs  # 此次插入操作影响的行数
>     
>             # 方法一，使用insert_id()方法:  插入一条记录后，获取这条数据所在的自增ID
>             print "使用insert_id()函数 ",
>             print "conn.insert_id()", conn.insert_id()
>             conn.commit()
>     
>             # 方法二，使用LAST_INSERT_ID()方法: 插入一条记录后，获取这条数据所在的自增ID
>             print "使用LAST_INSERT_ID()函数 ",
>             sql = ''' select LAST_INSERT_ID() '''
>             num = cursor.execute(sql)
>             if num>0:
>                 print cursor.fetchall()
>             # 方法三，使用max()方法: 插入一条记录后，获取这条数据所在的自增ID
>             sql = ''' select max(id) from spark_db.stu_info'''
>             print "使用max()函数 ",
>             num = cursor.execute(sql)
>             if num > 0:
>                 print cursor.fetchall()
>     
>     def test_main():
>         with open("./config/mysql.json", "r") as f:
>             config_json = json.loads(f.read())
>         print "config_json\n", config_json
>         mysql_client = Mysql(in_config_json=config_json['titan_db'])
>         print "\n数据插入之前\n"
>         num=mysql_client.execute_db("select * from spark_db.stu_info ")
>         if num>0:
>             print mysql_client.fetchall_db()
>         print "\n数据插入操作\n"
>     
>         mysql_client.return_id()
>     
>         print "\n数据插入后\n"
>         num = mysql_client.execute_db("select * from spark_db.stu_info ")
>         if num > 0:
>             print mysql_client.fetchall_db()
>     if __name__ == '__main__':
>         test_main()

代码块A的输出结果如下：

> 数据插入之前
> 
> (\{'user\_id': 10010L, 'id': 27L, 'name': u'Tom'\},)
> 
> 数据插入操作
> 
> 此次操作影响的行数为: rs 1  
> 使用insert\_id()函数  conn.insert\_id() 29  
> 使用LAST\_INSERT\_ID()函数  ((29L,),)  
> 使用max()函数  ((29L,),)
> 
> 数据插入后
> 
> (\{'user\_id': 10010L, 'id': 27L, 'name': u'Tom'\}, \{'user\_id': 10010L, 'id': 29L, 'name': u'Tom'\})

代码块B的输出结果如下：

> 数据插入操作
> 
> 此次操作影响的行数为: rs 0  
> 使用insert\_id()函数  conn.insert\_id() 0  
> 使用LAST\_INSERT\_ID()函数  ((0L,),)  
> 使用max()函数  ((41L,),)

所有返回自增ID只能是insert操作，而不是update操作

参考：[https://blog.csdn.net/anan890624/article/details/50808515][https_blog.csdn.net_anan890624_article_details_50808515]

[https_blog.csdn.net_anan890624_article_details_50808515]: https://blog.csdn.net/anan890624/article/details/50808515