- Bryan Yehuda Mannuel
- Calvin Mannuel Simatupang
- Ian Felix Jonathan Simanjuntak
- Muhammad Nur Fauzan
Kami membuat temple kode untuk client server nya. Berikut adalah template yang kami gunakan dalam membuat socket.
kode template untuk client.
*ini client*
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/stat.h>
#include <dirent.h>
#include <ctype.h>
#define PORT 4443
//Fungsi lain
int main(int argc, char *argv[]){
int clientSocket, ret;
struct sockaddr_in serverAddr;
char buffer[32000];
clientSocket = socket(AF_INET, SOCK_STREAM, 0);
if(clientSocket < 0){
printf("[-]Error in connection.\n");
exit(1);
}
printf("[+]Client Socket is created.\n");
memset(&serverAddr, '\0', sizeof(serverAddr));
serverAddr.sin_family = AF_INET;
serverAddr.sin_port = htons(PORT);
serverAddr.sin_addr.s_addr = inet_addr("127.0.0.1");
ret = connect(clientSocket, (struct sockaddr*)&serverAddr, sizeof(serverAddr));
if(ret < 0){
printf("[-]Error in connection.\n");
exit(1);
}
printf("[+]Connected to Server.\n");
while(1){
printf("Client: \t");
char input[10000];
char perintah[100][10000];
char *token;
int i=0;
scanf(" %[^\n]s", input);
printf("ini input %s\n", input);
token = strtok(input, " ");
while( token != NULL ) {
strcpy(perintah[i], token);
i++;
token = strtok(NULL, " ");
}
// kodelain
// printf("printah 0 : %s\n", perintah[0]);
if(strcmp(perintah[0], ":exit") == 0){
close(clientSocket);
printf("[-]Disconnected from server.\n");
exit(1);
}
if(recv(clientSocket, buffer, 1024, 0) < 0){
printf("[-]Error in receiving data.\n");
}else{
printf("Server: \t%s\n", buffer);
}
}
return 0;
}*Ini Server*
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#define PORT 4443
struct allowed{
char name[10000];
char password[10000];
};
int main(){
int sockfd, ret;
struct sockaddr_in serverAddr;
int newSocket;
struct sockaddr_in newAddr;
socklen_t addr_size;
char buffer[1024];
pid_t childpid;
sockfd = socket(AF_INET, SOCK_STREAM, 0);
if(sockfd < 0){
printf("[-]Error in connection.\n");
exit(1);
}
printf("[+]Server Socket is created.\n");
memset(&serverAddr, '\0', sizeof(serverAddr));
serverAddr.sin_family = AF_INET;
serverAddr.sin_port = htons(PORT);
serverAddr.sin_addr.s_addr = inet_addr("127.0.0.1");
ret = bind(sockfd, (struct sockaddr*)&serverAddr, sizeof(serverAddr));
if(ret < 0){
printf("[-]Error in binding.\n");
exit(1);
}
printf("[+]Bind to port %d\n", 4444);
if(listen(sockfd, 10) == 0){
printf("[+]Listening....\n");
}else{
printf("[-]Error in binding.\n");
}
while(1){
newSocket = accept(sockfd, (struct sockaddr*)&newAddr, &addr_size);
if(newSocket < 0){
exit(1);
}
printf("Connection accepted from %s:%d\n", inet_ntoa(newAddr.sin_addr), ntohs(newAddr.sin_port));
if((childpid = fork()) == 0){
close(sockfd);
while(1){
recv(newSocket, buffer, 1024, 0);
printf("buffer %s\n", buffer);
//kode lain
if(strcmp(buffer, ":exit") == 0){
printf("Disconnected from %s:%d\n", inet_ntoa(newAddr.sin_addr), ntohs(newAddr.sin_port));
break;
}else{
printf("Client: %s\n", buffer);
send(newSocket, buffer, strlen(buffer), 0);
bzero(buffer, sizeof(buffer));
}
}
}
}
close(newSocket);
return 0;
}Setelah kami membuat kode template untuk komunikasi client-server dengan menggunakan socket. setelah itu kami akan memproses bagaimana cara client dan server berkomunikasi.
//Library lain
//fungsi lain
int main(int argc, char *argv[]){
// printf("%s\n", argv[0]);
int allowed=0;
int id_user = geteuid();
char database_used[1000];
if(geteuid() == 0){
// printf("I AM ROOT");
allowed=1;
}else{
int id = geteuid();
// printf("ID kamu : %d", id);
allowed = cekAllowed(argv[2],argv[4]);
}
if(allowed==0){
return 0;
}
//Kode lain
return 0;
}cara yang kami lakukan adalah dengan mengambil uid dari user yang memanggil program ini. Jika UID nya adalah 0, maka dia adalah user root.
2. Setelah membuat bagaimana cara root mengakses program, sekarang kami membuat proses bagaimana cara root untuk membuat CREATE USER
//kode lain
scanf(" %[^\n]s", input);
strcpy(copyinput, input);
// printf("ini input %s\n", input);
token = strtok(input, " ");
while( token != NULL ) {
strcpy(perintah[i], token);
// printf("%s\n", perintah[i]);
i++;
token = strtok(NULL, " ");
}
//kode lainsetiap input user langsung kami pisahkan berdasarkan spasi menggunakan strtok, lalu kami salin ke variable perintah. Nah setelah itu kami memproses input user tersebut dengan kode dibawah ini
if(strcmp(perintah[0], "CREATE")==0){
if(strcmp(perintah[1], "USER")==0 && strcmp(perintah[3], "IDENTIFIED")==0 && strcmp(perintah[4], "BY")==0){
snprintf(buffer, sizeof buffer, "cUser:%s:%s:%d", perintah[2], perintah[5], id_user);
send(clientSocket, buffer, strlen(buffer), 0);
}else if(strcmp(perintah[1], "DATABASE")==0){
// kode lain
}else if(strcmp(perintah[1], "TABLE")==0){
//kode lain
}
}Hal yang kami lakukan adalah kami mengirimkan flag ke server dimana awal flag tersebut adalah cUSER lalu kami mengirimkan data seperti username dan password serta UID ke server. Untuk diserver, akan dihandle dengan kode dibawah ini.
*Server*
token = strtok(buffercopy, ":");
int i=0;
char database_used[1000];
while( token != NULL ) {
strcpy(perintah[i], token);
i++;
token = strtok(NULL, ":");
}Karna kami mengirimkan dari client menggunakan ":", sehingga pada server kami akan memecah informasi tersebut menggunakan strtok lalu menyalinnya ke variabel perintah. Setelah kita mendapatkan semua perintah, untuk pemrosesannya menggunakan kode berikut ini
if(strcmp(perintah[0], "cUser")==0){
if(strcmp(perintah[3], "0")==0){
createUser(perintah[1], perintah[2]);
}else{
char peringatan[] = "You're Not Allowed";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
}
}
//kode lainpada kode ini kita lihat kami memfilter flag cUSER yang dikirim dari client. Karena create user hanya bisa dilakukan oleh ROOT maka kami membuat handler bagaimana jika ada yang menjalankan perintah tersebut tetapi bukan root dengan mengirimkan pesan "Youre not allowed" kepada user. JIka yang mengakses tersebut adalah root, maka jalankan fungsi createUser. Fungsi createuser yang digunakan adalah sebagai berikut
struct allowed{
char name[10000];
char password[10000];
};
void createUser(char *nama, char *password){
struct allowed user;
strcpy(user.name, nama);
strcpy(user.password, password);
printf("%s %s\n", user.name, user.password);
char fname[]={"databases/user.dat"};
FILE *fp;
fp=fopen(fname,"ab");
fwrite(&user,sizeof(user),1,fp);
fclose(fp);
}Pertama kami menyimpan data yang diparsingkan ke fungsi createUser kedalam struct user. setelah kami menyimpan dalam struct, variabel tersebut kami write ke file yang bernama user.dat
int main(int argc, char *argv[]){
// printf("%s\n", argv[0]);
int allowed=0;
int id_user = geteuid();
char database_used[1000];
if(geteuid() == 0){
// printf("I AM ROOT");
allowed=1;
}else{
int id = geteuid();
// printf("ID kamu : %d", id);
allowed = cekAllowed(argv[2],argv[4]);
}
if(allowed==0){
return 0;
}
//Kode lain
return 0;
}Pada kode tersebut kami melihat apakah user merupakan root atau tidak. Jika tidak root, maka kami akan cek apakah user tersebut berhak mengakses program yang dipanggil melalui fungsi cekAllowed. Fungsi cekAllowed adalah sebagai berikut :
struct allowed{
char name[10000];
char password[10000];
};
int cekAllowed(char *username, char *password){
FILE *fp;
struct allowed user;
int id,found=0;
fp=fopen("../database/databases/user.dat","rb");
while(1){
fread(&user,sizeof(user),1,fp);
if(strcmp(user.name, username)==0){
if(strcmp(user.password, password)==0){
found=1;
}
}
if(feof(fp)){
break;
}
}
fclose(fp);
if(found==0){
printf("You're Not Allowed\n");
return 0;
}else{
return 1;
}
}Untuk mengecek apakah user bisa mengakses program, hal pertama yang kami lakukan adalah membaca file user.dat dan karena data yang ada disimpan dalam bentuk struct maka kita juga harus membaca dalam bentuk struct. Setelah itu kami baca perline setiap filenya lalu kami bandingkan apakah usernama dan password nya sama. setelah sama, maka dia akan return 1 yang mengartikan dia berhak menggunakan program.
else if(strcmp(perintah[0], "GRANT")==0 && strcmp(perintah[1], "PERMISSION")==0 && strcmp(perintah[3], "INTO")==0){
snprintf(buffer, sizeof buffer, "gPermission:%s:%s:%d", perintah[2],perintah[4], id_user);
send(clientSocket, buffer, strlen(buffer), 0);
}Hal yang kami lihat apakah user menggunakan perintah GRANT PERMISSION namaDB INTO user. setelah itu kami kirimkan flag gPermission serta beberapa variable lain kerserver. untuk handler di server, kami memisahkan menggunakan strtok seperti yang sudah kami jelaskan sebelumnya diatas. Lalu diproses menggunakan kode dibawah ini.
else if(strcmp(perintah[0], "gPermission")==0){
if(strcmp(perintah[3], "0")==0){
int exist = cekUserExist(perintah[2]);
if(exist == 1){
insertPermission(perintah[2], perintah[1]);
}else{
char peringatan[] = "User Not Found";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
}
}else{
char peringatan[] = "You're Not Allowed";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
}
}jika flag yang dikirimkan oleh user adalah "gPermission" lalu kami cek dahulu apa user yang ingin diberikan permission ada atau tidak. jika ada panggil fungsi insertPermission. JIka tidak ditemukan, balas ke client bahwa user not found. Ttetapi jika yang mengirimkan perintah bukan root, maka balas you're not allowed. Untuk fungsi inserPermission berikut adalah kode yang kami gunakan
struct allowed_database{
char database[10000];
char name[10000];
};
void insertPermission(char *nama, char *database){
struct allowed_database user;
strcpy(user.name, nama);
strcpy(user.database, database);
printf("%s %s\n", user.name, user.database);
char fname[]={"databases/permission.dat"};
FILE *fp;
fp=fopen(fname,"ab");
fwrite(&user,sizeof(user),1,fp);
fclose(fp);
}kami juga menyimpan daftar izin setiap user menggunakan struct pada file yang bernama permission.dat.
Berikut adalah kode yang kami gunakan pada sisi client untuk melakukan handle USE
else if(strcmp(perintah[0], "USE")==0){
snprintf(buffer, sizeof buffer, "uDatabase:%s:%s:%d", perintah[1], argv[2], id_user);
send(clientSocket, buffer, strlen(buffer), 0);
}Hal yang penting dari ini adalah kami mengirimkan flag uDatabase sebagai tanda user menggunakan perintah use database. pada server kami menggunakan perintah dibawah ini untuk menghandle perintah tersebut
else if(strcmp(perintah[0], "uDatabase") == 0){
if(strcmp(perintah[3], "0") != 0){
int allowed = cekAllowedDatabase(perintah[2], perintah[1]);
if(allowed != 1){
char peringatan[] = "Access_database : You're Not Allowed";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
}else{
strncpy(database_used, perintah[1], sizeof(perintah[1]));
char peringatan[] = "Access_database : Allowed";
printf("database_used = %s\n", database_used);
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
}
}
}Setelah memastikan flag yang dikirim user, kami memanggil fungsi cekAllowedDatabase untuk mengecek apakah user boleh menggunakan database tersbut. Jika boleh maka kami memasukkan database yang digunakan ke dalam variabel database_used. Jika tidak boleh, maka akan membalas ke user acces database not allowed. Berikut adalah fungsi dari cekAllowedDatabase.
int cekAllowedDatabase(char *nama, char *database){
FILE *fp;
struct allowed_database user;
int id,found=0;
printf("nama = %s database = %s", nama, database);
fp=fopen("../database/databases/permission.dat","rb");
while(1){
fread(&user,sizeof(user),1,fp);
if(strcmp(user.name, nama)==0){
// printf("MASUK!");
if(strcmp(user.database, database)==0){
return 1;
}
}
if(feof(fp)){
break;
}
}
fclose(fp);
return 0;
}karna pada insert permission kami menggnuakan struct dalam menyimpan permission, maka untuk membaca nya kami juga menggunakan struct. Untuk setiap data yang dibaca dari file, maka kami bandingkan dengan inputan dari user untuk di cek apakah sama atau tidak. Jika tidak sama return 0 atau jika sama return 1.
Berikut adalah kode yang kami gunakan pada sisi client untuk melakukan handle database
if(strcmp(perintah[0], "CREATE")==0){
if(strcmp(perintah[1], "USER")==0 && strcmp(perintah[3], "IDENTIFIED")==0 && strcmp(perintah[4], "BY")==0){
// kodelain
}else if(strcmp(perintah[1], "DATABASE")==0){
snprintf(buffer, sizeof buffer, "cDatabase:%s:%s:%d", perintah[2], argv[2], id_user);
send(clientSocket, buffer, strlen(buffer), 0);
}else if(strcmp(perintah[1], "TABLE")==0){
// Kode lain
}
}flag yang dikirimkan oleh user ketika menjalankan perintah ini ke server adalah cDatabase dan juga beberapa informasi lainnya. Untuk pada server kami menghandle dengan cara berikut
else if(strcmp(perintah[0], "cDatabase")==0){
char lokasi[20000];
snprintf(lokasi, sizeof lokasi, "databases/%s", perintah[1]);
printf("lokasi = %s, nama = %s , database = %s\n", lokasi, perintah[2], perintah[1]);
mkdir(lokasi,0777);
insertPermission(perintah[2], perintah[1]);
}nah karena membuat database, bearti membuat sebuah folder, maka kami menggunakan mkdir. dan karna yang membuat database, langsung mempunyai akses maka kami memanggil fungsi insertPermission(sudah dijelaskan diatas) untuk memasukkan permission user tersebut.
Apabila user memasukkan perintah "CREATE" dan juga "TABLE" [nama_tabel] ([nama_kolom] [tipe_data], ...); maka akan dilakukan pemanggilan perintah snprintf dengan parameter buffer, sizeof buffer, "cTable:%s", dan copyinput dimana hasil inputan dari User ini berupa [nama_tabel], [nama_kolom], dan [tipe_data] akan dilakukan penyimpanan kedalam buffer dengan size sebesar ukuran inputan. Kemudian Inputan ini akan dilakukan pengiriman ke Database dengan melakukan pemanggilan fungsi send dengan parameter clientSocket, buffer, strlen(buffer), 0 yang nantinya fungsi ini akan melakukan pengiriman hasil inputan dari user yang tersimpan di dalam buffer ke server untuk melakukan pembuatan table.
if(strcmp(perintah[0], "CREATE")==0){
if(strcmp(perintah[1], "USER")==0 && strcmp(perintah[3], "IDENTIFIED")==0 && strcmp(perintah[4], "BY")==0){
snprintf(buffer, sizeof buffer, "cUser:%s:%s:%d", perintah[2], perintah[5], id_user);
// printf("%s\n", buffer);
send(clientSocket, buffer, strlen(buffer), 0);
}else if(strcmp(perintah[1], "DATABASE")==0){
snprintf(buffer, sizeof buffer, "cDatabase:%s:%s:%d", perintah[2], argv[2], id_user);
// printf("%s\n", buffer);
send(clientSocket, buffer, strlen(buffer), 0);
}else if(strcmp(perintah[1], "TABLE")==0){
snprintf(buffer, sizeof buffer, "cTable:%s", copyinput);
// printf("%s\n", buffer);
send(clientSocket, buffer, strlen(buffer), 0);
}Kemudian di bagian server, pertama-tama akan dilakukan pencarian database, jika database belum dilakukan pemilihan, maka kembalikan kalimat "You're not selecting database yet" ke dalam buffer untuk dilakukan pengiriman kembali kepada client.
else if(strcmp(perintah[0], "cTable")==0){
printf("%s\n", perintah[1]);
char *tokens;
if(database_used[0] == '\0'){
strcpy(database_used, "You're not selecting database yet");
send(newSocket, database_used, strlen(database_used), 0);
bzero(buffer, sizeof(buffer));Kemudian, jika database sudah dilakukan pemilihan, maka ambil perintah yang tadi dikirimkan dan lakukan penyimpanan kedalam buffer. Lalu lakukan pembuatan table didalam file yang ditunjuk sesuai dengan yang diminta oleh user pada perintah [nama_tabel], pembuatan kolom didalam file yang ditunjuk sesuai dengan yang diminta oleh user pada perintah [nama_kolom], beserta dengan tipe data yang diminta sebanyak iterasi pemanggilan data yang diminta oleh user. Dan dengan demikian fungsi Create Table sudah berhasil dilakukan.
}else{
char daftarQuery[100][10000];
char copyPerintah[20000];
snprintf(copyPerintah, sizeof copyPerintah, "%s", perintah[1]);
tokens = strtok(copyPerintah, "(), ");
int jumlah=0;
while( tokens != NULL ) {
strcpy(daftarQuery[jumlah], tokens);
printf("%s\n", daftarQuery[jumlah]);
jumlah++;
tokens = strtok(NULL, "(), ");
}
char buatTable[20000];
snprintf(buatTable, sizeof buatTable, "../database/databases/%s/%s", database_used, daftarQuery[2]);
int iterasi = 0;
int iterasiData = 3;
struct table kolom;
while(jumlah > 3){
strcpy(kolom.data[iterasi], daftarQuery[iterasiData]);
printf("%s\n", kolom.data[iterasi]);
strcpy(kolom.type[iterasi], daftarQuery[iterasiData+1]);
iterasiData = iterasiData+2;
jumlah=jumlah-2;
iterasi++;
}
kolom.jumlahkolom = iterasi;
printf("iterasi = %d\n", iterasi);
FILE *fp;
printf("%s\n", buatTable);
fp=fopen(buatTable,"ab");
fwrite(&kolom,sizeof(kolom),1,fp);
fclose(fp);Apabila user memasukkan perintah "DROP" DATABASE [nama_database] maka akan dilakukan pemanggilan perintah snprintf dengan parameter buffer, sizeof buffer, dDatabase:%s", dan copyinput dimana hasil inputan dari User ini berupa [nama_database] akan dilakukan penyimpanan kedalam buffer dengan size sebesar ukuran inputan. Kemudian Inputan ini akan dilakukan pengiriman ke Database dengan melakukan pemanggilan fungsi send dengan parameter clientSocket, buffer, strlen(buffer), 0 yang nantinya fungsi ini akan melakukan pengiriman hasil inputan dari user yang tersimpan di dalam buffer ke server untuk melakukan drop database.
else if(strcmp(perintah[0], "DROP")==0){
if(strcmp(perintah[1], "DATABASE")==0){
snprintf(buffer, sizeof buffer, "dDatabase:%s:%s", perintah[2], argv[2]);
send(clientSocket, buffer, strlen(buffer), 0);
}else if(strcmp(perintah[1], "TABLE")==0){
snprintf(buffer, sizeof buffer, "dTable:%s:%s", perintah[2], argv[2]);
send(clientSocket, buffer, strlen(buffer), 0);
}else if(strcmp(perintah[1], "COLUMN")==0){
// printf("masuk\n");
snprintf(buffer, sizeof buffer, "dColumn:%s:%s:%s", perintah[2], perintah[4] ,argv[2]);
send(clientSocket, buffer, strlen(buffer), 0);
}Kemudian, kita melakukan check terlebih dahulu apakah database yang diminta termasuk dalam database yang allowed atau diperbolehkan untuk dihapus. Jika database tidak termasuk dalam database yang allowed maka kembalikan kalimat "Access_database : You're Not Allowed" ke dalam buffer untuk dilakukan pengiriman kembali kepada client.
else if(strcmp(perintah[0], "dDatabase")==0){
int allowed = cekAllowedDatabase(perintah[2], perintah[1]);
if(allowed != 1){
char peringatan[] = "Access_database : You're Not Allowed";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
continue;Namun, jika database termasuk dalam database yang allowed maka lakukan penghapusan database tersebut dan kembalikan kalimat "Database Has Been Removed" ke dalam buffer untuk dilakukan pengiriman kembali kepada client. Dan dengan demikian fungsi Drop Database sudah berhasil dilakukan.
}else{
char hapus[20000];
snprintf(hapus, sizeof hapus, "rm -r databases/%s", perintah[1]);
system(hapus);
char peringatan[] = "Database Has Been Removed";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
}Apabila user memasukkan perintah "DROP" TABLE [nama_tabel] maka akan dilakukan pemanggilan perintah snprintf dengan parameter buffer, sizeof buffer, dTable:%s", dan copyinput dimana hasil inputan dari User ini berupa [nama_table] akan dilakukan penyimpanan kedalam buffer dengan size sebesar ukuran inputan. Kemudian Inputan ini akan dilakukan pengiriman ke Database dengan melakukan pemanggilan fungsi send dengan parameter clientSocket, buffer, strlen(buffer), 0 yang nantinya fungsi ini akan melakukan pengiriman hasil inputan dari user yang tersimpan di dalam buffer ke server untuk melakukan drop table.
else if(strcmp(perintah[0], "DROP")==0){
if(strcmp(perintah[1], "DATABASE")==0){
snprintf(buffer, sizeof buffer, "dDatabase:%s:%s", perintah[2], argv[2]);
send(clientSocket, buffer, strlen(buffer), 0);
}else if(strcmp(perintah[1], "TABLE")==0){
snprintf(buffer, sizeof buffer, "dTable:%s:%s", perintah[2], argv[2]);
send(clientSocket, buffer, strlen(buffer), 0);
}else if(strcmp(perintah[1], "COLUMN")==0){
// printf("masuk\n");
snprintf(buffer, sizeof buffer, "dColumn:%s:%s:%s", perintah[2], perintah[4] ,argv[2]);
send(clientSocket, buffer, strlen(buffer), 0);
}Kemudian di bagian server, pertama-tama akan dilakukan pencarian database, jika database belum dilakukan pemilihan, maka kembalikan kalimat "You're not selecting database yet" ke dalam buffer untuk dilakukan pengiriman kembali kepada client.
else if(strcmp(perintah[0], "dTable")==0){
if(database_used[0] == '\0'){
strcpy(database_used, "You're not selecting database yet");
send(newSocket, database_used, strlen(database_used), 0);
bzero(buffer, sizeof(buffer));
continue;
}Kemudian, jika database sudah dilakukan pemilihan, maka ambil perintah yang tadi dikirimkan dan lakukan penyimpanan kedalam buffer. Lalu lakukan penghapusan table yang diminta dan kembalikan kalimat "Table Has Been Removed" ke dalam buffer untuk dilakukan pengiriman kembali kepada client. Dan dengan demikian fungsi Drop Table sudah berhasil dilakukan.
char hapus[20000];
snprintf(hapus, sizeof hapus, "databases/%s/%s", database_used ,perintah[1]);
remove(hapus);
char peringatan[] = "Table Has Been Removed";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));Apabila user memasukkan perintah "DROP" COLUMN [nama_kolom] FROM TABLE [nama_tabel] maka akan dilakukan pemanggilan perintah snprintf dengan parameter buffer, sizeof buffer, dColumn:%s", dan copyinput dimana hasil inputan dari User ini berupa [nama_kolom] dan [nama_table] akan dilakukan penyimpanan kedalam buffer dengan size sebesar ukuran inputan. Kemudian Inputan ini akan dilakukan pengiriman ke Database dengan melakukan pemanggilan fungsi send dengan parameter clientSocket, buffer, strlen(buffer), 0 yang nantinya fungsi ini akan melakukan pengiriman hasil inputan dari user yang tersimpan di dalam buffer ke server untuk melakukan drop column.
else if(strcmp(perintah[0], "DROP")==0){
if(strcmp(perintah[1], "DATABASE")==0){
snprintf(buffer, sizeof buffer, "dDatabase:%s:%s", perintah[2], argv[2]);
send(clientSocket, buffer, strlen(buffer), 0);
}else if(strcmp(perintah[1], "TABLE")==0){
snprintf(buffer, sizeof buffer, "dTable:%s:%s", perintah[2], argv[2]);
send(clientSocket, buffer, strlen(buffer), 0);
}else if(strcmp(perintah[1], "COLUMN")==0){
// printf("masuk\n");
snprintf(buffer, sizeof buffer, "dColumn:%s:%s:%s", perintah[2], perintah[4] ,argv[2]);
send(clientSocket, buffer, strlen(buffer), 0);
}Kemudian di bagian server, pertama-tama akan dilakukan pencarian database, jika database belum dilakukan pemilihan, maka kembalikan kalimat "You're not selecting database yet" ke dalam buffer untuk dilakukan pengiriman kembali kepada client.
else if(strcmp(perintah[0], "dColumn")==0){
if(database_used[0] == '\0'){
strcpy(database_used, "You're not selecting database yet");
send(newSocket, database_used, strlen(database_used), 0);
bzero(buffer, sizeof(buffer));
continue;
}Kemudian, jika database sudah dilakukan pemilihan, maka ambil perintah yang tadi dikirimkan dan lakukan penyimpanan kedalam buffer. Lalu lakukan pencarian column didalam file yang ditunjuk sesuai dengan yang diminta oleh user pada perintah [nama_column]. Jika column tidak dapat ditemukan maka kembalikan kalimat "Column Not Found" ke dalam buffer untuk dilakukan pengiriman kembali kepada client.
char buatTable[20000];
snprintf(buatTable, sizeof buatTable, "databases/%s/%s", database_used, perintah[2]);
int index = findColumn(buatTable, perintah[1]);
if(index == -1){
char peringatan[] = "Column Not Found";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
continue;
}Jika column berhasil ditemukan, lakukan penghapusan column yang diminta dan kembalikan kalimat "column Has Been Removed" ke dalam buffer untuk dilakukan pengiriman kembali kepada client. Dan dengan demikian fungsi Drop column sudah berhasil dilakukan.
// printf("%d\n", index);
deleteColumn(buatTable, index);
char peringatan[] = "Column Has Been Removed";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));Apabila user memasukkan perintah "INSERT" dan juga "INTO" [nama_tabel] ([value], ...); maka akan dilakukan pemanggilan perintah snprintf dengan parameter buffer, sizeof buffer, "insert:%s", dan copyinput dimana hasil inputan dari User ini berupa [nama_tabel] dan [value] akan dilakukan penyimpanan kedalam buffer dengan size sebesar ukuran inputan. Kemudian Inputan ini akan dilakukan pengiriman ke Database dengan melakukan pemanggilan fungsi send dengan parameter clientSocket, buffer, strlen(buffer), 0 yang nantinya fungsi ini akan melakukan pengiriman hasil inputan dari user yang tersimpan di dalam buffer ke server untuk dimasukkan kedalam Database.
else if(strcmp(perintah[0], "INSERT")==0 && strcmp(perintah[1], "INTO")==0){
snprintf(buffer, sizeof buffer, "insert:%s", copyinput);
send(clientSocket, buffer, strlen(buffer), 0);Kemudian di bagian server, pertama-tama akan dilakukan pencarian database, jika database belum dilakukan pemilihan, maka kembalikan kalimat "You're not selecting database yet" ke dalam buffer untuk dilakukan pengiriman kembali kepada client.
else if(strcmp(perintah[0], "insert")==0){
if(database_used[0] == '\0'){
strcpy(database_used, "You're not selecting database yet");
send(newSocket, database_used, strlen(database_used), 0);
bzero(buffer, sizeof(buffer));
continue;
}Kemudian, jika database sudah dilakukan pemilihan, maka ambil perintah yang tadi dikirimkan dan lakukan penyimpanan kedalam buffer. Lalu lakukan pencarian table didalam file yang ditunjuk sesuai dengan yang diminta oleh user pada perintah [nama_tabel]. Jika table tidak dapat ditemukan maka kembalikan kalimat "TABLE NOT FOUND" ke dalam buffer untuk dilakukan pengiriman kembali kepada client.
char daftarQuery[100][10000];
char copyPerintah[20000];
snprintf(copyPerintah, sizeof copyPerintah, "%s", perintah[1]);
// printf("%s\n", copyPerintah);
char *tokens;
tokens = strtok(copyPerintah, "\'(), ");
int jumlah=0;
while( tokens != NULL ) {
strcpy(daftarQuery[jumlah], tokens);
// printf("%s\n", daftarQuery[jumlah]);
jumlah++;
tokens = strtok(NULL, "\'(), ");
}
char buatTable[20000];
snprintf(buatTable, sizeof buatTable, "databases/%s/%s", database_used, daftarQuery[2]);
// printf("buat table = %s\n", buatTable);
FILE *fp;
// printf("%s\n", buatTable);
int banyakKolom;
fp=fopen(buatTable,"r");
if (fp == NULL){
char peringatan[] = "TABLE NOT FOUND";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
continue;Jika table berhasil ditemukan, maka lakukan pembuatan kolom sesuai dengan banyak iterasi data yang dikirimkan oleh input user dimulai dari kolom yang paling akhir. Jika kolom tidak sesuai maka kembalikan kalimat "YOUR INPUT NOT MATCH THE COLUMN" ke dalam buffer untuk dilakukan pengiriman kembali kepada client.
}else{
struct table user;
fread(&user,sizeof(user),1,fp);
banyakKolom=user.jumlahkolom;
fclose(fp);
}
int iterasi = 0;
int iterasiData = 3;
struct table kolom;
while(jumlah > 3){
strcpy(kolom.data[iterasi], daftarQuery[iterasiData]);
printf("%s\n", kolom.data[iterasi]);
strcpy(kolom.type[iterasi], "string");
iterasiData++;
jumlah=jumlah-1;
iterasi++;
}
kolom.jumlahkolom = iterasi;
// printf("iterasi = %d\n", iterasi);
// printf("%d\n", user.jumlahkolom);
if(banyakKolom != kolom.jumlahkolom){
char peringatan[] = "YOUR INPUT NOT MATCH THE COLUMN";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
continue;
} Jika semua pencarian table dan pembuatan kolom sudah selesai, maka lakukan write ke dalam database sesuai dengan format yang sudah dibuat dan kembalikan kalimat "Data Has Been Inserted" ke dalam buffer untuk dilakukan pengiriman kembali kepada client. Dan dengan demikian fungsi insert oleh user sudah berhasil dilakukan.
// fwrite(&kolom,sizeof(kolom),1,fp);
printf("iterasi = %d\n", iterasi);
FILE *fp1;
printf("%s\n", buatTable);
fp1=fopen(buatTable,"ab");
fwrite(&kolom,sizeof(kolom),1,fp1);
fclose(fp1);
char peringatan[] = "Data Has Been Inserted";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));Apabila user memasukkan perintah "UPDATE" [nama_tabel] SET [nama_kolom]=[value]; maka akan dilakukan pemanggilan perintah snprintf dengan parameter buffer, sizeof buffer, "update:%s", dan copyinput dimana hasil inputan dari User berupa [nama_tabel] dan [nama_kolom]=[value] akan dilakukan penyimpanan kedalam buffer dengan size sebesar ukuran inputan. Kemudian Inputan ini akan dilakukan pengiriman ke Database dengan melakukan pemanggilan fungsi send dengan parameter clientSocket, buffer, strlen(buffer), 0 yang nantinya fungsi ini akan melakukan pengiriman hasil inputan dari user yang tersimpan di dalam buffer ke server untuk melakukan update data didalam Database.
else if(strcmp(perintah[0], "UPDATE")==0){
snprintf(buffer, sizeof buffer, "update:%s", copyinput);
send(clientSocket, buffer, strlen(buffer), 0);Kemudian di bagian server, pertama-tama akan dilakukan pencarian database, jika database belum dilakukan pemilihan, maka kembalikan kalimat "You're not selecting database yet" ke dalam buffer untuk dilakukan pengiriman kembali kepada client menggunakan fungsi snprint. Dan dengan demikian fungsi select oleh user sudah berhasil dilakukan.
else if(strcmp(perintah[0], "update")==0){
if(database_used[0] == '\0'){
strcpy(database_used, "You're not selecting database yet");
send(newSocket, database_used, strlen(database_used), 0);
bzero(buffer, sizeof(buffer));
continue;
}Kemudian, jika database sudah dilakukan pemilihan, maka ambil perintah yang tadi dikirimkan dan lakukan penyimpanan kedalam buffer. Lalu lakukan pencarian table didalam file yang ditunjuk sesuai dengan yang diminta oleh user pada perintah [nama_tabel]. Kemudian lakukan pencarian kolom sesuai dengan data yang dikirimkan oleh input user. Jika kolom tidak ditemukan maka kembalikan kalimat "Column Not Found" ke dalam buffer untuk dilakukan pengiriman kembali kepada client. Lalu jika kolom berhasil ditemukan maka, lakukan update inputan data yang dikirimkan oleh user ke dalam kolom yang diminta.
char daftarQuery[100][10000];
char copyPerintah[20000];
snprintf(copyPerintah, sizeof copyPerintah, "%s", perintah[1]);
// printf("%s\n", copyPerintah);
char *tokens;
tokens = strtok(copyPerintah, "\'(),= ");
int jumlah=0;
while( tokens != NULL ) {
strcpy(daftarQuery[jumlah], tokens);
printf("%s\n", daftarQuery[jumlah]);
jumlah++;
tokens = strtok(NULL, "\'(),= ");
}
printf("jumlah = %d\n", jumlah);
char buatTable[20000];
snprintf(buatTable, sizeof buatTable, "databases/%s/%s", database_used, daftarQuery[1]);
if(jumlah==5){
printf("buat table = %s, kolumn = %s", buatTable, daftarQuery[3]);
int index = findColumn(buatTable, daftarQuery[3]);
if(index == -1){
char peringatan[] = "Column Not Found";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
continue;
}
printf("index = %d\n", index);
updateColumn(buatTable, index, daftarQuery[4]);
}else if(jumlah==8){
printf("buat table = %s, kolumn = %s", buatTable, daftarQuery[3]);
int index = findColumn(buatTable, daftarQuery[3]);
if(index == -1){
char peringatan[] = "Column Not Found";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
continue;
}
printf("%s\n", daftarQuery[7]);
int indexGanti = findColumn(buatTable, daftarQuery[6]);
updateColumnWhere(buatTable, index, daftarQuery[4], indexGanti ,daftarQuery[7]);Kemudian jika data perintah yang dikirimkan ternyata tidak membawa inputan data apapun, maka kembalikan kalimat "Data Has Been Deleted" ke dalam buffer untuk dilakukan pengiriman kembali kepada client. Tetapi jika data perintah yang dikirimkan membawa inputan data maka kembalikan kalimat "Data Has Been Updated" ke dalam buffer untuk dilakukan pengiriman kembali kepada client. Dan dengan demikian fungsi update oleh user sudah berhasil dilakukan.
}else{
char peringatan[] = "Data Has Been Deleted";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
continue;
}
char peringatan[] = "Data Has Been Updated";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
}Apabila user memasukkan perintah "DELETE" [nama_tabel] maka akan dilakukan pemanggilan perintah snprintf dengan parameter buffer, sizeof buffer, "delete:%s", dan copyinput dimana hasil inputan dari User berupa [nama_tabel] akan dilakukan penyimpanan kedalam buffer dengan size sebesar ukuran inputan. Kemudian Inputan ini akan dilakukan pengiriman ke Database dengan melakukan pemanggilan fungsi send dengan parameter clientSocket, buffer, strlen(buffer), 0 yang nantinya fungsi ini akan melakukan pengiriman hasil inputan dari user yang tersimpan di dalam buffer ke server untuk melakukan delete data didalam Database.
else if(strcmp(perintah[0], "DELETE")==0){
snprintf(buffer, sizeof buffer, "delete:%s", copyinput);
send(clientSocket, buffer, strlen(buffer), 0);Kemudian di bagian server, pertama-tama akan dilakukan pencarian database, jika database belum dilakukan pemilihan, maka kembalikan kalimat "You're not selecting database yet" ke dalam buffer untuk dilakukan pengiriman kembali kepada client.
else if(strcmp(perintah[0], "delete")==0){
if(database_used[0] == '\0'){
strcpy(database_used, "You're not selecting database yet");
send(newSocket, database_used, strlen(database_used), 0);
bzero(buffer, sizeof(buffer));
continue;
}Kemudian, jika database sudah dilakukan pemilihan, maka ambil perintah yang tadi dikirimkan dan lakukan penyimpanan kedalam buffer. Lalu lakukan pencarian table didalam file yang ditunjuk sesuai dengan yang diminta oleh user pada perintah [nama_tabel]. Kemudian lakukan pencarian semua kolom sesuai dengan table yang dipilih. Jika kolom tidak ditemukan maka kembalikan kalimat "Column Not Found" ke dalam buffer untuk dilakukan pengiriman kembali kepada client.
char daftarQuery[100][10000];
char copyPerintah[20000];
snprintf(copyPerintah, sizeof copyPerintah, "%s", perintah[1]);
// printf("%s\n", copyPerintah);
char *tokens;
tokens = strtok(copyPerintah, "\'(),= ");
int jumlah=0;
while( tokens != NULL ) {
strcpy(daftarQuery[jumlah], tokens);
printf("%s\n", daftarQuery[jumlah]);
jumlah++;
tokens = strtok(NULL, "\'(),= ");
}
printf("jumlah = %d\n", jumlah);
char buatTable[20000];
snprintf(buatTable, sizeof buatTable, "databases/%s/%s", database_used, daftarQuery[2]);
if(jumlah==3){
deleteTable(buatTable, daftarQuery[2]);
}else if(jumlah==6){
int index = findColumn(buatTable, daftarQuery[4]);
if(index == -1){
char peringatan[] = "Column Not Found";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
continue;
}Lalu jika kolom berhasil ditemukan maka, lakukan penghapusan semua data yang ada di dalam table yang dilakukan pemilihan oleh user. Kemudian kembalikan kalimat "Data Has Been Deleted" ke dalam buffer untuk dilakukan pengiriman kembali kepada client. Dan dengan demikian fungsi delete oleh user sudah berhasil dilakukan.
printf("index = %d\n", index);
deleteTableWhere(buatTable, index, daftarQuery[4], daftarQuery[5]);
}else{
char peringatan[] = "Input Salah";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
continue;
}
char peringatan[] = "Data Has Been Deleted";
send(newSocket, peringatan, strlen(peringatan), 0);
bzero(buffer, sizeof(buffer));
}Apabila user memasukkan perintah "SELECT" [nama_kolom, … | *] FROM [nama_tabel]; maka akan dilakukan pemanggilan perintah snprintf dengan parameter buffer, sizeof buffer, "select:%s", dan copyinput dimana hasil inputan dari User berupa [nama_kolom, … | *] dan [nama_tabel] akan dilakukan penyimpanan kedalam buffer dengan size sebesar ukuran inputan. Kemudian Inputan ini akan dilakukan pengiriman ke Database dengan melakukan pemanggilan fungsi send dengan parameter clientSocket, buffer, strlen(buffer), 0 yang nantinya fungsi ini akan melakukan pengiriman hasil inputan dari user yang tersimpan di dalam buffer ke server untuk melakukan select data didalam Database.
else if(strcmp(perintah[0], "SELECT")==0){
snprintf(buffer, sizeof buffer, "select:%s", copyinput);
send(clientSocket, buffer, strlen(buffer), 0);Kemudian di bagian server, pertama-tama akan dilakukan pencarian database, jika database belum dilakukan pemilihan, maka kembalikan kalimat "You're not selecting database yet" ke dalam buffer untuk dilakukan pengiriman kembali kepada client.
else if(strcmp(perintah[0], "select")==0){
if(database_used[0] == '\0'){
strcpy(database_used, "You're not selecting database yet");
send(newSocket, database_used, strlen(database_used), 0);
bzero(buffer, sizeof(buffer));
continue;
}Lalu kemudian kita lakukan pencarian table dan juga kolom sesuai dengan perintah yang diminta dari inputan user. Setelah kita berhasil menemukan table dan kolom yang sesuai, maka akan kita lakukan pengambilan data tersebut dan kemudian kita lakukan pengembalian data tersebut kepada client
char daftarQuery[100][10000];
char copyPerintah[20000];
snprintf(copyPerintah, sizeof copyPerintah, "%s", perintah[1]);
// printf("%s\n", copyPerintah);
char *tokens;
tokens = strtok(copyPerintah, "\'(),= ");
int jumlah=0;
while( tokens != NULL ) {
strcpy(daftarQuery[jumlah], tokens);
printf("%s\n", daftarQuery[jumlah]);
jumlah++;
tokens = strtok(NULL, "\'(),= ");
}
printf("ABC\n");
if(jumlah == 4){
char buatTable[20000];
snprintf(buatTable, sizeof buatTable, "databases/%s/%s", database_used, daftarQuery[3]);
printf("buat table = %s", buatTable);
char perintahKolom[1000];
printf("masuk 4\n");
if(strcmp(daftarQuery[1], "*")==0){
// showTableAll(buatTable, "ALL");
FILE *fp, *fp1;
struct table user;
int id,found=0;
fp=fopen(buatTable,"rb");
char buffers[40000];
char sendDatabase[40000];
bzero(buffer, sizeof(buffer));
bzero(sendDatabase, sizeof(sendDatabase));
while(1){
char enter[] = "\n";
// bzero(enter, sizeof(enter));
fread(&user,sizeof(user),1,fp);
snprintf(buffers, sizeof buffers, "\n");
// send(newSocket, enter, strlen(enter), 0);
if(feof(fp)){
break;
}
for(int i=0; i< user.jumlahkolom; i++){
char padding[20000];
snprintf(padding, sizeof padding, "%s\t",user.data[i]);
strcat(buffers, padding);
// send(newSocket, buffer, strlen(buffer), 0);
// bzero(buffer, sizeof(buffer));
}
// printf("%s", buffers);
strcat(sendDatabase, buffers);
}
// printf("ini send fix\n%s\n", sendDatabase);
send(newSocket, sendDatabase, strlen(sendDatabase), 0);
bzero(sendDatabase, sizeof(sendDatabase));
bzero(buffer, sizeof(buffer));
fclose(fp);
}else{
// showTable(buatTable, perintah[1]);
int index = findColumn(buatTable, daftarQuery[1]);
printf("%d\n", index);
FILE *fp, *fp1;
struct table user;
int id,found=0;
fp=fopen(buatTable,"rb");
char buffers[40000];
char sendDatabase[40000];
bzero(buffer, sizeof(buffer));
bzero(sendDatabase, sizeof(sendDatabase));
while(1){
char enter[] = "\n";
// bzero(enter, sizeof(enter));
fread(&user,sizeof(user),1,fp);
snprintf(buffers, sizeof buffers, "\n");
// send(newSocket, enter, strlen(enter), 0);
if(feof(fp)){
break;
}
for(int i=0; i< user.jumlahkolom; i++){
if(i == index){
char padding[20000];
snprintf(padding, sizeof padding, "%s\t",user.data[i]);
strcat(buffers, padding);
}
// send(newSocket, buffer, strlen(buffer), 0);
// bzero(buffer, sizeof(buffer));
}
// printf("%s", buffers);
strcat(sendDatabase, buffers);
}
printf("ini send fix\n%s\n", sendDatabase);
fclose(fp);
send(newSocket, sendDatabase, strlen(sendDatabase), 0);
bzero(sendDatabase, sizeof(sendDatabase));
bzero(buffer, sizeof(buffer));
}
}else if(jumlah == 7 && strcmp(daftarQuery[4], "WHERE")==0){
char buatTable[20000];
snprintf(buatTable, sizeof buatTable, "databases/%s/%s", database_used, daftarQuery[3]);
printf("buat table = %s", buatTable);
char perintahKolom[1000];
printf("masuk 4\n");
if(strcmp(daftarQuery[1], "*")==0){
// showTableAll(buatTable, "ALL");
FILE *fp, *fp1;
struct table user;
int id,found=0;
fp=fopen(buatTable,"rb");
char buffers[40000];
char sendDatabase[40000];
int index = findColumn(buatTable, daftarQuery[5]);
printf("%d\n", index);
bzero(buffer, sizeof(buffer));
bzero(sendDatabase, sizeof(sendDatabase));
while(1){
char enter[] = "\n";
// bzero(enter, sizeof(enter));
fread(&user,sizeof(user),1,fp);
snprintf(buffers, sizeof buffers, "\n");
// send(newSocket, enter, strlen(enter), 0);
if(feof(fp)){
break;
}
for(int i=0; i< user.jumlahkolom; i++){
if(strcmp(user.data[index], daftarQuery[6])==0){
char padding[20000];
snprintf(padding, sizeof padding, "%s\t",user.data[i]);
strcat(buffers, padding);
}
// send(newSocket, buffer, strlen(buffer), 0);
// bzero(buffer, sizeof(buffer));
}
// printf("%s", buffers);
strcat(sendDatabase, buffers);
}
// printf("ini send fix\n%s\n", sendDatabase);
send(newSocket, sendDatabase, strlen(sendDatabase), 0);
bzero(sendDatabase, sizeof(sendDatabase));
bzero(buffer, sizeof(buffer));
fclose(fp);
}else{
// showTable(buatTable, perintah[1]);
int index = findColumn(buatTable, daftarQuery[1]);
printf("%d\n", index);
FILE *fp, *fp1;
struct table user;
int id,found=0;
int indexGanti = findColumn(buatTable, daftarQuery[5]);
fp=fopen(buatTable,"rb");
char buffers[40000];
char sendDatabase[40000];
bzero(buffer, sizeof(buffer));
bzero(sendDatabase, sizeof(sendDatabase));
while(1){
char enter[] = "\n";
// bzero(enter, sizeof(enter));
fread(&user,sizeof(user),1,fp);
snprintf(buffers, sizeof buffers, "\n");
// send(newSocket, enter, strlen(enter), 0);
if(feof(fp)){
break;
}
for(int i=0; i< user.jumlahkolom; i++){
if(i == index && (strcmp(user.data[indexGanti], daftarQuery[6])==0 || strcmp(user.data[i],daftarQuery[5])==0)){
char padding[20000];
snprintf(padding, sizeof padding, "%s\t",user.data[i]);
strcat(buffers, padding);
}
// send(newSocket, buffer, strlen(buffer), 0);
// bzero(buffer, sizeof(buffer));
}
// printf("%s", buffers);
strcat(sendDatabase, buffers);
}
printf("ini send fix\n%s\n", sendDatabase);
fclose(fp);
send(newSocket, sendDatabase, strlen(sendDatabase), 0);
bzero(sendDatabase, sizeof(sendDatabase));
bzero(buffer, sizeof(buffer));
}
}else{
printf("ini query 3 %s", daftarQuery[jumlah-3]);
if(strcmp(daftarQuery[jumlah-3], "WHERE")!= 0){
char buatTable[20000];
snprintf(buatTable, sizeof buatTable, "databases/%s/%s", database_used, daftarQuery[jumlah-1]);
printf("buat table = %s", buatTable);
printf("tanpa where");
int index[100];
int iterasi=0;
for(int i=1; i<jumlah-2; i++){
index[iterasi] = findColumn(buatTable, daftarQuery[i]);
printf("%d\n", index[iterasi]);
iterasi++;
}
}else if(strcmp(daftarQuery[jumlah-3], "WHERE")== 0){
printf("dengan where");
}
}
}Setiap perintah yang dimasukkan user akan dicek apakah valid atau tidak. Hal tersebut kami lakukan dengan memanggil fungsi dibawah ini
if(wrongCommand != 1){
char namaSender[10000];
if(id_user == 0){
strcpy(namaSender, "root");
}else{
strcpy(namaSender, argv[2]);
}
writelog(copyinput, namaSender);
}jika perintah yang dimasukkan user valid dan bukan perintah yang salah, maka kita cek siapa yang menjalankan perintah dengan menggunakan UID. jika 0 maka root, selain itu ambil nama user dari argv[2]. setelah itu panggil fungsi writelog. fungsi writelog adalah sebagai berikut
void writelog(char *perintah, char *nama){
time_t rawtime;
struct tm *timeinfo;
time(&rawtime);
timeinfo = localtime(&rawtime);
char infoWriteLog[1000];
FILE *file;
char lokasi[10000];
snprintf(lokasi, sizeof lokasi, "../database/log/log%s.log", nama);
file = fopen(lokasi, "ab");
sprintf(infoWriteLog, "%d-%.2d-%.2d %.2d:%.2d:%.2d:%s:%s;\n",timeinfo->tm_year + 1900, timeinfo->tm_mon + 1, timeinfo->tm_mday, timeinfo->tm_hour, timeinfo->tm_min, timeinfo->tm_sec, nama, perintah);
// sprintf(infoWriteLog, "%.2d%.2d%d-%.2d:%.2d:%.2d::%s::%s\n", timeinfo->tm_mday, timeinfo->tm_mon + 1, timeinfo->tm_year + 1900, timeinfo->tm_hour, timeinfo->tm_min, timeinfo->tm_sec, nama, filepath);
fputs(infoWriteLog, file);
fclose(file);
return;
}dari kode diatas dapat dilihat bahwa kami menyimpan log nya itu untuk setiap user yang menjalankannya. hal yang kami write ke dalam file itu sesuai dengan format yang sudah diatur atau di tentukan pada ketentuan FP.
Ketika user menjalankan perintah tersebut maka kami akan memasukkan log yang dipunyai oleh user, kedalam file yang telah ditentukan oleh user, berikut adalah kode yang kami gunakan.
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/stat.h>
#include <dirent.h>
#include <ctype.h>
#include <time.h>
#define PORT 4443
struct allowed{
char name[10000];
char password[10000];
};
int cekAllowed(char *username, char *password){
FILE *fp;
struct allowed user;
int id,found=0;
fp=fopen("../database/databases/user.dat","rb");
while(1){
fread(&user,sizeof(user),1,fp);
// printf("%s %s\n", user.name, username);
// printf("%s %s\n", user.password, password);
// printf("masuk");
if(strcmp(user.name, username)==0){
// printf("MASUK!");
if(strcmp(user.password, password)==0){
found=1;
}
}
if(feof(fp)){
break;
}
}
fclose(fp);
// printf("found %d: \n",found);
if(found==0){
printf("You're Not Allowed\n");
return 0;
}else{
return 1;
}
}
int main(int argc, char *argv[]){
// printf("%s\n", argv[0]);
int allowed=0;
int id_user = geteuid();
char database_used[1000];
if(geteuid() == 0){
// printf("I AM ROOT");
allowed=1;
}else{
int id = geteuid();
// printf("ID kamu : %d", id);
allowed = cekAllowed(argv[2],argv[4]);
}
if(allowed==0){
return 0;
}
FILE *fp;
char lokasi[10000];
snprintf(lokasi, sizeof lokasi, "../database/log/log%s.log", argv[2]);
fp = fopen(lokasi, "rb");
char buffer[20000];
char perintah[100][10000];
int found=0;
while (fgets(buffer, 20000 , fp)){
char *token;
char buffercopy[20000];
snprintf(buffercopy, sizeof buffercopy, "%s", buffer);
token = strtok(buffercopy, ":");
int i=0;
while ( token != NULL){
strcpy(perintah[i], token);
// printf("%s\n", perintah[i]);
i++;
token = strtok(NULL, ":");
}
// printf("%s\n", perintah[4]);
char *b = strstr(perintah[4], "USE");
if(b != NULL){
char *tokens;
char perintahCopy[20000];
strcpy(perintahCopy, perintah[4]);
tokens = strtok(perintahCopy, "; ");
int j=0;
char perintahUse[100][10000];
while ( tokens != NULL){
strcpy(perintahUse[j], tokens);
// printf("%s\n", perintahUse[j]);
j++;
tokens = strtok(NULL, "; ");
}
char databaseTarget[20000];
// sprintf(databaseTarget, "%s;", argv[5]);
// printf("%s\n", perintahUse[1]);
// printf("%s\n", databaseTarget);
if(strcmp(perintahUse[1], argv[5])==0){
found = 1;
}else{
found = 0;
}
}
// printf("%d\n", found);
if(found == 1){
printf("%s", buffer);
}
// printf("%s", buffer);
}
fclose(fp);
}Hal yang kami lakukan adalah mengecek apakah user boleh menggunakan program ini atau tidak. Menggunakan cara yang sama dengan program yang sebelumnya dimana untuk setiap user akan dicek apakah allowed atau tidak(sama dengan yang sudah dijelaskan sebelumnya). Setelah itu kita buka file log yang dipunyai user. Lalu baca log tersebut, ketika user menggunakan database yang sama dengan yang diinputkan user, maka salin semua perintah yang dijalankan user sampai mengganti current directory kedalam file yang telah dibuat atau ditentukan oleh user.
Untuk error handling sudah dijelaskan bersaman dengan dijalankannya perintah lain
- Waktu yang sedikit dan banyak nya tugas membuat tidak bisa maksimal dalam mengerjakannya.