123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106 |
- extends Node
- func Create(db,key,value):
- print(key)
- print(value)
- var truncatekey = ''
- var truncatevalue = ''
- for i in key.size()-1:
- truncatekey += str(key[i]) + ','
- for i in value.size()-1:
- truncatevalue += "'"+str(value[i])+"'" + ','
-
- truncatekey += key.back()
- truncatevalue += "'"+str(value.back())+"'"
-
- print(truncatekey)
- print(truncatevalue)
-
- var db_command = ("""
- insert into %s (%s) values (%s);
- """ % [db, truncatekey, truncatevalue])
- print(db_command)
- database.execute(db_command)
- func Read(db, key, value):
- var db_command = ("""
- select * from %s where %s = %s;
- """ % [db, key, value])
- print(db_command)
- var datas := database.execute(db_command)
- var ret
- for data in datas:
- ret = (data.data_row)
- return ret
- func Update(db, key, value, wherekey, wherevalue):
- var db_command = ("""
- update %s set %s = %s where %s = %s;
- """ % [db, key, value, wherekey, wherevalue])
- print(db_command)
- database.execute(db_command)
- func Delete(db, key, value):
- var db_command = ("""
- delete from %s where %s = %s;
- """ % [db, key, value])
- print(db_command)
- database.execute(db_command)
- var database := PostgreSQLClient.new()
- const USER = "godot"
- const PASSWORD = "godotisfree"
- const HOST = "localhost"
- const PORT = 5432 # Default postgres port
- const DATABASE = "godot" # Database name
- func _ready():
- print('Database is being loaded...')
- var _error := database.connect("connection_established", self, "_executer")
- _error = database.connect("authentication_error", self, "_authentication_error")
- _error = database.connect("connection_closed", self, "_close")
- _error = database.connect_to_host("postgresql://%s:%s@%s:%d/%s" % [USER, PASSWORD, HOST, PORT, DATABASE])
- func _physics_process(_delta: float) -> void:
- database.poll()
- func _authentication_error(error_object: Dictionary) -> void:
- prints("Error connection to database:", error_object["message"])
- func _executer() -> void:
- database.execute("""
- create table login_database(
- id serial primary key,
- email varchar(64) unique not null,
- username varchar(64) unique not null,
- password varchar(64) not null,
- salt varchar(64) not null,
- creation_date varchar(64) not null
- );
- """)
-
- database.execute("""
- create table validtokens_database(
- id serial primary key,
- username varchar(64) not null,
- token varchar(64) unique not null,
- ip varchar(64) not null,
- creation_date varchar(64) not null
- );
- """)
- # print('readitng data test')
- # print(Read('validtokens_database','username',"'22222222'"))
- # Create('niggers',["crime","executiondate"],["'das rite'","'2017-06-01'"])
- # Update('niggers',"executiondate","'2019-08-07'" , "crime", "'das rite'")
- # print(Read('niggers',"crime","'das rite'"))
- # Delete('niggers',"crime","'das rite'")
- # print(Read('niggers',"crime","'das rite'"))
- func _close(clean_closure := true) -> void:
- prints("DB CLOSE,", "Clean closure:", clean_closure)
- func _exit_tree() -> void:
- print('closing')
- database.close()
|