From 5fe963de8f7edd086897ed26e576aa42762c4bf5 Mon Sep 17 00:00:00 2001
From: Relintai <relintai@protonmail.com>
Date: Sat, 27 Apr 2024 21:07:30 +0200
Subject: [PATCH] Prepared statements demo.

---
 database/prepared_statements/Main.gd          | 122 ++++++++++++++++++
 database/prepared_statements/Main.tscn        |   6 +
 database/prepared_statements/default_env.tres |   7 +
 database/prepared_statements/icon.png         | Bin 0 -> 3238 bytes
 database/prepared_statements/icon.png.import  |  35 +++++
 .../prepared_statements/project.pandemonium   |  25 ++++
 6 files changed, 195 insertions(+)
 create mode 100644 database/prepared_statements/Main.gd
 create mode 100644 database/prepared_statements/Main.tscn
 create mode 100644 database/prepared_statements/default_env.tres
 create mode 100644 database/prepared_statements/icon.png
 create mode 100644 database/prepared_statements/icon.png.import
 create mode 100644 database/prepared_statements/project.pandemonium

diff --git a/database/prepared_statements/Main.gd b/database/prepared_statements/Main.gd
new file mode 100644
index 0000000..073b5a5
--- /dev/null
+++ b/database/prepared_statements/Main.gd
@@ -0,0 +1,122 @@
+extends Node
+
+export(String) var database_location : String = "user://database.sqlite"
+
+func _ready() -> void:
+	DatabaseManager.connect("initialized", self, "on_databases_initialized", [], CONNECT_ONESHOT)
+	
+	var d : Directory = Directory.new()
+	var bd : String = database_location.get_base_dir()
+	var loc : String = d.get_filesystem_abspath_for(bd).append_path(database_location.get_file())
+	
+	PLogger.log_message("Database file location: " + loc)
+	PLogger.log_message("(Editor->Project->Open User Data Folder)")
+	
+	var file : File = File.new()
+	if !file.file_exists(loc):
+		PLogger.log_message("Database file doesn't exists, will run migrations!")
+		PLogger.log_message("(Editor->Project->Open User Data Folder)")
+		call_deferred("migrate")
+	else:
+		DatabaseManager.call_deferred("initialized")
+
+	var db : SQLite3Database = SQLite3Database.new()
+	db.connection_string = loc
+	DatabaseManager.add_database(db)
+
+func migrate() -> void:
+	PLogger.log_message("Running migrations!")
+	DatabaseManager.connect("migration", self, "_migration")
+	DatabaseManager.migrate(true, false, 0)
+	
+	DatabaseManager.call_deferred("initialized")
+
+func on_databases_initialized() -> void:
+	# Load sessions after the databases are initialized
+	# This happens on the Main node.
+	call_deferred("load_data")
+
+func _migration(clear: bool, should_seed: bool, pseed: int) -> void:
+	randomize()
+	
+	var tb : TableBuilder = DatabaseManager.ddb.get_connection().get_table_builder()
+	
+	tb.create_table("data_table");
+	tb.integer("id").auto_increment().next_row();
+	tb.varchar("data_varchar", 60).not_null().next_row();
+	tb.text("data_text").not_null().next_row();
+	tb.integer("data_int").not_null().next_row();
+	tb.real_double("data_double").not_null().next_row();
+	tb.primary_key("id");
+	tb.ccreate_table();
+	tb.run_query();
+	
+	print("Running:")
+	print(tb.result)
+	
+	var qb : QueryBuilder = DatabaseManager.ddb.get_connection().get_query_builder()
+	qb.insert("data_table", "data_varchar,data_text,data_int,data_double").values()
+	qb.valph().valph().valph().valph()
+	qb.cvalues()
+	qb.end_command()
+	print("Prepared statement:")
+	print(qb.result)
+	
+	var ps : PreparedStatement = qb.create_prepared_statement()
+	ps.prepare()
+	
+	print("Inserting 10 values!")
+	
+	for i in range(10):
+		ps.reset()
+		
+		ps.bind_text(1, "vc" + str(randi()))
+		ps.bind_text(2, "text" + str(randi()))
+		ps.bind_int(3, randi())
+		ps.bind_double(4, randf() * 100000)
+		ps.step()
+		
+
+
+func load_data() -> void:
+	print("Querying data from table using prepared statements:")
+	
+	var qb : QueryBuilder = DatabaseManager.ddb.get_connection().get_query_builder()
+	
+	var qr : QueryResult = qb.select("id").from("data_table").run()
+		
+	var ids : PoolIntArray = PoolIntArray()
+	
+	while qr.next_row():
+		ids.push_back(qr.get_cell_int(0))
+	
+	qb.reset()
+	
+	qb.select("id,data_varchar,data_text,data_int,data_double").from("data_table")
+	qb.where().wph("id")
+	qb.end_command()
+	print("Query prepared statement:")
+	print(qb.result)
+	
+	var ps : PreparedStatement = qb.create_prepared_statement()
+	ps.prepare()
+	
+	print("Querying rows one by one:")
+	for index in ids:
+		ps.reset()
+		
+		ps.bind_int(1, index)
+		ps.step()
+		
+		print("ps.column_count(): " + str(ps.column_count()))
+		print("id: " + str(ps.column_int(0)))
+		print("data_varchar: " + str(ps.column_text(1)))
+		print("data_text: " + str(ps.column_text(2)))
+		print("data_int: " + str(ps.column_int(3)))
+		print("data_double: " + str(ps.column_double(4)))
+
+
+
+
+
+
diff --git a/database/prepared_statements/Main.tscn b/database/prepared_statements/Main.tscn
new file mode 100644
index 0000000..85dfcb0
--- /dev/null
+++ b/database/prepared_statements/Main.tscn
@@ -0,0 +1,6 @@
+[gd_scene load_steps=2 format=3]
+
+[ext_resource path="res://Main.gd" type="Script" id=4]
+
+[node name="Main" type="Node"]
+script = ExtResource( 4 )
diff --git a/database/prepared_statements/default_env.tres b/database/prepared_statements/default_env.tres
new file mode 100644
index 0000000..8419635
--- /dev/null
+++ b/database/prepared_statements/default_env.tres
@@ -0,0 +1,7 @@
+[gd_resource type="Environment3D" load_steps=2 format=3]
+
+[sub_resource type="ProceduralSky" id=1]
+
+[resource]
+background_mode = 2
+background_sky = SubResource( 1 )
diff --git a/database/prepared_statements/icon.png b/database/prepared_statements/icon.png
new file mode 100644
index 0000000000000000000000000000000000000000..5eaa3d1ad38ef8667b54c5ae78ec23c708023ae7
GIT binary patch
literal 3238
zcmV;X3|aGuP)<h;3K|Lk000e1NJLTq002M$002M;1^@s6s%dfF00001b5ch_0Itp)
z=>Px>U`a$lRCt`-n|pBF*Hy<q_xIZ0daadKtCd!^9+v!y>vm$tcH&MlOwxf#49O%W
zO`rif1P5@ZO$wy#5N4SE1!>Y^lBQuW$+(Y%QYbYLAc4j$xFNOku;YhfS;n$0*?PaV
zTJ7#{f4_VAV<kn8-PNwVe)0Wlch9-!ckcO}d+xdCo)yeOC=^0U*<|YaBfwUK*dm0e
z=LUvS>LTzyN*zgi-rs7Pc41^>WQH!LKZL_!fZYPVE`(Tq^;Ny{P)bc8#FHrXH-ke%
zz?1>P;V=UB3n6x1Qw^^Ylu|!Z@adtUAw(z?LesR*X+r$fd`8nW@!K|<u3rm1FB{VH
zNF<Y_)9HmYrFKgx_lolJ@+Q+TPRw@uva&L2qfrdQxT*?YDY&jnPj4@=SZwAuC1ot_
zc{l52fxzQJ)9#)o1k1{(ud74Tv}>a5m4K#clm~;PQYli71Aq|1rwK8n0o$e-l~P2b
z(QBpW6-P80MJYA=r&|nQ%k($f=PQZZyROU7@Gzd|Q56njS=N%|^bZWs)!mKbIILZ>
zhRRUrvh*?x1Ka1D@dAXn#XyM2G{aIAoeiZFZKqCgi_$R=^!4^J-cV0fW}7V-=Pz8K
zX(Yy4-9q_H-fKTk#VzHRy)-S$`p5uKJ4c!jV&RA)kw_$1=Ye0-F*S`k!>0OT4;MN*
z3K}n^r0vWZ){VufFieCHXhLJ1ZW52jFI&I)b1ZqJbJA)2V(zvX)D6~;PH^t**+s{9
zb$9cLM4Es$SH^N(Cy_{$R9CnH25?=MY>wpDbedxchKGl9j`ci`Q2#K?w1s(xj$rae
zFo2R0p|aD;b%T)$ow%->mEP0c%?jPjO4EcuP9{sG=0|c%E>PD|IYNmLf{nVFH6FOG
zOK5NeP0JmJ4E^$B)B>3$7pUvFN&?x_XIs-LABl1N#0h4v6$AKWj<*k)-9?(Y=}Se)
z4WR2fZjL1|jn$TqMy1eZ@p+K<?V~`y5e%T|Iw>Xd^9X@8FH$b1h@v#x^a5QLV^B&l
zF)@)daLq?5nIxqaae*a3qL@r1kTSn<i$z|;cXW0V=pUlmFi9)LsPu@NI;uQKbmhu9
zX|v~fbY8rO+ds%A-?EY_37`u>{rDuuPo89TQxm~pa1PyZ9QykEaU6$4BEfQ3l0agW
zm9eU^5k1F|KCc0^{z2BvnoO9?8kD1xoEvH(Sref)8bwOU>9#i3rxg)9a7A2I2tloB
z5s{L2PM;>+*hsXdhIl+qcW*D|@F?po8&hZ)LI+JpDaE<bF-C$TR8>`Fm7CW9W{!zy
znqZA)lNuc3!=66kx?roY@Lz@cfuU)9(k`R5vx{SWebhM~n=BjC4lLjmLQo|P`tvNw
zyc$oMCQ7NCZ`7x0Y_|L;GJ)-CK@)<H`TR%)x-b6$E~X^@Wx1DR-XLg4!Z?crw9H}U
z>P>$3bM<`NCYb=<fk$Ae2B@s8q|0^kv0T@1l)_hDo;N1t_W+-d{(y~F;;rXuq0>!K
z9f{=SSu_u5Zf@q3o0?xry6zE|9<j=b1>5C(ENTGDvalQK81xEDgsuljsrbNkXsBQO
zQmdfTU?dWu-8OJ<fTf_6qSZ-Ix2CzE`ewn$;pWw=`7kwE5O1)^`d=Yf7A(Uk;4qX>
zl8K5kD$2_Xl3TC=EXyL_eqaXz{Qftd;nnkJ_}<x8zTeT#6EA*~K!J+n!W}#B=f(F9
z@%@f={;|J{XMX%T8@At;liyVeUlGOKk`zQN+veFf-(bhCN6~#gjvYJ3*$d~n<I}&&
zo`VNi7A#wm+=svXM|^4DOW?OTeCRMeJw2@7wv|7B{WWg=<$Fq@dTEZs4?X#ZG;Fwu
zix)5Q)E_@ZcXtl}4Gj%E`}Jq|>{tJkzkc#73&yS4you<lM&AGN0h047zIE%?^6;0R
z<lFnc%`30G3S^R>U61YJkw-qm=bzuhiGyz~7*{Mx;sM)sWNy~}a?f)!lLzSR?Bs=S
zev2)?^ot9|R8&{<^c(-mm-fBH&L_UGfWG-tchP$K^vvWT6X0Hc>1EEGIYW6>6>Bzc
zx@_HxGJqm`E>P3ZfRvJ!mX-yymX;R6D_1PIVXkd%!u0uo%-f!iXwxcAoH&{Fc`Yp;
zW_VUL7NdSv6lDNG_LTBsTN|3DQC+<->#C`#ru%F=(({T^tn+kRR(TnjH2`$9o-Rse
zHk4!u{Pges9)MksJvLXkrt#a4KFWXp!w-v=`R?m)uyxZW)~=oF9UC`(jP2WR<KpQy
z&K*Cobfu?Ik|6jW`@X}?cm4u*-FGk5)e+u&^8mW0arfPKlj!MT|8p-CEpw!=pO?S#
z6yJF6FZj2Af1RG59_s7sx&MLtNyK98`MuBK6<DUrhk`v|v9rK4pZy)a_4ps)4h-@e
z4?f79n>TZC-*@=x&WEzPf9I)I5)%^u{O{2ZvdVn>pI_ro?zxwhmXFWue1L5mH*(;+
zukiTxJ2-!GVZ2!iL{&KK2q8?!G)L6c)n#Q=N^$nRBW&}Ru79dL5@F?<W=<V?r(`n6
zJ(qK#OdT*AE?v6B_*AEeQYu~W61Wm|zOjJ;#s&sTF1HvI6$AsJax}w07}sCZlmaxv
zAXHObR1ZN>LC}sw*ni@q$SbAf;17QU!104WqxXCVt%nX>5pS7>wQL#Ne`N<N*R7?x
zzMfSZH_-I)kI&He?%m4=U;A3Y@(PXtQcAkdo@J9S!1BrvE1H_9Z(7Aox86!+O@y28
zyc2+(krk*M(b>0rIlG^I8uGlMlmGJ;KYjHFIq8o*{b$^}`*#_<)XmAa-zGjf&bvQ3
z!06Br{pULv6L3bQsn0QwCC30w(@2bt<N76|<1t1rbaLvy4)UM-z6(I*idy!4cpTGb
z<G2%9Wqj(_ALjN4ck=c>{YzGQ!-fsq^=l9DlUIL`BjtkXhI)Rse?NP6?aoS1c`j5{
z6gsWqmcXRUz3(Qb4keat;p8}<tlPSU)}Q~J=XZZTE4`+<iM>bO!Svg>iR`@q;kr6n
z-g+yi9-b;LU>6kxovC|*Y)B_l0Nl3Y9>Vo?gzM|jOcTv8K+inp6Sv>asl)H(lt0qj
z2SBJQ0xA>KG{YcJQ9-!Aj_SrnYMWOv)Z3d=MnZY`{r-aIRFnt!Z5z+aJ}8}X7#|+y
z@fV)UE2I5b?)24}YJqv_#F4x*PQRPoh)O9sJcp({_W<)zlmUXlARPmPtTq=~SfKc=
z=Jgm;)fmgRSzejx>#M16pt3e|fH`vDK<)=9#Zx=(BT}CUU~NZ^B0Uc`oo0Ms5CG5h
zAjkE)R4@+Mwq5X?iZVcTB*M|IE*f<oMwUn}gut6>OirZJB&MS6Ku2f6&uBgT4y}im
zmKkaSmU#-taSHBvEGh=rwvFHK$IVd}xYiIt&}{h_A0IDxOi>2#Jdfn$BtCKdHd2Rm
zgVC|Eg87S@NqlmWX48K~Grh}&PiVwPM+@dJ$^a9w7%Ows=3OaK^6D%NsT6~*L!axA
zns-?vgrJeayGn}+f)it71ZKIvREjar<4ih9((fZ4i?Pn~v(m7zgtqAQbusXyB!!~S
zb7*tZL~Cl$b)EC^ILpQ-xXEW@O||IO8Ybt)#tO;@3O0aJ3TI*hVVB`b$tBmJ%QmTs
zR?{2`VVWlCbeh4TA&!oWFflQK;Yz9vgOL8wV+0V)(h3WZQj+AXM9Wc%G3hbvx_G9}
z@<4!acqQAy;W<4&$z+mKeSP=_hgog-Foec<EJkes|9zNafW;g*CM5@)I5jmjR7WCg
zoT}<h!!%85qtTfMr&1~6laow1bMKS}Q>m<7XO?AQ&Rb$Z!=N@0$h)`Ow#}->M!dQ@
z+6M+092~@#<K52BWJOhFWtY&j6#zb;kJZi1IUn@@0qyPWGyfM*Qg&-fh?#<1GMU6H
zvV46b!F64dsnpDOCBz3BaCG_yAq2g74jMN)`uh6jY~ezwcSSH5Tw|H$F(JfEpILb@
zNHiMF*<5&|!Sg(NdVA+&h)SurlTL3Ep^6H0O?yIU+Vk@V`Ya3Ee|;xD`JkjEnM}_9
zkI)RHQeW^q@5SkviEudlnkK}(S69Vr1105agTuoQ0BSm`Q7CnvlJbj6slwVoZa^rd
z;!4Ud0{1hu>(BA+s`7G>a;>tg-vqV_*dm0exdytH3`(g!1xJAQ)9Lj0bWLj?nRQn9
YKS0)|(`eK%fB*mh07*qoM6N<$f~sd<Pyhe`

literal 0
HcmV?d00001

diff --git a/database/prepared_statements/icon.png.import b/database/prepared_statements/icon.png.import
new file mode 100644
index 0000000..a4c02e6
--- /dev/null
+++ b/database/prepared_statements/icon.png.import
@@ -0,0 +1,35 @@
+[remap]
+
+importer="texture"
+type="StreamTexture"
+path="res://.import/icon.png-487276ed1e3a0c39cad0279d744ee560.stex"
+metadata={
+"vram_texture": false
+}
+
+[deps]
+
+source_file="res://icon.png"
+dest_files=[ "res://.import/icon.png-487276ed1e3a0c39cad0279d744ee560.stex" ]
+
+[params]
+
+compress/mode=0
+compress/lossy_quality=0.7
+compress/hdr_mode=0
+compress/bptc_ldr=0
+compress/normal_map=0
+flags/repeat=0
+flags/filter=true
+flags/mipmaps=false
+flags/anisotropic=false
+flags/srgb=2
+process/fix_alpha_border=true
+process/premult_alpha=false
+process/HDR_as_SRGB=false
+process/invert_color=false
+process/normal_map_invert_y=false
+stream=false
+size_limit=0
+detect_3d=true
+svg/scale=1.0
diff --git a/database/prepared_statements/project.pandemonium b/database/prepared_statements/project.pandemonium
new file mode 100644
index 0000000..cf040d2
--- /dev/null
+++ b/database/prepared_statements/project.pandemonium
@@ -0,0 +1,25 @@
+; Engine configuration file.
+; It's best edited using the editor UI and not directly,
+; since the parameters that go here are not all obvious.
+;
+; Format:
+;   [section] ; section goes between []
+;   param=value ; assign values to parameters
+
+config_version=4
+
+[application]
+
+config/name="Database Prepared Statements"
+run/main_scene="res://Main.tscn"
+config/icon="res://icon.png"
+
+[physics]
+
+common/enable_pause_aware_picking=true
+
+[rendering]
+
+vram_compression/import_etc=true
+vram_compression/import_etc2=false
+environment/default_environment="res://default_env.tres"