Merge pull request #52 from microsoft/saumya/connectionclassc++

FEAT: adding connection class structure in C++

Author: gargsaumya

mssql_python/pybind/connection/connection.cpp

@@ -0,0 +1,54 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT license.
+
+// INFO|TODO - Note that is file is Windows specific right now. Making it arch agnostic will be
+//             taken up in future
+
+#include "connection.h"
+#include <iostream>
+
+//-------------------------------------------------------------------------------------------------
+// Implements the Connection class declared in connection.h.
+// This class wraps low-level ODBC operations like connect/disconnect,
+// transaction control, and autocommit configuration.
+//-------------------------------------------------------------------------------------------------
+Connection::Connection(const std::wstring& conn_str) : _conn_str(conn_str) {}
+
+Connection::~Connection() {
+    LOG("Connection destructor called");
+    close();    // Ensure the connection is closed when the object is destroyed.
+}
+
+SQLRETURN Connection::connect() {
+    LOG("Connecting to MSSQL");
+    // to be added 
+}
+
+SQLRETURN Connection::close() {
+    LOG("Disconnect from MSSQL");
+    // to be added
+}
+
+SQLRETURN Connection::commit() {
+    LOG("Committing transaction");
+    // to be added
+}
+
+SQLRETURN Connection::rollback() {
+    LOG("Rolling back transaction");
+    // to be added
+}
+
+SQLRETURN Connection::end_transaction(SQLSMALLINT completion_type) {
+    // to be added
+}
+
+SQLRETURN Connection::set_autocommit(bool enable) {
+    LOG("Setting autocommit mode");
+    // to be added
+}
+
+bool Connection::get_autocommit() const {
+    LOG("Getting autocommit mode");
+    // to be added
+}

mssql_python/pybind/connection/connection.h

@@ -0,0 +1,51 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT license.
+
+// INFO|TODO - Note that is file is Windows specific right now. Making it arch agnostic will be
+//             taken up in future.
+
+#ifndef CONNECTION_H
+#define CONNECTION_H
+
+#include "ddbc_bindings.h"
+
+// Represents a single ODBC database connection.
+// Manages its own environment and connection handles.
+// Note: This class does NOT implement pooling logic directly.
+
+class Connection {
+public:
+    Connection(const std::wstring& conn_str);
+    ~Connection();
+
+    // Establish the connection using the stored connection string.
+    SQLRETURN connect();
+
+    // Close the connection and free resources.
+    SQLRETURN close();
+
+    // Commit the current transaction.
+    SQLRETURN commit();
+
+    // Rollback the current transaction.
+    SQLRETURN rollback();
+
+    // End the transaction with the specified completion type.
+    SQLRETURN end_transaction(SQLSMALLINT completion_type);
+
+    // Enable or disable autocommit mode.
+    SQLRETURN set_autocommit(bool value);
+
+    //  Check whether autocommit is enabled.
+    bool get_autocommit() const;
+
+private:
+
+    std::wstring _conn_str;     // Connection string
+    SqlHandlePtr _env_handle;   // Environment handle
+    SqlHandlePtr _dbc_handle;   // Connection handle
+
+    bool _autocommit = false;
+    std::shared_ptr<Connection> _conn; 
+};
+#endif // CONNECTION_H