settings文件如下：

DATABASES = { ’default’: { ’ENGINE’: ’django.db.backends.sqlite3’, ’NAME’: os.path.join(BASE_DIR, ’db.sqlite3’), }, ’db1’: { # 配置第二個(gè)數(shù)據(jù)庫(kù)節(jié)點(diǎn)名稱 ’ENGINE’: ’django.db.backends.oracle’, ’NAME’: ’devdb’, ’USER’: ’hysh’, ’PASSWORD’: ’hysh’, ’HOST’: ’192.168.191.3’, ’PORT’: ’1521’, },}

查找Django的文檔：

from django.db import connection def my_custom_sql(self): with connection.cursor() as cursor: cursor.execute('UPDATE bar SET foo = 1 WHERE baz = %s', [self.baz]) cursor.execute('SELECT foo FROM bar WHERE baz = %s', [self.baz]) row = cursor.fetchone() return row

上述方法是設(shè)置中如果有多個(gè)數(shù)據(jù)庫(kù)，會(huì)默認(rèn)使用 default，當(dāng)你想使用指定的數(shù)據(jù)庫(kù)連接時(shí)，引入的對(duì)象就變成了connections ！

from django.db import connection def my_custom_sql(self): with connection.cursor() as cursor: cursor.execute('UPDATE bar SET foo = 1 WHERE baz = %s', [self.baz]) cursor.execute('SELECT foo FROM bar WHERE baz = %s', [self.baz]) row = cursor.fetchone() return row

之后再進(jìn)行操作。

補(bǔ)充知識(shí)：Django多數(shù)據(jù)源接入類

from rest_framework.generics import GenericAPIViewfrom rest_framework.response import Responsefrom rest_framework import statusfrom django.db import transactionfrom .contants import db_dictcontants.py的內(nèi)容（import cx_Oracleimport pymysql# 定義一個(gè)數(shù)據(jù)庫(kù)類型&引擎的字典,db_dict = {’mysql’:pymysql,’Oracle’:cx_Oracle}）from .models import DataSystem,Ruleclass DBconnectView(GenericAPIView): __DBtype = db_dict def get(self,request,pk,rule_id): # 通過傳入的id進(jìn)行對(duì)應(yīng)的數(shù)據(jù)庫(kù)鏈接 self.datas = DataSystem.objects.get(pk=pk) self.url = self.datas.url self.username = self.datas.username self.password = self.datas.password_enc self.DBname = self.datas.name self.DBtype = self.__DBtype[self.datas.type] # 獲取check_code規(guī)則 self.ruledatas = Rule.objects.get(id=rule_id) self.check_code = self.ruledatas.check_code # db = __import__(self.DBtype) try: conn = self.DBtype.connect(host=self.url,user=self.username,password=self.password,database=self.DBname) # 鏈接成功后創(chuàng)建一個(gè)游標(biāo) cs_ms = conn.cursor() except Exception as e: raise e else: # 明顯的開啟事務(wù) with transaction.atomic():# 在安全的地方，創(chuàng)建保存點(diǎn)，將來操作數(shù)據(jù)庫(kù)失敗回滾到此save_id = transaction.savepoint()try: # 獲取一個(gè)元組 db_ret = cs_ms.execute(self.check_code)except Exception as e: transaction.savepoint_rollback(save_id) raise eelse: db_set = db_ret.fetchone() # transaction.savepoint_commit(save_id) finally: cs_ms.close() conn.close() return Response({’pk’:pk,’rule_id’:rule_id})

以上這篇django 鏈接多個(gè)數(shù)據(jù)庫(kù) 并使用原生sql實(shí)現(xiàn)就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持好吧啦網(wǎng)。