mirror of
https://gitlab.com/flectra-community/reporting-engine.git
synced 2024-11-22 22:22:05 +00:00
51 lines
1.3 KiB
Python
51 lines
1.3 KiB
Python
# Copyright 2018 Simone Rubino - Agile Business Group
|
|
# License AGPL-3.0 or later (http://www.gnu.org/licenses/agpl.html).
|
|
|
|
from openupgradelib.openupgrade import logged_query, migrate
|
|
import json
|
|
|
|
|
|
@migrate()
|
|
def migrate(env, version):
|
|
cr = env.cr
|
|
convert_text_to_serialized(
|
|
cr, env['bve.view']._table, env['bve.view']._fields['data'].name)
|
|
pass
|
|
|
|
|
|
def convert_text_to_serialized(
|
|
cr, table, text_field_name, serialized_field_name=None):
|
|
"""
|
|
Convert Text field value to Serialized value.
|
|
"""
|
|
if not serialized_field_name:
|
|
serialized_field_name = text_field_name
|
|
select_query = """
|
|
SELECT
|
|
id,
|
|
%(text_field_name)s
|
|
FROM %(table)s
|
|
WHERE %(text_field_name)s IS NOT NULL
|
|
"""
|
|
cr.execute(
|
|
select_query % {
|
|
'text_field_name': text_field_name,
|
|
'table': table,
|
|
}
|
|
)
|
|
update_query = """
|
|
UPDATE %(table)s
|
|
SET %(serialized_field_name)s = %%(field_value)s
|
|
WHERE id = %(record_id)d
|
|
"""
|
|
for row in cr.fetchall():
|
|
# Fill in the field_value later because it needs escaping
|
|
row_update_query = update_query % {
|
|
'serialized_field_name': serialized_field_name,
|
|
'table': table,
|
|
'record_id': row[0]}
|
|
logged_query(
|
|
cr, row_update_query, {
|
|
'field_value': json.dumps(row[1])
|
|
})
|