integrate prisma ORM not working

[bobwatcherx]

Question

i have a little problem . i want to integrate flet with Orm Prisma . but it seems not working . is there something wrong with my `code```

Code sample

my code 
main.py 

from flet import *
import os
import asyncio
from prisma import Client

os.environ['PRISMA_DATASOURCES'] = 'default = mysql://root:[email protected]:3306/dbfood'
prisma = Client()

def main(page:Page):
	nametxt = TextField(label="username")
	agetxt = TextField(label="you age")

	async def create_record(e):
		try:
			res = await prisma.user.create(
			{"name": nametxt.value, "age": agetxt}
			)
			print("success",res)
		except Exception as e:
			print(e)
			print("Error check !!!!")



	page.add(
	Column([
		nametxt,
		agetxt,
		ElevatedButton("send ",
		on_click=create_record
			)

		])

		)

flet.app(target=main)


And my schema.prisma

datasource db {
  provider = "mysql"
  url      = "mysql://root:[email protected]:3306/dbfood"
}

generator client {
  provider = "prisma-client-py"
}

model User {
  id   Int    @id @default(autoincrement())
  name String
  age  Int
}

Error message

RuntimeWarning: Enable tracemalloc to get the object allocation traceback
/usr/lib/python3.10/threading.py:953: RuntimeWarning: coroutine 'main.<locals>.create_record' was never awaited
  self._target(*self._args, **self._kwargs)
RuntimeWarning: Enable tracemalloc to get the object allocation traceback

------------------------------------------------------

• I have searched for answers to my question both in the issues and in previous discussions.

[iron3oxide]

Your main method should be async too and in it you probably want to use add_async() instead of add(). Try that and reply with the result.

[bobwatcherx]

Flet version
flet 0.3.2

[iron3oxide]

Well, there's your problem: async support added in 0.4.0, please upgrade.

[bobwatcherx]

still not working . even though it's been upgraded

root@minx-Lenovo-V145-14AST:/home/minx/belajar/fletApp/fletmysql# flet --version
0.4.2

error

RuntimeWarning: Enable tracemalloc to get the object allocation traceback
/home/minx/belajar/fletApp/fletmysql/main.py:25: RuntimeWarning: coroutine 'Page.add_async' was never awaited
 page.add_async(
RuntimeWarning: Enable tracemalloc to get the object allocation traceback

code

from flet import *
import os
import asyncio
from prisma import Client

os.environ['PRISMA_DATASOURCES'] = 'default = mysql://root:[email protected]:3306/dbfood'
prisma = Client()

async def main(page:Page):
	nametxt = TextField(label="username")
	agetxt = TextField(label="you age")
	async def create_record(e):
		try:
			res = await prisma.user.create(
			{"name": nametxt.value, "age": agetxt}
			)
			print("success",res)
		except Exception as e:
			print(e)
			print("Error check !!!!")



	page.add_async(
	Column([
		nametxt,
		agetxt,
		ElevatedButton("send ",
		on_click=create_record
			)

		])

		)

flet.app(target=main)

[iron3oxide]

You should use await page.add_async(), as it says in the error message.

[bobwatcherx]

thanks . it works now .

from flet import *
import os
import asyncio
from prisma import Client

os.environ['PRISMA_DATASOURCES'] = 'default = mysql://root:[email protected]:3306/dbfood'
prisma = Client()

async def main(page:Page):
	nametxt = TextField(label="username")
	agetxt = TextField(label="you age")
	async def create_record(e):
		try:
			await prisma.connect()
			res = await prisma.user.create(
			{"name": nametxt.value, "age": int(agetxt.value)}
			)
			print("success",res)
		except Exception as e:
			print(e)
			print("Error check !!!!")

		await prisma.disconnect()


	await page.add_async(
	Column([
		nametxt,
		agetxt,
		ElevatedButton("send ",
		on_click=create_record
			)

		])

		)

flet.app(target=main)

[bobwatcherx]

still not working and there is an error

from flet import *
import os
import asyncio
from prisma import Client

os.environ['PRISMA_DATASOURCES'] = 'default = mysql://root:[email protected]:3306/dbfood'
prisma = Client()

async def main(page:Page):
	nametxt = TextField(label="username")
	agetxt = TextField(label="you age")
	page.add_async()
	async def create_record(e):
		try:
			res = await prisma.user.create(
			{"name": nametxt.value, "age": agetxt}
			)
			print("success",res)
		except Exception as e:
			print(e)
			print("Error check !!!!")



	page.add(
	Column([
		nametxt,
		agetxt,
		ElevatedButton("send ",
		on_click=create_record
			)

		])

		)

flet.app(target=main)

root@minx-Lenovo-V145-14AST:/home/minx/belajar/fletApp/fletmysql# flet main.py 
/home/minx/belajar/fletApp/fletmysql/main.py:13: RuntimeWarning: coroutine 'Page.add_async' was never awaited
  page.add_async()
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
/home/minx/belajar/fletApp/fletmysql/main.py:13: RuntimeWarning: coroutine 'Page.add_async' was never awaited
  page.add_async()
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
Unhandled error processing page session : Traceback (most recent call last):
  File "/usr/local/lib/python3.10/dist-packages/flet/flet.py", line 377, in on_session_created
    await session_handler(page)
  File "/home/minx/belajar/fletApp/fletmysql/main.py", line 26, in main
    page.add(
  File "/usr/local/lib/python3.10/dist-packages/flet_core/page.py", line 272, in add
    r = self.__update(self)
  File "/usr/local/lib/python3.10/dist-packages/flet_core/page.py", line 362, in __update
    results = self.__conn.send_commands(self._session_id, commands).results
  File "/usr/local/lib/python3.10/dist-packages/flet_core/connection.py", line 27, in send_commands
    raise NotImplementedError()
NotImplementedError

[bobwatcherx]

this also doesn't work

from flet import *
import os
import asyncio
from prisma import Client

os.environ['PRISMA_DATASOURCES'] = 'default = mysql://root:[email protected]:3306/dbfood'
prisma = Client()

async def main(page:Page):
	nametxt = TextField(label="username")
	agetxt = TextField(label="you age")
	async def create_record(e):
		try:
			res = await prisma.user.create(
			{"name": nametxt.value, "age": agetxt}
			)
			print("success",res)
		except Exception as e:
			print(e)
			print("Error check !!!!")



	page.add_async(
	Column([
		nametxt,
		agetxt,
		ElevatedButton("send ",
		on_click=create_record
			)

		])

		)

flet.app(target=main)

/usr/lib/python3.10/threading.py:953: RuntimeWarning: coroutine 'main.<locals>.create_record' was never awaited
  self._target(*self._args, **self._kwargs)
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
/home/minx/belajar/fletApp/fletmysql/main.py:25: RuntimeWarning: coroutine 'Page.add_async' was never awaited
  page.add_async(
RuntimeWarning: Enable tracemalloc to get the object allocation traceback

[bobwatcherx]

and i have one more problem . why can't it be realtime. when added and edited and deleted the data. you have to reload the application again. usually I can use the clear() way on the widget . so no need to refresh to get the latest data.
But This Not Work . and Must Reload Again
my code

from flet import *
import os
import asyncio
from prisma import Client

os.environ['PRISMA_DATASOURCES'] = 'default = mysql://root:[email protected]:3306/dbfood'
prisma = Client()

async def main(page:Page):
	page.scroll = "auto"
	nametxt = TextField(label="username")
	agetxt = TextField(label="you age")

	mytable = DataTable(
		columns=[
			DataColumn(Text("id")),
			DataColumn(Text("name")),
			DataColumn(Text("age")),
		],
		rows=[]

		)
	
	await prisma.connect()

	async def create_record(e):
		try:
			res = await prisma.user.create(
			{"name": nametxt.value, "age": int(agetxt.value)}
			)
			print("success",res)


		except Exception as e:
			print(e)
			print("Error check !!!!")

		mytable.rows.clear()
		await read_alldata()
		page.update()


	async def read_alldata():
		users = await prisma.user.find_many()
		for user in users:
			user_dict = {"id": user.id, "name": user.name, "age": user.age}
			mytable.rows.append(
				DataRow(
					cells=[
					DataCell(Text(user.id)),
					DataCell(Text(user.name)),
					DataCell(Text(user.name)),

					]
					)

				)


	await read_alldata()

	await page.add_async(
	Column([
		nametxt,
		agetxt,
		ElevatedButton("send ",
			bgcolor="blue",color="white",
		on_click=create_record
			),
		mytable

		])

		)

flet.app(target=main)

[iron3oxide]

Flet controls aren't exactly reactive as of yet, so you'll have to manually update the table rows and then update the page each time the data changes. Right now you only query the database once when the app starts and then each time you create a user. So if you edit or delete a row from another db connection, your app will only see the updated data once you create a new user. If you enable editing and deleting users from within the app and call read_all_data() in those functions, you should see real-time updates. Also, you might want to use await page.update_async().

[bobwatcherx]

I have a problem why every time I do page.update() it always reloads.
I want to edit data. and when I click the pencil button . always reloading

my code

from flet import *
import os
import asyncio
from prisma import Client

os.environ['PRISMA_DATASOURCES'] = 'default = sqlite:///mydb.db'

prisma = Client()

async def main(page:Page):
	page.scroll = "auto"
	nametxt = TextField(label="username")
	agetxt = TextField(label="you age")
	myid = Text()

	mytable = DataTable(
		columns=[
			DataColumn(Text("actions")),
			DataColumn(Text("id")),
			DataColumn(Text("name")),
			DataColumn(Text("age")),
		],
		rows=[]

		)
	
	await prisma.connect()

	async def saveedit(e):
		await prisma.user.update(
        where={"id": myid.value},
        data={"name": nametxt.value, "age": agetxt.value},
        	)
		mytable.rows.clear()
		await read_alldata()
		page.update()

	mydialog = AlertDialog(
		title=Text("Edit data id"),
		content=Column([
			nametxt,
			agetxt
			]),
		actions=[
			ElevatedButton("save",
				bgcolor="green",color="white",
				on_click=saveedit
				)

			],
		actions_alignment="end"
		)

	async def editbtn(e):
		nametxt.value = e.control.data.name
		agetxt.value = e.control.data.age
		myid.value = e.control.data.id
		page.update()
		# page.dialog = mydialog
		# mydialog.open = True
		# page.update()



	async def deletebtn(e):
		delid = e.control.data
		await prisma.user.delete(where={"id": delid})
		mytable.rows.clear()
		await read_alldata()
		page.update()


	async def create_record(e):
		try:
			res = await prisma.user.create(
			{"name": nametxt.value, "age": int(agetxt.value)}
			)
			print("success",res)


		except Exception as e:
			print(e)
			print("Error check !!!!")

		mytable.rows.clear()
		await read_alldata()
		page.update()


	async def read_alldata():
		users = await prisma.user.find_many()
		for user in users:
			# user_dict = {"id": user.id, "name": user.name, "age": user.age}
			mytable.rows.append(
				DataRow(
					cells=[
					DataCell(Row([
						IconButton("create",icon_color="blue",
							data=user,
							on_click=editbtn
							),
						IconButton("delete",icon_color="red",
							data=user.id,
							on_click=deletebtn
							),
						])),

					DataCell(Text(user.id)),
					DataCell(Text(user.name)),
					DataCell(Text(user.name)),

					]
					)

				)


	await read_alldata()

	await page.add_async(
	Column([
		nametxt,
		agetxt,
		ElevatedButton("send ",
			bgcolor="blue",color="white",
		on_click=create_record
			),
		Row([mytable],scroll="always")

		])

		)

flet.app(target=main)

schema.prisma file

datasource db {
  provider = "sqlite"
  url      = "file:mydb.db"
}

generator py {
  provider = "prisma-client-py"
  recursive_type_depth = 5
}


model User {
  id   Int    @id @default(autoincrement()) 
  name String
  age  Int
}

[bobwatcherx]

THANKS SOLVED