1 files changed, 239 insertions, 0 deletions
diff --git a/v_windows/v/vlib/mysql/mysql.v b/v_windows/v/vlib/mysql/mysql.v
new file mode 100644
index 0000000..90e7008
--- /dev/null
+++ b/v_windows/v/vlib/mysql/mysql.v
@@ -0,0 +1,239 @@
+module mysql
+
+// Values for the capabilities flag bitmask used by the MySQL protocol.
+// See more on https://dev.mysql.com/doc/dev/mysql-server/latest/group__group__cs__capabilities__flags.html#details
+pub enum ConnectionFlag {
+	// CAN_HANDLE_EXPIRED_PASSWORDS       = C.CAN_HANDLE_EXPIRED_PASSWORDS
+	client_compress = C.CLIENT_COMPRESS
+	client_found_rows = C.CLIENT_FOUND_ROWS
+	client_ignore_sigpipe = C.CLIENT_IGNORE_SIGPIPE
+	client_ignore_space = C.CLIENT_IGNORE_SPACE
+	client_interactive = C.CLIENT_INTERACTIVE
+	client_local_files = C.CLIENT_LOCAL_FILES
+	client_multi_results = C.CLIENT_MULTI_RESULTS
+	client_multi_statements = C.CLIENT_MULTI_STATEMENTS
+	client_no_schema = C.CLIENT_NO_SCHEMA
+	client_odbc = C.CLIENT_ODBC
+	// client_optional_resultset_metadata = C.CLIENT_OPTIONAL_RESULTSET_METADATA
+	client_ssl = C.CLIENT_SSL
+	client_remember_options = C.CLIENT_REMEMBER_OPTIONS
+}
+
+struct SQLError {
+	msg  string
+	code int
+}
+
+// TODO: Documentation
+pub struct Connection {
+mut:
+	conn &C.MYSQL = C.mysql_init(0)
+pub mut:
+	host     string = '127.0.0.1'
+	port     u32    = 3306
+	username string
+	password string
+	dbname   string
+	flag     ConnectionFlag
+}
+
+// connect - create a new connection to the MySQL server.
+pub fn (mut conn Connection) connect() ?bool {
+	instance := C.mysql_init(conn.conn)
+	conn.conn = C.mysql_real_connect(instance, conn.host.str, conn.username.str, conn.password.str,
+		conn.dbname.str, conn.port, 0, conn.flag)
+	if isnil(conn.conn) {
+		return error_with_code(get_error_msg(instance), get_errno(instance))
+	}
+	return true
+}
+
+// query - make an SQL query and receive the results.
+// `query()` cannot be used for statements that contain binary data;
+// Use `real_query()` instead.
+pub fn (conn Connection) query(q string) ?Result {
+	if C.mysql_query(conn.conn, q.str) != 0 {
+		return error_with_code(get_error_msg(conn.conn), get_errno(conn.conn))
+	}
+	res := C.mysql_store_result(conn.conn)
+	return Result{res}
+}
+
+// real_query - make an SQL query and receive the results.
+// `real_query()` can be used for statements containing binary data.
+// (Binary data may contain the `\0` character, which `query()`
+// interprets as the end of the statement string). In addition,
+// `real_query()` is faster than `query()`.
+pub fn (mut conn Connection) real_query(q string) ?Result {
+	if C.mysql_real_query(conn.conn, q.str, q.len) != 0 {
+		return error_with_code(get_error_msg(conn.conn), get_errno(conn.conn))
+	}
+	res := C.mysql_store_result(conn.conn)
+	return Result{res}
+}
+
+// select_db - change the default database for database queries.
+pub fn (mut conn Connection) select_db(dbname string) ?bool {
+	if C.mysql_select_db(conn.conn, dbname.str) != 0 {
+		return error_with_code(get_error_msg(conn.conn), get_errno(conn.conn))
+	}
+	return true
+}
+
+// change_user - change the mysql user for the connection.
+// Passing an empty string for the `dbname` parameter, resultsg in only changing
+// the user and not changing the default database for the connection.
+pub fn (mut conn Connection) change_user(username string, password string, dbname string) ?bool {
+	mut ret := true
+	if dbname != '' {
+		ret = C.mysql_change_user(conn.conn, username.str, password.str, dbname.str)
+	} else {
+		ret = C.mysql_change_user(conn.conn, username.str, password.str, 0)
+	}
+	if !ret {
+		return error_with_code(get_error_msg(conn.conn), get_errno(conn.conn))
+	}
+	return ret
+}
+
+// affected_rows - return the number of rows changed/deleted/inserted
+// by the last `UPDATE`, `DELETE`, or `INSERT` query.
+pub fn (conn &Connection) affected_rows() u64 {
+	return C.mysql_affected_rows(conn.conn)
+}
+
+// autocommit - turns on/off the auto-committing mode for the connection.
+// When it is on, then each query is commited right away.
+pub fn (mut conn Connection) autocommit(mode bool) {
+	C.mysql_autocommit(conn.conn, mode)
+}
+
+// tables - returns a list of the names of the tables in the current database,
+// that match the simple regular expression specified by the `wildcard` parameter.
+// The `wildcard` parameter may contain the wildcard characters `%` or `_`.
+// If an empty string is passed, it will return all tables.
+// Calling `tables()` is similar to executing query `SHOW TABLES [LIKE wildcard]`.
+pub fn (conn &Connection) tables(wildcard string) ?[]string {
+	cres := C.mysql_list_tables(conn.conn, wildcard.str)
+	if isnil(cres) {
+		return error_with_code(get_error_msg(conn.conn), get_errno(conn.conn))
+	}
+	res := Result{cres}
+	mut tables := []string{}
+	for row in res.rows() {
+		tables << row.vals[0]
+	}
+	return tables
+}
+
+// escape_string - creates a legal SQL string for use in an SQL statement.
+// The `s` argument is encoded to produce an escaped SQL string,
+// taking into account the current character set of the connection.
+pub fn (conn &Connection) escape_string(s string) string {
+	unsafe {
+		to := malloc_noscan(2 * s.len + 1)
+		C.mysql_real_escape_string(conn.conn, to, s.str, s.len)
+		return to.vstring()
+	}
+}
+
+// set_option - sets extra connect options that affect the behavior of
+// a connection. This function may be called multiple times to set several
+// options. To retrieve the current values for an option, use `get_option()`.
+pub fn (mut conn Connection) set_option(option_type int, val voidptr) {
+	C.mysql_options(conn.conn, option_type, val)
+}
+
+// get_option - return the value of an option, settable by `set_option`.
+// https://dev.mysql.com/doc/c-api/5.7/en/mysql-get-option.html
+pub fn (conn &Connection) get_option(option_type int) ?voidptr {
+	ret := voidptr(0)
+	if C.mysql_get_option(conn.conn, option_type, &ret) != 0 {
+		return error_with_code(get_error_msg(conn.conn), get_errno(conn.conn))
+	}
+	return ret
+}
+
+// refresh - flush the tables or caches, or resets replication server
+// information. The connected user must have the `RELOAD` privilege.
+pub fn (mut conn Connection) refresh(options u32) ?bool {
+	if C.mysql_refresh(conn.conn, options) != 0 {
+		return error_with_code(get_error_msg(conn.conn), get_errno(conn.conn))
+	}
+	return true
+}
+
+// reset - resets the connection, and clear the session state.
+pub fn (mut conn Connection) reset() ?bool {
+	if C.mysql_reset_connection(conn.conn) != 0 {
+		return error_with_code(get_error_msg(conn.conn), get_errno(conn.conn))
+	}
+	return true
+}
+
+// ping - pings a server connection, or tries to reconnect if the connection
+// has gone down.
+pub fn (mut conn Connection) ping() ?bool {
+	if C.mysql_ping(conn.conn) != 0 {
+		return error_with_code(get_error_msg(conn.conn), get_errno(conn.conn))
+	}
+	return true
+}
+
+// close - closes the connection.
+pub fn (mut conn Connection) close() {
+	C.mysql_close(conn.conn)
+}
+
+// info - returns information about the most recently executed query.
+// See more on https://dev.mysql.com/doc/c-api/8.0/en/mysql-info.html
+pub fn (conn &Connection) info() string {
+	return resolve_nil_str(C.mysql_info(conn.conn))
+}
+
+// get_host_info - returns a string describing the type of connection in use,
+// including the server host name.
+pub fn (conn &Connection) get_host_info() string {
+	return unsafe { C.mysql_get_host_info(conn.conn).vstring() }
+}
+
+// get_server_info - returns a string representing the MySQL server version.
+// For example, `8.0.24`.
+pub fn (conn &Connection) get_server_info() string {
+	return unsafe { C.mysql_get_server_info(conn.conn).vstring() }
+}
+
+// get_server_version - returns an integer, representing the MySQL server
+// version. The value has the format `XYYZZ` where `X` is the major version,
+// `YY` is the release level (or minor version), and `ZZ` is the sub-version
+// within the release level. For example, `8.0.24` is returned as `80024`.
+pub fn (conn &Connection) get_server_version() u64 {
+	return C.mysql_get_server_version(conn.conn)
+}
+
+// dump_debug_info - instructs the server to write debugging information
+// to the error log. The connected user must have the `SUPER` privilege.
+pub fn (mut conn Connection) dump_debug_info() ?bool {
+	if C.mysql_dump_debug_info(conn.conn) != 0 {
+		return error_with_code(get_error_msg(conn.conn), get_errno(conn.conn))
+	}
+	return true
+}
+
+// get_client_info - returns client version information as a string.
+pub fn get_client_info() string {
+	return unsafe { C.mysql_get_client_info().vstring() }
+}
+
+// get_client_version - returns the client version information as an integer.
+pub fn get_client_version() u64 {
+	return C.mysql_get_client_version()
+}
+
+// debug - does a `DBUG_PUSH` with the given string.
+// `debug()` uses the Fred Fish debug library.
+// To use this function, you must compile the client library to support debugging.
+// See https://dev.mysql.com/doc/c-api/8.0/en/mysql-debug.html
+pub fn debug(debug string) {
+	C.mysql_debug(debug.str)
+}