fa9e303fe4
All configuration is driven through configuration files place in the conf directory. Each .ini conf file contains info on the configuration. README file updated to reflect all the changes. Fixed issue with delete_network deleting the network even when attachments were present. Fixed issue with port id generation.
60 lines
1.9 KiB
Python
60 lines
1.9 KiB
Python
# vim: tabstop=4 shiftwidth=4 softtabstop=4
|
|
#
|
|
# Copyright 2011 Cisco Systems, Inc. All rights reserved.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
#
|
|
# @author: Sumit Naiksatam, Cisco Systems, Inc.
|
|
#
|
|
|
|
import MySQLdb
|
|
import logging as LOG
|
|
import sys
|
|
import traceback
|
|
|
|
from quantum.common import exceptions as exc
|
|
from quantum.plugins.cisco.common import cisco_constants as const
|
|
from quantum.plugins.cisco.common import cisco_credentials as cred
|
|
from quantum.plugins.cisco.common import cisco_nova_configuration as conf
|
|
|
|
LOG.basicConfig(level=LOG.WARN)
|
|
LOG.getLogger(const.LOGGER_COMPONENT_NAME)
|
|
|
|
|
|
class DBUtils(object):
|
|
|
|
def __init__(self):
|
|
pass
|
|
|
|
def _get_db_connection(self):
|
|
db_ip = conf.DB_SERVER_IP
|
|
db_username = conf.DB_USERNAME
|
|
db_password = conf.DB_PASSWORD
|
|
self.db = MySQLdb.connect(db_ip, db_username, db_password,
|
|
conf.DB_NAME)
|
|
return self.db
|
|
|
|
def execute_db_query(self, sql_query):
|
|
db = self._get_db_connection()
|
|
cursor = db.cursor()
|
|
try:
|
|
cursor.execute(sql_query)
|
|
results = cursor.fetchall()
|
|
db.commit()
|
|
LOG.debug("DB query execution succeeded: %s" % sql_query)
|
|
except:
|
|
db.rollback()
|
|
LOG.debug("DB query execution failed: %s" % sql_query)
|
|
traceback.print_exc()
|
|
db.close()
|