@@ -153,11 +153,10 @@ def _cleanBuildScript(self, type_:str, file_name_:str):
153
153
)
154
154
)
155
155
self ._conn .commit ()
156
-
157
- def _listProcedures (self ):
156
+ def _showStatus (self , type_ :str ):
158
157
lista = []
159
158
self ._cur .execute (
160
- "SHOW PROCEDURE STATUS WHERE db = ?" ,
159
+ "SHOW " + type_ + " STATUS WHERE db = ?" ,
161
160
[
162
161
self ._config .get ('database' )
163
162
]
@@ -177,61 +176,32 @@ def _listProcedures(self):
177
176
) in self ._cur :
178
177
lista .append (Name )
179
178
return lista
179
+ def _dropIfExists (self , type_ :str , name_ :str ):
180
+ self ._cur .execute (
181
+ "DROP " + type_ + " `" + name_ + "`;"
182
+ )
183
+ self ._p ("Delete " + type_ + " " + name_ )
184
+ self ._conn .commit ()
180
185
def _showProcedures (self ):
181
186
for (
182
187
Name
183
- ) in self ._listProcedures ( ):
188
+ ) in self ._showStatus ( "PROCEDURE" ):
184
189
self ._p (f"{ Name } " )
185
- def _deleteProcedure (self , procedure :str ):
186
- self ._cur .execute (
187
- f"DROP PROCEDURE `{ procedure } `;"
188
- )
189
- self ._p (f"Delete procedure { procedure } " )
190
- self ._conn .commit ()
191
190
def _deleteAllProcedures (self ):
192
191
for (
193
192
Name
194
- ) in self ._listProcedures ():
195
- self ._deleteProcedure (Name )
196
- def _listFunctions (self ):
197
- lista = []
198
- self ._cur .execute (
199
- "SHOW FUNCTION STATUS WHERE db = ?" ,
200
- [
201
- self ._config .get ('database' )
202
- ]
203
- )
204
- for (
205
- Db ,
206
- Name ,
207
- Type ,
208
- Definer ,
209
- Modified ,
210
- Created ,
211
- Security_type ,
212
- Comment ,
213
- character_set_client ,
214
- collation_connection ,
215
- coll
216
- ) in self ._cur :
217
- lista .append (Name )
218
- return lista
193
+ ) in self ._showStatus ("PROCEDURE" ):
194
+ self ._dropIfExists ("PROCEDURE" , Name )
219
195
def _showFunctions (self ):
220
196
for (
221
197
Name
222
- ) in self ._listFunctions ( ):
198
+ ) in self ._showStatus ( "FUNCTION" ):
223
199
self ._p (f"{ Name } " )
224
- def _deleteFunction (self , function :str ):
225
- self ._cur .execute (
226
- f"DROP FUNCTION `{ function } `;"
227
- )
228
- self ._p (f"Delete function { function } " )
229
- self ._conn .commit ()
230
200
def _deleteAllFunctions (self ):
231
201
for (
232
202
Name
233
- ) in self ._listFunctions ( ):
234
- self ._deleteFunction ( Name )
203
+ ) in self ._showStatus ( "FUNCTION" ):
204
+ self ._dropIfExists ( "FUNCTION" , Name )
235
205
def _listViews (self ):
236
206
lista = []
237
207
self ._cur .execute (
@@ -248,17 +218,11 @@ def _showViews(self):
248
218
Name
249
219
) in self ._listViews ():
250
220
self ._p (f"{ Name } " )
251
- def _deleteView (self , table :str ):
252
- self ._cur .execute (
253
- f"DROP VIEW IF EXISTS `{ table } `;" ,
254
- )
255
- self ._p (f"Delete table { table } " )
256
- self ._conn .commit ()
257
221
def _deleteAllViews (self ):
258
222
for (
259
223
Name
260
224
) in self ._listViews ():
261
- self ._deleteView ( Name )
225
+ self ._dropIfExists ( "VIEW" , Name )
262
226
def _listTables (self ):
263
227
lista = []
264
228
self ._cur .execute (
@@ -276,15 +240,10 @@ def _showTables(self):
276
240
Name
277
241
) in self ._listTables ():
278
242
self ._p (f"{ Name } " )
279
- def _deleteTable (self , table :str ):
280
- self ._cur .execute (
281
- f"DROP TABLES IF EXISTS `{ table } `;" ,
282
- )
283
- self ._p (f"Delete table { table } " )
284
- self ._conn .commit ()
285
243
def _deleteAllTables (self ):
286
244
for (
287
245
Name
288
246
) in self ._listTables ():
289
- self ._deleteTable (Name )
247
+ self ._p (f"{ Name } " )
248
+ self ._dropIfExists ("TABLES" , Name )
290
249
0 commit comments