时间:2021-05-22
settings文件如下:
DATABASES = { 'default': { 'ENGINE': 'django.db.backends.sqlite3', 'NAME': os.path.join(BASE_DIR, 'db.sqlite3'), }, 'db1': { # 配置第二个数据库节点名称 '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上述方法是设置中如果有多个数据库,会默认使用 default,当你想使用指定的数据库连接时,引入的对象就变成了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之后再进行操作。
补充知识:Django多数据源接入类
from rest_framework.generics import GenericAPIViewfrom rest_framework.response import Responsefrom rest_framework import statusfrom django.db import transactionfrom .contants import db_dictcontants.py的内容(import cx_Oracleimport pymysql# 定义一个数据库类型&引擎的字典,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进行对应的数据库链接 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规则 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) # 链接成功后创建一个游标 cs_ms = conn.cursor() except Exception as e: raise e else: # 明显的开启事务 with transaction.atomic(): # 在安全的地方,创建保存点,将来操作数据库失败回滚到此 save_id = transaction.savepoint() try: # 获取一个元组 db_ret = cs_ms.execute(self.check_code) except Exception as e: transaction.savepoint_rollback(save_id) raise e else: 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 链接多个数据库 并使用原生sql实现就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
需求:一条SQL语句从多个数据库查询出相关联的结果,输出到客户端调查:spring框架可以配置多数据源;sql也可以将多个数据库附加到一个主数据库下解决办法:用
django外键使用一对一因为django中处于安全和方便将数据库中的表封装成模型,所以很多sql原生的功能无法使用,比如leftjoin,但是我们可以使用外键
在django项目中,一个工程中存在多个APP应用很常见.有时候希望不同的APP连接不同的数据库,这个时候需要建立多个数据库连接。1.修改项目的settings
Django项目默认使用sqlite数据库,但是我想用mysql数据库,应该如何配置呢。Django连接mysql数据库的操作,是通过根模块的配置实现的,在项目
如题,本次是要实现点击超链接实现执行js代码,并确认是否删除数据库数据,采用php。首先链接数据库,查询数据库数据:复制代码代码如下:prepare($quer