From: yuyangbj <yangyu@vmware.com>
Date: Wed, 13 May 2015 06:07:36 +0000 (+0800)
Subject: Fixes bulk insertion of data to ml2_port_binding
X-Git-Url: https://review.fuel-infra.org/gitweb?a=commitdiff_plain;h=b322ebae09cc59ed0a860ea6e39ed9b6fa6c5c12;p=openstack-build%2Fneutron-build.git

Fixes bulk insertion of data to ml2_port_binding

We should use schema definition to insert bulk of data to table.
Closes-Bug: #1454566

Change-Id: I66b3ee8c2f9fa6f04b9e89dc49d1a3d277d63191
---

diff --git a/neutron/db/migration/alembic_migrations/versions/2b801560a332_remove_hypervneutronplugin_tables.py b/neutron/db/migration/alembic_migrations/versions/2b801560a332_remove_hypervneutronplugin_tables.py
index 315158499..711ebe05e 100644
--- a/neutron/db/migration/alembic_migrations/versions/2b801560a332_remove_hypervneutronplugin_tables.py
+++ b/neutron/db/migration/alembic_migrations/versions/2b801560a332_remove_hypervneutronplugin_tables.py
@@ -32,6 +32,7 @@ revision = '2b801560a332'
 down_revision = '2d2a8a565438'
 
 from alembic import op
+import sqlalchemy as sa
 from sqlalchemy.sql import expression as sa_expr
 
 from neutron.extensions import portbindings
@@ -119,8 +120,9 @@ def _migrate_port_bindings(engine):
         if segment:
             binding['segment'] = segment
     if ml2_bindings:
-        ml2_port_bindings = sa_expr.table('ml2_port_bindings')
-        op.execute(ml2_port_bindings.insert(), ml2_bindings)
+        md = sa.MetaData()
+        sa.Table('ml2_port_bindings', md, autoload=True, autoload_with=engine)
+        op.bulk_insert(md.tables['ml2_port_bindings'], ml2_bindings)
 
 
 def upgrade():