0009-sql-update-user_name-column-of-wcs_all_forms-on-name.patch

Frédéric Péters, 25 mars 2022 14:53

Voir les différences: en ligne côte à côte

Subject: [PATCH 9/9] sql: update user_name column of wcs_all_forms on name
 changes (#60552)

 tests/test_sql.py                             | 29 +++++++++++++++++++
 wcs/ctl/management/commands/convert_to_sql.py |  6 ++--
 wcs/sql.py                                    |  8 +++--
 3 files changed, 38 insertions(+), 5 deletions(-)

         assert bool(cur.fetchone()[0] == 2)
     def test_all_forms_user_name_change(pub, formdef):
         sql.SqlUser.wipe()
         user = sql.SqlUser()
         user.name = 'Foo'
         user.store()
         formdata = formdef.data_class()()
         formdata.user_id = user.id
         formdata.store()
         objects = sql.AnyFormData.select()
         assert len(objects) == 1
         assert objects[0].user_id == str(user.id)
         conn, cur = sql.get_connection_and_cursor()
         cur.execute('SELECT user_name FROM wcs_all_forms')
         row = cur.fetchone()
         assert row[0] == 'Foo'
         user.name = 'Foo Bar'
         user.store()
         cur.execute('SELECT user_name FROM wcs_all_forms')
         row = cur.fetchone()
         assert row[0] == 'Foo Bar'
         cur.close()
         conn.commit()
     def test_views_fts(pub):
         drop_formdef_tables()
         _, cur = sql.get_connection_and_cursor()

                 atomic_write(options_file, force_bytes(stringio.getvalue()))
         def store_users(self):
             self.convert_objects('user', User, sql.SqlUser)
             self.convert_objects('user', User, sql.SqlUser, skip_global_forms_table_update=True)
             sql.SqlUser.fix_sequences()
         def store_roles(self):
             self.convert_objects('role', Role, sql.Role)
         def convert_objects(self, object_name, object_class, object_sql_class):
         def convert_objects(self, object_name, object_class, object_sql_class, **kwargs):
             errors = []
             print('converting %ss' % object_name)
             getattr(sql, 'do_%s_table' % object_name)()
-...
                 obj = object_class.get(obj_id)
                 obj.__class__ = object_sql_class
                 try:
                     obj.store()
                     obj.store(**kwargs)
                 except AssertionError:
                     errors.append((obj, traceback.format_exc()))
                 self.update_progress(100 * i / count)

     LANGUAGE plpgsql
     AS $$
     BEGIN
         -- TODO : sync back from users change !
         IF TG_OP = 'DELETE' THEN
             DELETE FROM wcs_all_forms WHERE formdef_id = {formdef_id} AND id = OLD.id;
             RETURN OLD;
-...
         @guard_postgres
         @invalidate_substitution_cache
         def store(self):
         def store(self, skip_global_forms_table_update=False):
             sql_dict = {
                 'name': self.name,
                 'ascii_name': self.ascii_name,
-...
+            )
             cur.execute(sql_statement, {'id': self.id, 'fts': ' '.join(fts_strings)})
             if not skip_global_forms_table_update:
                 # update wcs_all_forms rows with potential name change
                 sql_statement = 'UPDATE wcs_all_forms SET user_name = %(user_name)s WHERE user_id = %(user_id)s'
                 cur.execute(sql_statement, {'user_id': str(self.id), 'user_name': self.name})
             conn.commit()
             cur.close()
+    -

Projet

Général

Profil

Produits Entr'ouvert » w.c.s.

0009-sql-update-user_name-column-of-wcs_all_forms-on-name.patch