ODBCとは？初心者でもわかる基礎知識と活用法

sudo apt-get install unixodbc unixodbc-dev

isql -v データソース名 ユーザー名 パスワード

#include <stdio.h>
#include <sql.h>
#include <sqlext.h>

int main() {
    SQLHENV env;
    SQLHDBC dbc;
    SQLHSTMT stmt;
    SQLRETURN ret;

    // 環境ハンドルの割り当て
    SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &env);
    SQLSetEnvAttr(env, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0);

    // 接続ハンドルの割り当て
    SQLAllocHandle(SQL_HANDLE_DBC, env, &dbc);

    // データソースへの接続
    ret = SQLDriverConnect(dbc, NULL, (SQLCHAR*)"DSN=MyDataSource;UID=username;PWD=password", SQL_NTS, NULL, 0, NULL, SQL_DRIVER_COMPLETE);

    if (SQL_SUCCEEDED(ret)) {
        printf("接続成功\n");
        // ここでSQLクエリを実行
        SQLDisconnect(dbc);
    } else {
        printf("接続失敗\n");
    }

    // リソースの解放
    SQLFreeHandle(SQL_HANDLE_DBC, dbc);
    SQLFreeHandle(SQL_HANDLE_ENV, env);

    return 0;
}

import pyodbc

# 接続文字列
conn_str = (
    r'DRIVER={SQL Server};'
    r'SERVER=myserver;'
    r'DATABASE=mydatabase;'
    r'UID=myusername;'
    r'PWD=mypassword'
)

# 接続の確立
conn = pyodbc.connect(conn_str)

# カーソルの作成
cursor = conn.cursor()

# SQLクエリの実行
cursor.execute("SELECT * FROM mytable")

# 結果の取得
rows = cursor.fetchall()

# 結果の表示
for row in rows:
    print(row)

# 接続のクローズ
conn.close()

import java.sql.*;

public class ODBCExample {
    public static void main(String[] args) {
        String url = "jdbc:odbc:MyDataSource";
        String user = "username";
        String password = "password";

        try {
            // JDBCドライバーの登録
            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");

            // 接続の確立
            Connection conn = DriverManager.getConnection(url, user, password);

            // ステートメントの作成
            Statement stmt = conn.createStatement();

            // SQLクエリの実行
            ResultSet rs = stmt.executeQuery("SELECT * FROM mytable");

            // 結果の処理
            while (rs.next()) {
                System.out.println(rs.getString("column_name"));
            }

            // リソースのクローズ
            rs.close();
            stmt.close();
            conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

String url = "jdbc:mysql://localhost:3306/mydb";
String user = "username";
String password = "password";

try (Connection conn = DriverManager.getConnection(url, user, password);
     Statement stmt = conn.createStatement();
     ResultSet rs = stmt.executeQuery("SELECT * FROM mytable")) {
    while (rs.next()) {
        System.out.println(rs.getString("column_name"));
    }
} catch (SQLException e) {
    e.printStackTrace();
}

string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;";

using (SqlConnection connection = new SqlConnection(connectionString))
{
    connection.Open();
    string sql = "SELECT * FROM mytable";
    using (SqlCommand command = new SqlCommand(sql, connection))
    {
        using (SqlDataReader reader = command.ExecuteReader())
        {
            while (reader.Read())
            {
                Console.WriteLine(reader["column_name"].ToString());
            }
        }
    }
}

from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

Base = declarative_base()

class User(Base):
    __tablename__ = 'users'
    id = Column(Integer, primary_key=True)
    name = Column(String)
    age = Column(Integer)

engine = create_engine('sqlite:///example.db')
Session = sessionmaker(bind=engine)
session = Session()

# データの挿入
new_user = User(name='John Doe', age=30)
session.add(new_user)
session.commit()

# データの取得
users = session.query(User).all()
for user in users:
    print(f"Name: {user.name}, Age: {user.age}")