为 Django.db 连接对象指定只读访问权限
Specifying Readonly access for Django.db connection object
我有一系列集成级测试,这些测试 运行 作为我的 Django 项目中的管理命令。这些测试正在验证从外部来源摄取到我的数据库中的大量天气数据的完整性。因为我有如此大量的数据,所以我真的必须针对我的生产数据库进行测试才能使测试有意义。我想弄清楚的是如何定义特定于该命令或连接对象的只读数据库连接。我还应该补充一点,这些测试不能通过 ORM,所以我需要执行原始 SQL。
我的测试结构如下所示
class Command(BaseCommand):
help = 'Runs Integration Tests and Query Tests against Prod Database'
def handle(self,*args, **options):
suite = unittest.TestLoader().loadTestsFromTestCase(TestWeatherModel)
ret = unittest.TextTestRunner().run(suite)
if(len(ret.failures) != 0):
sys.exit(1)
else:
sys.exit(0)
class TestWeatherModel(unittest.TestCase):
def testCollectWeatherDataHist(self):
wm = WeatherManager()
wm.CollectWeatherData()
self.assertTrue(wm.weatherData is not None)
WeatherManager.CollectWeatherData() 方法如下所示:
def CollecWeatherData(self):
cur = connection.cursor()
cur.execute(<Raw SQL Query>)
wm.WeatherData = cur.fetchall()
cur.close()
我想以某种方式防止白痴发生,以免其他人(或我)稍后出现并意外编写会修改生产数据库的测试。
如果你为你的模型添加一个序列化器,你可以专门研究在只读模式下工作的序列化器
class AccountSerializer(serializers.ModelSerializer):
class Meta:
model = Account
fields = ('id', 'account_name', 'users', 'created')
read_only_fields = ('account_name',)
来自 http://www.django-rest-framework.org/api-guide/serializers/#specifying-read-only-fields
伙计,再一次,在我 post 在这里提问之前,我应该更仔细地阅读文档。我可以在设置文件中定义到我的生产数据库的只读连接,然后直接从 docs:
如果您使用多个数据库,您可以使用django.db.connections 获取特定数据库的连接(和游标)。 django.db.connections 是一个类似字典的对象,允许您使用别名检索特定连接:
from django.db import connections
cursor = connections['my_db_alias'].cursor()
# Your code here...
您可以通过连接到 Django 的 connection_created
信号来实现,并且
然后进行交易 read-only.
以下适用于 PostgreSQL:
from django.db.backends.signals import connection_created
class MyappConfig(AppConfig):
def ready(self):
def connection_created_handler(connection, **kwargs):
with connection.cursor() as cursor:
cursor.execute('SET default_transaction_read_only = true;')
connection_created.connect(connection_created_handler, weak=False)
这对于某些特定的 Django 设置很有用(例如 运行 开发
代码 runserver
针对生产数据库),你不想
创建一个真正的 read-only 数据库用户。
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.postgresql_psycopg2',
'NAME': 'mydb',
'USER': 'myusername',
'PASSWORD': 'mypassword',
'HOST': 'myhost',
'OPTIONS': {
'options': '-c default_transaction_read_only=on'
}
}
}
我有一系列集成级测试,这些测试 运行 作为我的 Django 项目中的管理命令。这些测试正在验证从外部来源摄取到我的数据库中的大量天气数据的完整性。因为我有如此大量的数据,所以我真的必须针对我的生产数据库进行测试才能使测试有意义。我想弄清楚的是如何定义特定于该命令或连接对象的只读数据库连接。我还应该补充一点,这些测试不能通过 ORM,所以我需要执行原始 SQL。
我的测试结构如下所示
class Command(BaseCommand):
help = 'Runs Integration Tests and Query Tests against Prod Database'
def handle(self,*args, **options):
suite = unittest.TestLoader().loadTestsFromTestCase(TestWeatherModel)
ret = unittest.TextTestRunner().run(suite)
if(len(ret.failures) != 0):
sys.exit(1)
else:
sys.exit(0)
class TestWeatherModel(unittest.TestCase):
def testCollectWeatherDataHist(self):
wm = WeatherManager()
wm.CollectWeatherData()
self.assertTrue(wm.weatherData is not None)
WeatherManager.CollectWeatherData() 方法如下所示:
def CollecWeatherData(self):
cur = connection.cursor()
cur.execute(<Raw SQL Query>)
wm.WeatherData = cur.fetchall()
cur.close()
我想以某种方式防止白痴发生,以免其他人(或我)稍后出现并意外编写会修改生产数据库的测试。
如果你为你的模型添加一个序列化器,你可以专门研究在只读模式下工作的序列化器
class AccountSerializer(serializers.ModelSerializer):
class Meta:
model = Account
fields = ('id', 'account_name', 'users', 'created')
read_only_fields = ('account_name',)
来自 http://www.django-rest-framework.org/api-guide/serializers/#specifying-read-only-fields
伙计,再一次,在我 post 在这里提问之前,我应该更仔细地阅读文档。我可以在设置文件中定义到我的生产数据库的只读连接,然后直接从 docs:
如果您使用多个数据库,您可以使用django.db.connections 获取特定数据库的连接(和游标)。 django.db.connections 是一个类似字典的对象,允许您使用别名检索特定连接:
from django.db import connections
cursor = connections['my_db_alias'].cursor()
# Your code here...
您可以通过连接到 Django 的 connection_created
信号来实现,并且
然后进行交易 read-only.
以下适用于 PostgreSQL:
from django.db.backends.signals import connection_created
class MyappConfig(AppConfig):
def ready(self):
def connection_created_handler(connection, **kwargs):
with connection.cursor() as cursor:
cursor.execute('SET default_transaction_read_only = true;')
connection_created.connect(connection_created_handler, weak=False)
这对于某些特定的 Django 设置很有用(例如 运行 开发
代码 runserver
针对生产数据库),你不想
创建一个真正的 read-only 数据库用户。
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.postgresql_psycopg2',
'NAME': 'mydb',
'USER': 'myusername',
'PASSWORD': 'mypassword',
'HOST': 'myhost',
'OPTIONS': {
'options': '-c default_transaction_read_only=on'
}
}
}