SAP Hana 数据库编程接口 - ODBC

时间:2022-07-13 16:51:48

对于 Windows 平台,SAP 提供了三种编程接口:ODBC, MDX (用于 Excel) 和 ADO.NET Provider。但在我的 Windows 系统上测试,ADO.NET Provider 连接 Hana DB 出错,估计是版本问题,只好放弃。ODBC 连接方式使用 C# 和 VBA 测试都能成功 CRUD。以下介绍 ODBC。

ODBC 驱动

安装 SAP Client 就会自动安装 ODBC 驱动。使用 odbcad32.exe 可以查看数据库驱动:

SAP Hana 数据库编程接口 - ODBC

ODBC 驱动分为 64 位和 32 位。如果 32 位,驱动名称为 HDBODBC32。注意 Windows 有两个 odbcad32.exe 程序 (32 位 和 64 位)。在 Windows 10 下,Windows\system32 文件夹下是 64 位设置程序,Windows\SysWOW64 文件夹下是 32 位设置程序。

还是用前面介绍的 emp_master 表测试 CRUD。测试环境:Visual Stuido 2015。

实体类

实体类在文件 EmpMasterEntity.cs 中。

namespace HanaTest
{
public class EmpMasterEntity
{
public String EmpID { get; set; }
public String Gender { get; set; }
public int Age { get; set; }
public String EMail { get; set; }
public String PhoneNr { get; set; }
public String Education { get; set; }
public String MaritalStat { get; set; }
public int NrOfChildren { get; set; }
}
}

CRUD

文件放在 EmpMasterDAO.cs 文件中。

using System;
using System.Data;
using System.Data.Odbc;

namespace HanaTest
{
public class EmpMasterDAO
{
public EmpMasterDAO() { }

public OdbcConnection getConnection() {
String connStr = "Driver={HDBODBC};ServerNode=192.168.1.100:30015;uid=STONE;pwd=haapwd;";
var conn = new OdbcConnection(connStr);
return conn;
}

public DataTable listAll() {
OdbcConnection conn = this.getConnection();
String sql = "SELECT * FROM STONE.EMP_MASTER";
conn.Open();

OdbcCommand selectCmd = new OdbcCommand(sql, conn);
var adapter = new OdbcDataAdapter(selectCmd);

DataTable employeeTable = new DataTable("employees");
adapter.Fill(employeeTable);

conn.Close();

return employeeTable;
}

public int insert(EmpMasterEntity employee) {

OdbcConnection conn = this.getConnection();
String sql = "INSERT INTO STONE.EMP_MASTER VALUES(?,?,?,?,?,?,?,?)";

OdbcCommand cmd = new OdbcCommand(sql, conn);

// parameters
cmd.Parameters.AddWithValue("@emp_id", employee.EmpID);
cmd.Parameters.AddWithValue("@gender", employee.Gender);
cmd.Parameters.AddWithValue("@age", employee.Age);
cmd.Parameters.AddWithValue("@email", employee.EMail);
cmd.Parameters.AddWithValue("@phoneNr", employee.PhoneNr);
cmd.Parameters.AddWithValue("@education",employee.Education);
cmd.Parameters.AddWithValue("@maritalStat", employee.MaritalStat);
cmd.Parameters.AddWithValue("@nrOfChildren", employee.NrOfChildren);

conn.Open();
int count = cmd.ExecuteNonQuery();
conn.Close();

return count;
}

public int delete(String empId) {
OdbcConnection conn = this.getConnection();
String sql = "DELETE FROM STONE.EMP_MASTER WHERE EMP_ID=?";
OdbcCommand cmd = new OdbcCommand(sql, conn);
cmd.Parameters.AddWithValue("@empid", empId);

conn.Open();
int count = cmd.ExecuteNonQuery();
conn.Close();

return count;
}
}
}

调用 CRUD

在 Unit Test 中进行测试。注意 unit test 要根据 obdc 驱动的版本来选择合适的处理器架构 (菜单: Test -> Test Settings -> Default Processor Architecture)。因为我安装的是 64 位版,所以选用 x64。下面是测试代码:

using System;
using Microsoft.VisualStudio.TestTools.UnitTesting;
using HanaTest;

namespace UnitTestProject1
{
[TestClass]
public class UnitTest1
{
[TestMethod]
public void test_insert() {
EmpMasterDAO empDAO = new EmpMasterDAO();
EmpMasterEntity empEntity = new EmpMasterEntity();

empEntity.EmpID = "9001";
empEntity.Gender = "Male";
empEntity.Age = 20;
empEntity.EMail = "test@qq.com";
empEntity.PhoneNr = "13800138000";
empEntity.Education = "Bachelor";
empEntity.MaritalStat = "Single";
empEntity.NrOfChildren = 0;

empDAO.insert(empEntity);
}

[TestMethod]
public void test_delete() {
EmpMasterDAO empDAO = new EmpMasterDAO();
int count = empDAO.delete("9001");
Console.WriteLine(count);
}
}
}

参考

Connect to SAP HANA via ODBC