|
4 | 4 |
|
5 | 5 | import pytest
|
6 | 6 |
|
7 |
| -from asyncmy.cursors import DictCursor |
| 7 | +from asyncmy.cursors import DictCursor, RE_INSERT_VALUES |
8 | 8 |
|
9 | 9 |
|
10 | 10 | @pytest.mark.asyncio
|
@@ -140,3 +140,41 @@ async def test_insert_enum(connection):
|
140 | 140 | ),
|
141 | 141 | )
|
142 | 142 | assert rows == 1
|
| 143 | + |
| 144 | + |
| 145 | +def test_executemany_regex(): |
| 146 | + query = "INSERT INTO foo (bar, baz) VALUES (%s, %s)" |
| 147 | + match = RE_INSERT_VALUES.match(query) |
| 148 | + assert match is not None |
| 149 | + assert match.group(1) == "INSERT INTO foo (bar, baz) VALUES " |
| 150 | + assert match.group(2) == "(%s, %s)" |
| 151 | + assert match.group(3) == "" |
| 152 | + |
| 153 | + # Deprecated VALUES syntax |
| 154 | + query = "INSERT INTO foo (bar, baz) VALUES (%s, %s) ON DUPLICATE KEY UPDATE baz=VALUES(baz)" |
| 155 | + match = RE_INSERT_VALUES.match(query) |
| 156 | + assert match is not None |
| 157 | + assert match.group(1) == "INSERT INTO foo (bar, baz) VALUES " |
| 158 | + assert match.group(2) == "(%s, %s)" |
| 159 | + assert match.group(3) == " ON DUPLICATE KEY UPDATE baz=VALUES(baz)" |
| 160 | + |
| 161 | + # The new syntax |
| 162 | + query = "INSERT INTO foo (bar, baz) VALUES (%s, %s) AS new ON DUPLICATE KEY UPDATE baz=new.baz" |
| 163 | + match = RE_INSERT_VALUES.match(query) |
| 164 | + assert match is not None |
| 165 | + assert match.group(1) == "INSERT INTO foo (bar, baz) VALUES " |
| 166 | + assert match.group(2) == "(%s, %s)" |
| 167 | + assert match.group(3) == " AS new ON DUPLICATE KEY UPDATE baz=new.baz" |
| 168 | + |
| 169 | + # Test REPLACE VALUES |
| 170 | + query = "REPLACE INTO foo (bar, baz, aa, bb) VALUES (%s, %s, %s, %s)" |
| 171 | + match = RE_INSERT_VALUES.match(query) |
| 172 | + assert match is not None |
| 173 | + assert match.group(1) == "REPLACE INTO foo (bar, baz, aa, bb) VALUES " |
| 174 | + assert match.group(2) == "(%s, %s, %s, %s)" |
| 175 | + assert match.group(3) == "" |
| 176 | + |
| 177 | + # Test invalid queries |
| 178 | + query = "INSERT INTO foo (bar, baz) VALUES (%s, %s), (%s, %s)" |
| 179 | + match = RE_INSERT_VALUES.match(query) |
| 180 | + assert match is None |
0 commit comments