chore: db.get_all -> get_all (#17895)

Reduces 1 pointless function call.
Function calls are also not "super cheap" in python.

(cherry picked from commit 2eec621e95)

[skip ci]

Co-authored-by: Ankush Menat <ankush@frappe.io>

frappe/__init__.py

@@ -2329,7 +2329,7 @@ def get_version(doctype, name, limit=None, head=False, raise_err=True):
 	"""
 	meta = get_meta(doctype)
 	if meta.track_changes:
-		names = db.get_all(
+		names = get_all(
 			"Version",
 			filters={
 				"ref_doctype": doctype,

frappe/automation/doctype/auto_repeat/auto_repeat.py

@@ -241,7 +241,7 @@ class AutoRepeat(Document):
 	def set_auto_repeat_period(self, new_doc):
 		mcount = month_map.get(self.frequency)
 		if mcount and new_doc.meta.get_field("from_date") and new_doc.meta.get_field("to_date"):
-			last_ref_doc = frappe.db.get_all(
+			last_ref_doc = frappe.get_all(
 				doctype=self.reference_doctype,
 				fields=["name", "from_date", "to_date"],
 				filters=[
@@ -470,7 +470,7 @@ def create_repeated_entries(data):
 def get_auto_repeat_entries(date=None):
 	if not date:
 		date = getdate(today())
-	return frappe.db.get_all(
+	return frappe.get_all(
 		"Auto Repeat", filters=[["next_schedule_date", "<=", date], ["status", "=", "Active"]]
 	)
 
@@ -504,7 +504,7 @@ def make_auto_repeat(doctype, docname, frequency="Daily", start_date=None, end_d
 @frappe.whitelist()
 @frappe.validate_and_sanitize_search_inputs
 def get_auto_repeat_doctypes(doctype, txt, searchfield, start, page_len, filters):
-	res = frappe.db.get_all(
+	res = frappe.get_all(
 		"Property Setter",
 		{
 			"property": "allow_auto_repeat",
@@ -514,7 +514,7 @@ def get_auto_repeat_doctypes(doctype, txt, searchfield, start, page_len, filters
 	)
 	docs = [r.doc_type for r in res]
 
-	res = frappe.db.get_all(
+	res = frappe.get_all(
 		"DocType",
 		{
 			"allow_auto_repeat": 1,

frappe/automation/doctype/auto_repeat/test_auto_repeat.py

@@ -228,7 +228,7 @@ class TestAutoRepeat(unittest.TestCase):
 
 		data = get_auto_repeat_entries(current_date)
 		create_repeated_entries(data)
-		docnames = frappe.db.get_all(
+		docnames = frappe.get_all(
 			doc.reference_doctype, filters={"auto_repeat": doc.name}, fields=["docstatus"], limit=1
 		)
 		self.assertEqual(docnames[0].docstatus, 1)

frappe/boot.py

@@ -336,7 +336,7 @@ def get_success_action():
 def get_link_preview_doctypes():
 	from frappe.utils import cint
 
-	link_preview_doctypes = [d.name for d in frappe.db.get_all("DocType", {"show_preview_popup": 1})]
+	link_preview_doctypes = [d.name for d in frappe.get_all("DocType", {"show_preview_popup": 1})]
 	customizations = frappe.get_all(
 		"Property Setter", fields=["doc_type", "value"], filters={"property": "show_preview_popup"}
 	)

frappe/cache_manager.py

@@ -134,7 +134,7 @@ def clear_doctype_cache(doctype=None):
 
 		# clear all parent doctypes
 
-		for dt in frappe.db.get_all(
+		for dt in frappe.get_all(
 			"DocField", "parent", dict(fieldtype=["in", frappe.model.table_fields], options=doctype)
 		):
 			clear_single(dt.parent)

frappe/core/doctype/activity_log/test_activity_log.py

@@ -41,7 +41,7 @@ class TestActivityLog(unittest.TestCase):
 		frappe.local.form_dict = frappe._dict()
 
 	def get_auth_log(self, operation="Login"):
-		names = frappe.db.get_all(
+		names = frappe.get_all(
 			"Activity Log",
 			filters={
 				"user": "Administrator",

frappe/core/doctype/data_import/exporter.py

@@ -183,7 +183,7 @@ class Exporter:
 			child_fields = ["name", "idx", "parent", "parentfield"] + list(
 				{format_column_name(df) for df in self.fields if df.parent == child_table_doctype}
 			)
-			data = frappe.db.get_all(
+			data = frappe.get_all(
 				child_table_doctype,
 				filters={
 					"parent": ("in", parent_names),

frappe/core/doctype/data_import/importer.py

@@ -50,7 +50,7 @@ class Importer:
 	def get_data_for_import_preview(self):
 		out = self.import_file.get_data_for_import_preview()
 
-		out.import_log = frappe.db.get_all(
+		out.import_log = frappe.get_all(
 			"Data Import Log",
 			fields=["row_indexes", "success"],
 			filters={"data_import": self.data_import.name},
@@ -90,7 +90,7 @@ class Importer:
 
 		# setup import log
 		import_log = (
-			frappe.db.get_all(
+			frappe.get_all(
 				"Data Import Log",
 				fields=["row_indexes", "success", "log_index"],
 				filters={"data_import": self.data_import.name},
@@ -204,7 +204,7 @@ class Importer:
 
 		# Logs are db inserted directly so will have to be fetched again
 		import_log = (
-			frappe.db.get_all(
+			frappe.get_all(
 				"Data Import Log",
 				fields=["row_indexes", "success", "log_index"],
 				filters={"data_import": self.data_import.name},
@@ -297,7 +297,7 @@ class Importer:
 			return
 
 		import_log = (
-			frappe.db.get_all(
+			frappe.get_all(
 				"Data Import Log",
 				fields=["row_indexes", "success"],
 				filters={"data_import": self.data_import.name},
@@ -327,7 +327,7 @@ class Importer:
 		if not self.data_import:
 			return
 
-		import_log = frappe.db.get_all(
+		import_log = frappe.get_all(
 			"Data Import Log",
 			fields=["row_indexes", "success", "messages", "exception", "docname"],
 			filters={"data_import": self.data_import.name},
@@ -985,7 +985,7 @@ class Column:
 			# find all values that dont exist
 			values = list({cstr(v) for v in self.column_values[1:] if v})
 			exists = [
-				cstr(d.name) for d in frappe.db.get_all(self.df.options, filters={"name": ("in", values)})
+				cstr(d.name) for d in frappe.get_all(self.df.options, filters={"name": ("in", values)})
 			]
 			not_exists = list(set(values) - set(exists))
 			if not_exists:

frappe/core/doctype/data_import/test_importer.py

@@ -67,7 +67,7 @@ class TestImporter(unittest.TestCase):
 		data_import.start_import()
 		data_import.reload()
 
-		import_log = frappe.db.get_all(
+		import_log = frappe.get_all(
 			"Data Import Log",
 			fields=["row_indexes", "success", "messages", "exception", "docname"],
 			filters={"data_import": data_import.name},

frappe/core/doctype/doctype/doctype.py

@@ -325,7 +325,7 @@ class DocType(Document):
 		"""Change the timestamp of parent DocType if the current one is a child to clear caches."""
 		if frappe.flags.in_import:
 			return
-		parent_list = frappe.db.get_all(
+		parent_list = frappe.get_all(
 			"DocField", "parent", dict(fieldtype=["in", frappe.model.table_fields], options=self.name)
 		)
 		for p in parent_list:

frappe/core/doctype/file/test_file.py

@@ -239,7 +239,7 @@ class TestFile(FrappeTestCase):
 			pass
 
 	def delete_test_data(self):
-		test_file_data = frappe.db.get_all(
+		test_file_data = frappe.get_all(
 			"File",
 			pluck="name",
 			filters={"is_home_folder": 0, "is_attachments_folder": 0},

frappe/core/doctype/language/language.py

@@ -30,7 +30,7 @@ def validate_with_regex(name, label):
 
 def export_languages_json():
 	"""Export list of all languages"""
-	languages = frappe.db.get_all("Language", fields=["name", "language_name"])
+	languages = frappe.get_all("Language", fields=["name", "language_name"])
 	languages = [{"name": d.language_name, "code": d.name} for d in languages]
 
 	languages.sort(key=lambda a: a["code"])

frappe/core/doctype/package_release/package_release.py

@@ -60,7 +60,7 @@ class PackageRelease(Document):
 		self.make_tarfile(package)
 
 	def export_modules(self):
-		for m in frappe.db.get_all("Module Def", dict(package=self.package)):
+		for m in frappe.get_all("Module Def", dict(package=self.package)):
 			module = frappe.get_doc("Module Def", m.name)
 			for l in module.meta.links:
 				if l.link_doctype == "Module Def":

frappe/core/doctype/server_script/server_script.py

@@ -129,7 +129,7 @@ class ServerScript(Document):
 
 		Returns:
 		        list: Returns list of autocompletion items.
-		        For e.g., ["frappe.utils.cint", "frappe.db.get_all", ...]
+		        For e.g., ["frappe.utils.cint", "frappe.get_all", ...]
 		"""
 
 		def get_keys(obj):

frappe/core/doctype/translation/translation.py

@@ -39,7 +39,7 @@ def create_translations(translation_map, language):
 	# first create / update local user translations
 	for source_id, translation_dict in translation_map.items():
 		translation_dict = frappe._dict(translation_dict)
-		existing_doc_name = frappe.db.get_all(
+		existing_doc_name = frappe.get_all(
 			"Translation",
 			{
 				"source_text": translation_dict.source_text,

frappe/core/doctype/user/user.py

@@ -621,7 +621,7 @@ class User(Document):
 		if login_with_username:
 			or_filters.append({"username": user_name})
 
-		users = frappe.db.get_all("User", fields=["name", "enabled"], or_filters=or_filters, limit=1)
+		users = frappe.get_all("User", fields=["name", "enabled"], or_filters=or_filters, limit=1)
 		if not users:
 			return
 

frappe/core/doctype/user_permission/user_permission.py

@@ -27,7 +27,7 @@ class UserPermission(Document):
 	def validate_user_permission(self):
 		"""checks for duplicate user permission records"""
 
-		duplicate_exists = frappe.db.get_all(
+		duplicate_exists = frappe.get_all(
 			self.doctype,
 			filters={
 				"allow": self.allow,

frappe/custom/doctype/doctype_layout/patches/convert_web_forms_to_doctype_layout.py

@@ -2,7 +2,7 @@ import frappe
 
 
 def execute():
-	for web_form_name in frappe.db.get_all("Web Form", pluck="name"):
+	for web_form_name in frappe.get_all("Web Form", pluck="name"):
 		web_form = frappe.get_doc("Web Form", web_form_name)
 		doctype_layout = frappe.get_doc(
 			dict(

frappe/desk/desktop.py

@@ -172,7 +172,7 @@ class Workspace:
 
 		if not exists and frappe.db.exists(name):
 			if not frappe.db.get_value("DocType", name, "issingle"):
-				exists = bool(frappe.db.get_all(name, limit=1))
+				exists = bool(frappe.get_all(name, limit=1))
 			else:
 				exists = True
 			self.table_counts[name] = exists

frappe/desk/doctype/dashboard_chart/dashboard_chart.py

@@ -249,7 +249,7 @@ def get_heatmap_chart_config(chart, filters, heatmap_year):
 		timestamp_field = f"extract(epoch from timestamp {datefield})"
 
 	data = dict(
-		frappe.db.get_all(
+		frappe.get_all(
 			doctype,
 			fields=[
 				timestamp_field,

frappe/desk/doctype/desktop_icon/desktop_icon.py

@@ -61,7 +61,7 @@ def get_desktop_icons(user=None):
 
 		blocked_doctypes = [d.get("name") for d in blocked_doctypes]
 
-		standard_icons = frappe.db.get_all("Desktop Icon", fields=fields, filters={"standard": 1})
+		standard_icons = frappe.get_all("Desktop Icon", fields=fields, filters={"standard": 1})
 
 		standard_map = {}
 		for icon in standard_icons:
@@ -69,7 +69,7 @@ def get_desktop_icons(user=None):
 				icon.blocked = 1
 			standard_map[icon.module_name] = icon
 
-		user_icons = frappe.db.get_all(
+		user_icons = frappe.get_all(
 			"Desktop Icon", fields=fields, filters={"standard": 0, "owner": user}
 		)
 
@@ -430,7 +430,7 @@ def get_context(context):
 	context.user = frappe.session.user
 
 	if "System Manager" in frappe.get_roles():
-		context.users = frappe.db.get_all(
+		context.users = frappe.get_all(
 			"User",
 			filters={"user_type": "System User", "enabled": 1},
 			fields=["name", "first_name", "last_name"],
@@ -443,7 +443,7 @@ def get_module_icons(user=None):
 		frappe.only_for("System Manager")
 
 	if not user:
-		icons = frappe.db.get_all("Desktop Icon", fields="*", filters={"standard": 1}, order_by="idx")
+		icons = frappe.get_all("Desktop Icon", fields="*", filters={"standard": 1}, order_by="idx")
 	else:
 		frappe.cache().hdel("desktop_icons", user)
 		icons = get_user_icons(user)

frappe/desk/doctype/notification_log/notification_log.py

@@ -151,7 +151,7 @@ def get_notification_logs(limit=20):
 
 @frappe.whitelist()
 def mark_all_as_read():
-	unread_docs_list = frappe.db.get_all(
+	unread_docs_list = frappe.get_all(
 		"Notification Log", filters={"read": 0, "for_user": frappe.session.user}
 	)
 	unread_docnames = [doc.name for doc in unread_docs_list]

frappe/desk/doctype/notification_log/test_notification_log.py

@@ -38,7 +38,7 @@ class TestNotificationLog(unittest.TestCase):
 
 
 def get_last_email_queue():
-	res = frappe.db.get_all("Email Queue", fields=["message"], order_by="creation desc", limit=1)
+	res = frappe.get_all("Email Queue", fields=["message"], order_by="creation desc", limit=1)
 	return res[0]
 
 

frappe/desk/form/assign_to.py

@@ -138,7 +138,7 @@ def add_multiple(args=None):
 
 
 def close_all_assignments(doctype, name):
-	assignments = frappe.db.get_all(
+	assignments = frappe.get_all(
 		"ToDo",
 		fields=["allocated_to"],
 		filters=dict(reference_type=doctype, reference_name=name, status=("!=", "Cancelled")),
@@ -189,7 +189,7 @@ def clear(doctype, name):
 	"""
 	Clears assignments, return False if not assigned.
 	"""
-	assignments = frappe.db.get_all(
+	assignments = frappe.get_all(
 		"ToDo", fields=["allocated_to"], filters=dict(reference_type=doctype, reference_name=name)
 	)
 	if not assignments:

frappe/desk/form/linked_with.py

@@ -136,7 +136,7 @@ class SubmittableDocumentTree:
 	def get_submittable_doctypes(self) -> list[str]:
 		"""Returns list of submittable doctypes."""
 		if not self._submittable_doctypes:
-			self._submittable_doctypes = frappe.db.get_all("DocType", {"is_submittable": 1}, pluck="name")
+			self._submittable_doctypes = frappe.get_all("DocType", {"is_submittable": 1}, pluck="name")
 		return self._submittable_doctypes
 
 
@@ -288,9 +288,7 @@ def get_references_across_doctypes_by_dynamic_link_field(
 	for doctype, fieldname, doctype_fieldname in links:
 		try:
 			filters = [[doctype_fieldname, "in", to_doctypes]] if to_doctypes else []
-			for linked_to in frappe.db.get_all(
-				doctype, pluck=doctype_fieldname, filters=filters, distinct=1
-			):
+			for linked_to in frappe.get_all(doctype, pluck=doctype_fieldname, filters=filters, distinct=1):
 				if linked_to:
 					links_by_doctype[linked_to].append(
 						{"doctype": doctype, "fieldname": fieldname, "doctype_fieldname": doctype_fieldname}
@@ -330,17 +328,17 @@ def get_referencing_documents(
 
 	if not link_info.get("is_child"):
 		filters.extend(parent_filters or [])
-		return {from_table: frappe.db.get_all(from_table, filters, pluck="name")}
+		return {from_table: frappe.get_all(from_table, filters, pluck="name")}
 
 	filters.extend(child_filters or [])
-	res = frappe.db.get_all(from_table, filters=filters, fields=["name", "parenttype", "parent"])
+	res = frappe.get_all(from_table, filters=filters, fields=["name", "parenttype", "parent"])
 	documents = defaultdict(list)
 
 	for parent, rows in itertools.groupby(res, key=lambda row: row["parenttype"]):
 		if allowed_parents and parent not in allowed_parents:
 			continue
 		filters = (parent_filters or []) + [["name", "in", tuple(row.parent for row in rows)]]
-		documents[parent].extend(frappe.db.get_all(parent, filters=filters, pluck="name") or [])
+		documents[parent].extend(frappe.get_all(parent, filters=filters, pluck="name") or [])
 	return documents
 
 

frappe/desk/form/load.py

@@ -178,7 +178,7 @@ def add_comments(doc, docinfo):
 
 
 def get_milestones(doctype, name):
-	return frappe.db.get_all(
+	return frappe.get_all(
 		"Milestone",
 		fields=["creation", "owner", "track_field", "value"],
 		filters=dict(reference_type=doctype, reference_name=name),
@@ -249,7 +249,7 @@ def get_comments(
 
 
 def get_point_logs(doctype, docname):
-	return frappe.db.get_all(
+	return frappe.get_all(
 		"Energy Point Log",
 		filters={"reference_doctype": doctype, "reference_name": docname, "type": ["!=", "Review"]},
 		fields=["*"],

frappe/desk/form/meta.py

@@ -146,7 +146,7 @@ class FormMeta(Meta):
 		"""embed all require files"""
 		# custom script
 		client_scripts = (
-			frappe.db.get_all(
+			frappe.get_all(
 				"Client Script",
 				filters={"dt": self.name, "enabled": 1},
 				fields=["name", "script", "view"],

frappe/desk/leaderboard.py

@@ -16,7 +16,7 @@ def get_leaderboards():
 
 @frappe.whitelist()
 def get_energy_point_leaderboard(date_range, company=None, field=None, limit=None):
-	all_users = frappe.db.get_all(
+	all_users = frappe.get_all(
 		"User",
 		filters={
 			"name": ["not in", ["Administrator", "Guest"]],
@@ -31,7 +31,7 @@ def get_energy_point_leaderboard(date_range, company=None, field=None, limit=Non
 	if date_range:
 		date_range = frappe.parse_json(date_range)
 		filters.append(["creation", "between", [date_range[0], date_range[1]]])
-	energy_point_users = frappe.db.get_all(
+	energy_point_users = frappe.get_all(
 		"Energy Point Log",
 		fields=["user as name", "sum(points) as value"],
 		filters=filters,

frappe/desk/page/user_profile/user_profile.py

@@ -31,7 +31,7 @@ def get_energy_points_heatmap_data(user, date):
 
 @frappe.whitelist()
 def get_energy_points_percentage_chart_data(user, field):
-	result = frappe.db.get_all(
+	result = frappe.get_all(
 		"Energy Point Log",
 		filters={"user": user, "type": ["!=", "Review"]},
 		group_by=field,
@@ -49,7 +49,7 @@ def get_energy_points_percentage_chart_data(user, field):
 @frappe.whitelist()
 def get_user_rank(user):
 	month_start = datetime.today().replace(day=1)
-	monthly_rank = frappe.db.get_all(
+	monthly_rank = frappe.get_all(
 		"Energy Point Log",
 		group_by="user",
 		filters={"creation": [">", month_start], "type": ["!=", "Review"]},
@@ -58,7 +58,7 @@ def get_user_rank(user):
 		as_list=True,
 	)
 
-	all_time_rank = frappe.db.get_all(
+	all_time_rank = frappe.get_all(
 		"Energy Point Log",
 		group_by="user",
 		filters={"type": ["!=", "Review"]},

frappe/email/doctype/email_account/email_account.py

@@ -846,7 +846,7 @@ def get_max_email_uid(email_account):
 	# get maximum uid of emails
 	max_uid = 1
 
-	result = frappe.db.get_all(
+	result = frappe.get_all(
 		"Communication",
 		filters={
 			"communication_medium": "Email",

frappe/email/doctype/email_group/email_group.py

@@ -9,10 +9,10 @@ from frappe.utils import parse_addr, validate_email_address
 
 class EmailGroup(Document):
 	def onload(self):
-		singles = [d.name for d in frappe.db.get_all("DocType", "name", {"issingle": 1})]
+		singles = [d.name for d in frappe.get_all("DocType", "name", {"issingle": 1})]
 		self.get("__onload").import_types = [
 			{"value": d.parent, "label": f"{d.parent} ({d.label})"}
-			for d in frappe.db.get_all("DocField", ("parent", "label"), {"options": "Email"})
+			for d in frappe.get_all("DocField", ("parent", "label"), {"options": "Email"})
 			if d.parent not in singles
 		]
 
@@ -27,7 +27,7 @@ class EmailGroup(Document):
 		unsubscribed_field = "unsubscribed" if meta.get_field("unsubscribed") else None
 		added = 0
 
-		for user in frappe.db.get_all(doctype, [email_field, unsubscribed_field or "name"]):
+		for user in frappe.get_all(doctype, [email_field, unsubscribed_field or "name"]):
 			try:
 				email = parse_addr(user.get(email_field))[1] if user.get(email_field) else None
 				if email:

frappe/email/doctype/newsletter/test_newsletter.py

@@ -107,7 +107,7 @@ class TestNewsletterMixin:
 			"content_type": "Rich Text",
 			"message": "Testing my news.",
 		}
-		similar_newsletters = frappe.db.get_all(doctype, newsletter_content, pluck="name")
+		similar_newsletters = frappe.get_all(doctype, newsletter_content, pluck="name")
 
 		for similar_newsletter in similar_newsletters:
 			frappe.delete_doc(doctype, similar_newsletter)
@@ -180,7 +180,7 @@ class TestNewsletter(TestNewsletterMixin, FrappeTestCase):
 		newsletter.save = MagicMock()
 		self.assertFalse(newsletter.save.called)
 		# check if the test email is in the queue
-		email_queue = frappe.db.get_all(
+		email_queue = frappe.get_all(
 			"Email Queue",
 			filters=[
 				["reference_doctype", "=", "Newsletter"],

frappe/integrations/doctype/webhook/test_webhook.py

@@ -176,7 +176,7 @@ class TestWebhook(unittest.TestCase):
 		webhook = frappe.get_doc("Webhook", {"webhook_doctype": "User"})
 		enqueue_webhook(user, webhook)
 
-		self.assertTrue(frappe.db.get_all("Webhook Request Log", pluck="name"))
+		self.assertTrue(frappe.get_all("Webhook Request Log", pluck="name"))
 
 	def test_webhook_with_array_body(self):
 		"""Check if array request body are supported."""

frappe/model/meta.py

@@ -666,7 +666,7 @@ def is_single(doctype):
 
 
 def get_parent_dt(dt):
-	parent_dt = frappe.db.get_all(
+	parent_dt = frappe.get_all(
 		"DocField", "parent", dict(fieldtype=["in", frappe.model.table_fields], options=dt), limit=1
 	)
 	return parent_dt and parent_dt[0].parent or ""
@@ -764,7 +764,7 @@ def trim_tables(doctype=None, dry_run=False, quiet=False):
 	if doctype:
 		filters["name"] = doctype
 
-	for doctype in frappe.db.get_all("DocType", filters=filters, pluck="name"):
+	for doctype in frappe.get_all("DocType", filters=filters, pluck="name"):
 		try:
 			dropped_columns = trim_table(doctype, dry_run=dry_run)
 			if dropped_columns:

frappe/model/rename_doc.py

@@ -237,7 +237,7 @@ def update_assignments(old: str, new: str, doctype: str) -> None:
 
 	for user in common_assignments:
 		# delete todos linked to old doc
-		todos = frappe.db.get_all(
+		todos = frappe.get_all(
 			"ToDo",
 			{
 				"owner": user,

frappe/patches/v12_0/change_existing_dashboard_chart_filters.py

@@ -7,7 +7,7 @@ def execute():
 	if not frappe.db.table_exists("Dashboard Chart"):
 		return
 
-	charts_to_modify = frappe.db.get_all(
+	charts_to_modify = frappe.get_all(
 		"Dashboard Chart",
 		fields=["name", "filters_json", "document_type"],
 		filters={"chart_type": ["not in", ["Report", "Custom"]]},

frappe/patches/v12_0/create_notification_settings_for_user.py

@@ -8,6 +8,6 @@ def execute():
 	frappe.reload_doc("desk", "doctype", "notification_settings")
 	frappe.reload_doc("desk", "doctype", "notification_subscribed_document")
 
-	users = frappe.db.get_all("User", fields=["name"])
+	users = frappe.get_all("User", fields=["name"])
 	for user in users:
 		create_notification_settings(user.name)

frappe/patches/v12_0/set_default_incoming_email_port.py

@@ -15,9 +15,7 @@ def execute():
 
 
 def setup_incoming_email_port_in_email_domains():
-	email_domains = frappe.db.get_all(
-		"Email Domain", ["incoming_port", "use_imap", "use_ssl", "name"]
-	)
+	email_domains = frappe.get_all("Email Domain", ["incoming_port", "use_imap", "use_ssl", "name"])
 	for domain in email_domains:
 		if not domain.incoming_port:
 			incoming_port = get_port(domain)
@@ -33,7 +31,7 @@ def setup_incoming_email_port_in_email_domains():
 
 
 def setup_incoming_email_port_in_email_accounts():
-	email_accounts = frappe.db.get_all(
+	email_accounts = frappe.get_all(
 		"Email Account", ["incoming_port", "use_imap", "use_ssl", "name", "enable_incoming"]
 	)
 

frappe/patches/v13_0/generate_theme_files_in_public_folder.py

@@ -6,7 +6,7 @@ import frappe
 
 def execute():
 	frappe.reload_doc("website", "doctype", "website_theme_ignore_app")
-	themes = frappe.db.get_all(
+	themes = frappe.get_all(
 		"Website Theme", filters={"theme_url": ("not like", "/files/website_theme/%")}
 	)
 	for theme in themes:

frappe/patches/v13_0/set_existing_dashboard_charts_as_public.py

@@ -15,7 +15,7 @@ def execute():
 	)
 
 	users = [item.parent for item in users_with_permission]
-	charts = frappe.db.get_all("Dashboard Chart", filters={"owner": ["in", users]})
+	charts = frappe.get_all("Dashboard Chart", filters={"owner": ["in", users]})
 
 	for chart in charts:
 		frappe.db.set_value("Dashboard Chart", chart.name, "is_public", 1)

frappe/patches/v14_0/delete_data_migration_tool.py

@@ -5,7 +5,7 @@ import frappe
 
 
 def execute():
-	doctypes = frappe.db.get_all("DocType", {"module": "Data Migration", "custom": 0}, pluck="name")
+	doctypes = frappe.get_all("DocType", {"module": "Data Migration", "custom": 0}, pluck="name")
 	for doctype in doctypes:
 		frappe.delete_doc("DocType", doctype, ignore_missing=True)
 

frappe/patches/v14_0/update_color_names_in_kanban_board_column.py

@@ -17,6 +17,6 @@ def execute():
 		"yellow": "Yellow",
 		"lightblue": "Light Blue",
 	}
-	for d in frappe.db.get_all("Kanban Board Column", fields=["name", "indicator"]):
+	for d in frappe.get_all("Kanban Board Column", fields=["name", "indicator"]):
 		color_name = indicator_map.get(d.indicator, "Gray")
 		frappe.db.set_value("Kanban Board Column", d.name, "indicator", color_name)

frappe/patches/v14_0/update_multistep_webforms.py

@@ -4,7 +4,7 @@ import frappe
 def execute():
 	frappe.reload_doctype("Web Form")
 
-	for web_form in frappe.db.get_all("Web Form", filters={"is_multi_step_form": 1}):
+	for web_form in frappe.get_all("Web Form", filters={"is_multi_step_form": 1}):
 		web_form_fields = frappe.get_doc("Web Form", web_form.name).web_form_fields
 		for web_form_field in web_form_fields:
 			if web_form_field.fieldtype == "Section Break" and web_form_field.idx != 1:

frappe/patches/v14_0/update_webforms.py

@@ -9,6 +9,6 @@ def execute():
 	frappe.reload_doc("website", "doctype", "web_form_list_column")
 	frappe.reload_doctype("Web Form")
 
-	for web_form in frappe.db.get_all("Web Form", fields=["*"]):
+	for web_form in frappe.get_all("Web Form", fields=["*"]):
 		if web_form.allow_multiple and not web_form.show_list:
 			frappe.db.set_value("Web Form", web_form.name, "show_list", True)

frappe/permissions.py

@@ -451,13 +451,13 @@ def get_doctype_roles(doctype, access_type="read"):
 def get_perms_for(roles, perm_doctype="DocPerm"):
 	"""Get perms for given roles"""
 	filters = {"permlevel": 0, "docstatus": 0, "role": ["in", roles]}
-	return frappe.db.get_all(perm_doctype, fields=["*"], filters=filters)
+	return frappe.get_all(perm_doctype, fields=["*"], filters=filters)
 
 
 def get_doctypes_with_custom_docperms():
 	"""Returns all the doctypes with Custom Docperms"""
 
-	doctypes = frappe.db.get_all("Custom DocPerm", fields=["parent"], distinct=1)
+	doctypes = frappe.get_all("Custom DocPerm", fields=["parent"], distinct=1)
 	return [d.parent for d in doctypes]
 
 
@@ -525,7 +525,7 @@ def clear_user_permissions_for_doctype(doctype, user=None):
 	filters = {"allow": doctype}
 	if user:
 		filters["user"] = user
-	user_permissions_for_doctype = frappe.db.get_all("User Permission", filters=filters)
+	user_permissions_for_doctype = frappe.get_all("User Permission", filters=filters)
 	for d in user_permissions_for_doctype:
 		frappe.delete_doc("User Permission", d.name)
 

frappe/printing/doctype/print_format/print_format.py

@@ -13,7 +13,7 @@ from frappe.utils.weasyprint import download_pdf, get_html
 
 class PrintFormat(Document):
 	def onload(self):
-		templates = frappe.db.get_all(
+		templates = frappe.get_all(
 			"Print Format Field Template",
 			fields=["template", "field", "name"],
 			filters={"document_type": self.doc_type},

frappe/printing/doctype/print_format_field_template/print_format_field_template.py

@@ -27,7 +27,7 @@ class PrintFormatFieldTemplate(Document):
 		filters = {"document_type": self.document_type, "field": self.field}
 		if not self.is_new():
 			filters.update({"name": ("!=", self.name)})
-		result = frappe.db.get_all("Print Format Field Template", filters=filters, limit=1)
+		result = frappe.get_all("Print Format Field Template", filters=filters, limit=1)
 		if result:
 			frappe.throw(
 				_("A template already exists for field {0} of {1}").format(

frappe/share.py

@@ -101,7 +101,7 @@ def set_permission(doctype, name, user, permission_to, value=1, everyone=0):
 @frappe.whitelist()
 def get_users(doctype, name):
 	"""Get list of users with which this document is shared"""
-	return frappe.db.get_all(
+	return frappe.get_all(
 		"DocShare",
 		fields=[
 			"`name`",
@@ -137,7 +137,7 @@ def get_shared(doctype, user=None, rights=None):
 	if user != "Guest":
 		or_filters += [["everyone", "=", 1]]
 
-	shared_docs = frappe.db.get_all(
+	shared_docs = frappe.get_all(
 		"DocShare", fields=["share_name"], filters=filters, or_filters=or_filters
 	)
 

frappe/tests/test_db_query.py

@@ -42,7 +42,7 @@ class TestReportview(unittest.TestCase):
 			content="test",
 			seen_by=[{"user": "Administrator"}],
 		).insert()
-		result = frappe.db.get_all(
+		result = frappe.get_all(
 			"Note",
 			filters={"name": note.name},
 			fields=["name", "seen_by.user as seen_by"],
@@ -55,7 +55,7 @@ class TestReportview(unittest.TestCase):
 		todo = frappe.get_doc(
 			doctype="ToDo", description="Test ToDo", allocated_to="Administrator"
 		).insert()
-		result = frappe.db.get_all(
+		result = frappe.get_all(
 			"ToDo",
 			filters={"name": todo.name},
 			fields=["name", "allocated_to.email as allocated_user_email"],

frappe/tests/test_sitemap.py

@@ -9,7 +9,7 @@ class TestSitemap(unittest.TestCase):
 		from frappe.test_runner import make_test_records
 
 		make_test_records("Blog Post")
-		blogs = frappe.db.get_all("Blog Post", {"published": 1}, ["route"], limit=1)
+		blogs = frappe.get_all("Blog Post", {"published": 1}, ["route"], limit=1)
 		xml = get_html_for_route("sitemap.xml")
 		self.assertTrue("/about</loc>" in xml)
 		self.assertTrue("/contact</loc>" in xml)

frappe/tests/ui_test_helpers.py

@@ -38,7 +38,7 @@ def create_if_not_exists(doc):
 
 @frappe.whitelist()
 def create_todo_records():
-	if frappe.db.get_all("ToDo", {"description": "this is first todo"}):
+	if frappe.get_all("ToDo", {"description": "this is first todo"}):
 		return
 
 	frappe.get_doc(
@@ -80,7 +80,7 @@ def setup_workflow():
 
 @frappe.whitelist()
 def create_contact_phone_nos_records():
-	if frappe.db.get_all("Contact", {"first_name": "Test Contact"}):
+	if frappe.get_all("Contact", {"first_name": "Test Contact"}):
 		return
 
 	doc = frappe.new_doc("Contact")
@@ -127,7 +127,7 @@ def create_child_doctype(name, fields):
 
 @frappe.whitelist()
 def create_contact_records():
-	if frappe.db.get_all("Contact", {"first_name": "Test Form Contact 1"}):
+	if frappe.get_all("Contact", {"first_name": "Test Form Contact 1"}):
 		return
 
 	insert_contact("Test Form Contact 1", "12345")
@@ -137,7 +137,7 @@ def create_contact_records():
 
 @frappe.whitelist()
 def create_multiple_todo_records():
-	if frappe.db.get_all("ToDo", {"description": "Multiple ToDo 1"}):
+	if frappe.get_all("ToDo", {"description": "Multiple ToDo 1"}):
 		return
 
 	values = [(f"100{i}", f"Multiple ToDo {i}") for i in range(1, 1002)]
@@ -291,7 +291,7 @@ def update_child_table(name):
 
 @frappe.whitelist()
 def insert_doctype_with_child_table_record(name):
-	if frappe.db.get_all(name, {"title": "Test Grid Search"}):
+	if frappe.get_all(name, {"title": "Test Grid Search"}):
 		return
 
 	def insert_child(doc, data, barcode, check, rating, duration, date):

frappe/website/doctype/web_template/web_template.py

@@ -33,7 +33,7 @@ class WebTemplate(Document):
 
 	def on_update(self):
 		"""Clear cache for all Web Pages in which this template is used"""
-		routes = frappe.db.get_all(
+		routes = frappe.get_all(
 			"Web Page",
 			filters=[
 				["Web Page Block", "web_template", "=", self.name],

frappe/website/router.py

@@ -33,7 +33,7 @@ def get_page_info_from_web_page_with_dynamic_routes(path):
 def get_page_info_from_web_form(path):
 	"""Query published web forms and evaluate if the route matches"""
 	rules, page_info = [], {}
-	web_forms = frappe.db.get_all("Web Form", ["name", "route", "modified"], {"published": 1})
+	web_forms = frappe.get_all("Web Form", ["name", "route", "modified"], {"published": 1})
 	for d in web_forms:
 		rules.append(Rule(f"/{d.route}", endpoint=d.name))
 		rules.append(Rule(f"/{d.route}/list", endpoint=d.name))

frappe/www/unsubscribe.py

@@ -40,7 +40,7 @@ def get_email_groups(user_email):
 
 def get_current_groups(name):
 	# Return current group by which the mail has been sent.
-	return frappe.db.get_all(
+	return frappe.get_all(
 		"Newsletter Email Group",
 		fields=["email_group"],
 		filters={"parent": name, "parenttype": "Newsletter"},