hlib/example.cpp at master · tmnyoni/hlib · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
#include <iostream>

#include "hlib.h"
#pragma comment(lib, "hlib.lib")

using namespace hlib;
hbase db;

//printing out the table.
void out_put(std::string table_name, std::string& error) {
	std::vector<hbase::row_> rows_;
	if (!db.get_records(rows_, table_name, error))
		std::cout << error << " occured!" << std::endl;
	else
		for (auto headings : rows_) {
			for (const auto heading : headings.fields) {
				std::cout << heading.name << "\t|";
			}
			std::cout << std::endl;
			break;
		}

	for (auto row : rows_) {
		for (auto field : row.fields) {
			std::cout << field.item + "\t";
		}
		std::cout << std::endl;
	}
}

int main() {
	std::string error;

  //printing out the error.
	auto on_error = [](std::string& error) { std::cout << error << "occured!" << std::endl; };

	hbase::database_file_ file = { "test.db", "pass" };
	hbase::tables_ tables;

  //creating the tables.
	hbase::table_ users;
	users.name = "sample_table";
	users.columns = {
		{"ID", hbase::column_type_::text_, hbase::constraint_::not_null},
		{"Username", hbase::column_type_::text_, hbase::constraint_::not_null},
		{"User_type", hbase::column_type_::text_, hbase::constraint_::null}
	};
	users.primary_key = "ID";
	tables.add(users);

  //connecting to the database.
	if (!db.connect(file, tables, error)) {
		on_error(error);
		return 0;
	}
	else
		std::cout << "database connected successfully!" << std::endl;

	std::vector<hbase::row_> rows;
	hbase::row_ row0 = {
		{
			{ {"ID"}, {"n145"} },
			{ {"Username"}, {"User3"} },
			{ {"User_type"}, {"guest"} }
		}
	};

	hbase::row_ row1 = {
		{
			{ {"ID"}, {"3453hk"} },
			{ {"Username"}, {"User7"} },
			{ {"User_type"}, {"Guest"} }
		}
	};

	rows.push_back(row0);
	rows.push_back(row1);

  //inserting data into the table.
	for (auto row : rows)
		if (!db.insert_row(row, users.name, error))
			std::cout << error << " occurred!" << std::endl;
		else
			std::cout << "record saved!" << std::endl;

	out_put(users.name, error);

	size_t num;
	if (db.count_records(users.name, num, error))
		std::cout << num << " records" << std::endl;

  //deleting the table row.
	hbase::field_ field = { "Username", "User7" };
	if (!db.delete_row(field, users.name, error))
		std::cout << error << " occurred!" << std::endl;
	else
		std::cout << "deleted successfully" << std::endl;

	hbase::row_ update = {
		{
			{ {"ID"}, {"n00r"} },
			{ {"Username"}, {"Hkay"} },
			{ {"User_type"}, {"Guest"} }
		}
	};

	out_put(users.name, error);
	if (!db.update_record(row0, update, users.name, error))
		std::cout << error << " occurred!" << std::endl;
	else
		std::cout << "updated successfully!" << std::endl;

	out_put(users.name, error);

	return 0;
}