如何根據資料庫寫介面

⑴ 如何使用sql server 資料庫介面

要實現跟資料庫連接操作，第一：寫一個資料庫連接類，第二：配置訪問資料庫基本元素,可以採用*.XML形式（配置IP，埠，用戶名，密碼等），第三：門診收費系統會提供一個介面調用資料庫連接類的。一般像在醫院或門診這地方，一般都是採用配置形式做資料庫連接的，直接拿配置文件修改一下連接IP地址就可以了，但確保資料庫伺服器上有資料庫表，有連接配置上還要提供一下伺服器IP，埠，和資料庫用戶名和密碼就可以了。在SQL SERVER2008資料庫上只做授權操作即可，授權操作可以有用戶管理裡面進行。允許該用戶查詢和修改等操作就OK了。

⑵ 請問你是怎麼實現的一個項目使用不同資料庫，介面怎麼寫的

自己封裝一個用ADO方式訪問資料庫的類，然後再根據不同的資料庫傳入不同的連接字元串就可以實現對各種資料庫的訪問。其實操作各種資料庫的sql語句都是一樣的，就是剛開始打開資料庫的連接字元串不一樣。當然不同的資料庫添加數據源的方式不一樣。

⑶ C#開發，我要為資料庫中的一個表中一個欄位寫一個介面，供其他人調用

兩種辦法，一是你的傳統方法 GET/SET
第二種。供其它人調用，你可以寫一個方法，把結果編歷出來。別人調用其實就是用你的數據，你把數據先編歷到一個 DATAVEIW。讓調 用你的人自己去遍歷你的DATAVIEW就可以了

⑷ php中怎麼把資料庫連接寫成一個介面

我自己封裝的一個

<?php
class AppConfig{
public static $dbParam = array(
'dbHost' => 'localhost',
'dbUser' => 'root',
'dbPassword' =>'',
'dbName' => '資料庫名',
'dbCharset' => 'utf8',
'dbPort' => 3306,
'dbPrefix' => 'test_',
'dbPconnect' => 0,
'dbDebug' => true,
);
}

class Model {
private $version = ''; //mysql版本
private $config = array(); //資料庫配置數組
private $class; //當前類名
public $tablepre = 'ts_'; //表前綴
public $db = ''; //庫名
public $table = ''; //表名
private static $link; //資料庫鏈接句柄
private $data = array(); //中間數據容器
private $condition = ''; //查詢條件
private $fields = array(); //欄位信息
private $sql = array(); //sql集合，調試用
public $primaryKey = 'id'; //表主鍵

//構造函數初始化
public function __construct($dbParam = array()) {
$this->config = (is_array($dbParam) && !empty($dbParam)) ? $dbParam : AppConfig::$dbParam;
$this->connect();
$this->init();
}

//鏈接資料庫
private function connect() {
if($this->config['dbPconnect']) {
self::$link = @mysql_pconnect($this->config['dbHost'], $this->config['dbUser'], $this->config['dbPassword']);
}else{
self::$link = @mysql_connect($this->config['dbHost'], $this->config['dbUser'], $this->config['dbPassword'], true);
}
mysql_errno(self::$link) != 0 && $this->errdie('Could not connect Mysql: ');
$this->db= !empty($this->db) ? $this->db : $this->config['dbName'];

$serverinfo = $this->version();
if ($serverinfo > '4.1' && $this->config['dbCharset']) {
mysql_query("SET character_set_connection=".$this->config['dbCharset'].",character_set_results=".$this->config['dbCharset'].",character_set_client=binary", self::$link);
}
if ($serverinfo > '5.0') {
mysql_query("SET sql_mode=''", self::$link);
}
@mysql_select_db($this->db, self::$link) or $this->errdie('Cannot use database');
return self::$link;
}

//表基本信息初始化
protected function init() {
$this->class = get_class($this);
$this->table = !empty($this->table) ? $this->table : strtolower($this->class);
$this->table = $this->tablepre . $this->table;
return $this;
}

//設置屬性值
public function __set($name, $value) {
//exit($value);
$this->data['fields'][$name] = $value;
}

//獲取屬性值
public function __get($name) {
if(isset($this->data['fields'][$name])) {
return($this->data['fields'][$name]);
}else {
return NULL;
}
}

//欄位信息處理
private function implodefields($data) {
if (!is_array($data)) {
$data = array();
}
$this->fields = !empty($this->data['fields']) ? array_merge($this->data['fields'], $data) : $data;
foreach($this->fields as $key => $value) {
$fieldsNameValueStr[] = "`$key`='$value'";
$fieldsNameStr[] = "`$key`";
$fieldsValueStr[] = "'$value'";
}
return array($fieldsNameValueStr, $fieldsNameStr, $fieldsValueStr);
}

//條件判斷組裝
private function condition($where = NULL) {
if (is_numeric($where)) {
$where = "WHERE `{$this->primaryKey}`='{$where}' LIMIT 1";
}elseif (is_array($where)){
$where = "WHERE `{$this->primaryKey}` in (".implode(',',$where).")";
}elseif(!empty($this->data['condition'])){
//'預留WHERE', 'order', 'group', 'limit' …………等條件關鍵詞處理介面
$where = $where ? "WHERE {$where}" : "WHERE 1";
isset($this->data['condition']['where']) && $where .= ' AND '.$this->data['condition']['where'];
isset($this->data['condition']['group']) && $where .= ' GROUP BY '.$this->data['condition']['group'];
isset($this->data['condition']['order']) && $where .= ' ORDER BY '.$this->data['condition']['order'];
isset($this->data['condition']['limit']) && $where .= ' LIMIT '.$this->data['condition']['limit'];
}else{
$where = "WHERE {$where}";
}
$this->condition = $where;
return $this;
}

//插入數據
public function insert($data = array(), $replace = false) {
$fields = $this->implodefields($data);
$insert = $replace ? 'REPLACE' : 'INSERT';
$sql = "{$insert} INTO `{$this->db}`.`{$this->table}` (".implode(', ',$fields[1]).") values (".implode(', ',$fields[2]).")";
$this->query($sql);
return $this->getInsertId();
}

//更新數據
public function update($data = array() ,$where = '') {
$numargs = func_num_args();
if ($numargs == 1) {
$where = $data;
$data = array();
}
$fields = $this->implodefields($data);
$this->condition($where);
$sql = "UPDATE `{$this->db}`.`{$this->table}` SET ".implode(', ',$fields[0])." {$this->condition}";
$this->query($sql);
return $this->getAffectedRows();
}

//刪除數據
public function delete($where = NULL) {
if(!is_array($where) && strtolower(substr(trim($where), 0, 6)) == 'delete'){
$sql = $where;
}else{
$this->condition($where);
$sql = "DELETE FROM `{$this->db}`.`{$this->table}` {$this->condition}";
}
$this->query($sql);
return $this->getAffectedRows();
}

//查詢數據
public function select($where = NULL, $fields = '*') {
if(!is_array($where) && strtolower(substr(trim($where), 0, 6)) == 'select'){
$sql = $where;
}else{
$this->condition($where);
$sql = "SELECT {$fields} FROM `{$this->db}`.`{$this->table}` {$this->condition}";
}
return $this->fetch($this->query($sql));
}

//查詢一條數據
public function getOne($where, $fields = '*') {
$data = $this->select($where, $fields = '*');
if($data) {
return $data[0];
}
return array();
}

//查詢多條數據
public function getAll($where, $fields = '*') {
$data = $this->select($where, $fields = '*');
return $data;
}

//結果數量
public function getCount($where = '', $fields = '*') {
$this->condition($where);
$sql = "SELECT count({$fields}) as count FROM `{$this->db}`.`{$this->table}` {$this->condition}";
$data = $this->query($sql);
if($data){
return @mysql_result($data,0);
}
return 0;
}

//執行sql語句（flag為0返回mysql_query查詢後的結果，為1返回lastid，其他返回影響行數，默認為2返回影響行數）
public function query($sql, $flag = '0', $type = '') {
if ($this->config['dbDebug']) {
$startime = $this->microtime_float();
}

//查詢
if ($type == 'UNBUFFERED' && function_exists('mysql_unbuffered_query')) {
$result = @mysql_unbuffered_query($sql, self::$link);
} else {
//exit($sql);
$result = @mysql_query($sql, self::$link);
}

//重試
if (in_array(mysql_errno(self::$link), array(2006,2013)) && empty($result) && $this->config['dbPconnect']==0 && !defined('RETRY')) {
define('RETRY',true); @mysql_close(self::$link); sleep(2);
$this->connect();
$result = $this->query($sql);
}

if ($result === false) {
$this->errdie($sql);
}

if ($this->config['dbDebug']) {
$endtime = $this->microtime_float();
$this->sql[] = array($sql,$endtime-$startime);
}
//清空操作數據
$this->data = array();
return $flag == '0' ? $result : ($flag == '1' ? $this->getInsertId() : $this->getAffectedRows());
}

//返回結果$onlyone為true返回一條否則返回所有,$type有MYSQL_ASSOC,MYSQL_NUM,MYSQL_BOTH
public function fetch($result, $onlyone = false, $type = MYSQL_ASSOC) {
if($result){
if ($onlyone) {
$row = @mysql_fetch_array($result, $type);
return $row;
}else{
$rowsRs = array();
while($row=@mysql_fetch_array($result, $type)) {
$rowsRs[] = $row;
}
return $rowsRs;
}
}
return array();
}

//可以運行SELECT，SHOW，EXPLAIN 或 DESCRIBE 等返回一個資源標識符的語句得到返回結果數組
public function show($sql, $onlyone = false) {
return $this->fetch($this->query($sql), $onlyone);
}

// 使用call函數處理同類型函數
private function __call($name, $arguments) {
$callArr = array('on', 'where', 'order', 'between', 'group', 'limit');
if (in_array($name, $callArr)) {
$this->data['condition'][$name] = $arguments[0];
}else{
$this->errdie("function error: function {$name} is not in ($this->class) class exist");
}
return $this;

}

//返回最後一次插入ID
public function getInsertId() {
return @mysql_insert_id(self::$link);
}

//返回受影響行數
public function getAffectedRows() {
return @mysql_affected_rows(self::$link);
}

//獲取錯誤信息
private function error() {
return ((self::$link) ? @mysql_error(self::$link) : @mysql_error());
}

//獲取錯誤信息ID
private function errno() {
return ((self::$link) ? @mysql_errno(self::$link) : @mysql_errno());
}

//獲取版本信息
function version() {
if(empty($this->version)) {
$this->version = mysql_get_server_info(self::$link);
}
return $this->version;
}

//列印錯誤信息
private function errdie($sql = '') {
if ($this->config['dbDebug']) {
die('</BR><B>MySQL ERROR</B></BR>
SQL:'.$sql.'</BR>
ERRNO:'.$this->errno().'</BR>
ERROR:'.$this->error().'</BR>');
}
die('DB ERROR！！！');
}

//獲取時間微妙數
private function microtime_float()
{
list($usec, $sec) = explode(" ", microtime());
return ((float)$usec + (float)$sec);
}

//析構函數
public function __destruct() {
echo '<hr>';
$this->config['dbDebug'] && print_r($this->sql);
//unset($this->result);
//unset($this->condition);
//unset($this->data);
}
}

class user extends Model {
//public $db = 'qsf_mvc';
//public $table = 'user';
public $primaryKey = 'uid';
}

$userObj = new user();
//---------------------------------------插入數據方法一-----------------------------------------
//模擬ActiveRecord模式 插入數據
$userObj->username = 'hoho';
$userObj->passwd = '1478522';
$userObj->email = '[email protected]';
$userObj->sex = 1;
$userObj->desc = '清潔工';
$insetId = $userObj->insert();
if ($insetId > 0) {
echo "插入ID為:{$insetId}<BR>";
}

//---------------------------------------插入數據方法二-----------------------------------------
//直接數組做參數插入數據
$userArr = array(
'username' => 'hoho',
'passwd' => '1478522',
'email' => '[email protected]',
'sex' => '1',
'desc' => '廚師',
);
$insetId = $userObj->insert($userArr);
if ($insetId > 0) {
echo "插入ID為:{$insetId}<BR>";
}

//---------------------------------------更新數據方法一----------------------------------------
$userObj->username = 'h111oho';
$userObj->passwd = '1478511122';
$userObj->email = '[email protected]';
$userObj->sex = 1;
$userObj->desc = '清潔工';
$affectedRows1 = $userObj->update(89);
if ($affectedRows1 > 0) {
echo "影響行數為:{$affectedRows1}<BR>";
}

//---------------------------------------更新數據方法二----------------------------------------
//更新記錄（傳遞參數的方式和insert操作一樣）
$userArr = array(
'username' => 'hohoho',
'passwd' => '1474rr4448522',
'email' => '[email protected]',
'sex' => '0',
'desc' => '廚師qq',
);
$affectedRows = $userObj->update($userArr, $insetId);
if ($affectedRows > 0) {
echo "影響行數為:{$affectedRows}<BR>";
}

//----------------------------------------查詢數據----------------------------------------------
$userRs0 = $userObj->select(8); //單個主鍵值
//print_r($userRs0);

$userRs1 = $userObj->select(array(1,5,8)); //多個主鍵值的數組
//print_r($userRs1);

$userRs2 = $userObj->select('select count(*) as count from user where uid > 20'); //直接完整sql語句
//print_r($userRs2);

$userRs3 = $userObj->select("`uid` > 0"); //where條件
//print_r($userRs3);

$userRs4 = $userObj->getOne("`uid` > 0"); //獲取單條記錄
//print_r($userRs4);

$usersRs5 = $userObj->getAll("`uid` > 0"); ////獲取所有記錄
//print_r($usersRs5);

$usersRs6 = $userObj->limit('0,10')->where('uid > 100')->order('uid DESC')->group('username')->select();
//print_r($usersRs6);

//----------------------------------------刪除數據-----------------------------------------------
//刪除操作傳遞參數的方式和select操作一樣
$userObj->delete(60); //單個主鍵值
$userObj->delete(array(1,5,8)); //多個主鍵值的數組
$userObj->delete('delete from user where uid > 100'); //直接完整sql語句
$userObj->delete("`uid` > 100"); //where條件
$userObj->limit('5')->where('uid > 80')->delete();
//----------------------------------------特殊查詢-----------------------------------------------
$userShowRs = $userObj->show('show create table user', true); //獲取特殊查詢的結果,第二個參數代表返回一條結果還是所有的結果

⑸ 有了數據介面規范,怎麼寫介面程序

你所謂的介面規范是一組API嗎，是以數據文件還是資料庫做為輸入

我覺得應該是後者，那就通過標准介面如odbc來讀取需要的數據，然後按老師要求輸出文本，應該不太難

先問清楚老師的要求的說

⑹ 網站的資料庫查詢介面怎麼做

jsp網站,想提供介面給其他項目獲取資料庫的數據方法如下：
jsp接收參數，就跟java類接收參數一樣，用request.getParameter("參數名");獲取
網頁游戲發送上來的參數，然後調用資料庫，把需要的信息查詢出來，通過字元串或者xml或者
json總之一切你想要的數據格式，返回出來就可以了。
返回出來實現：直接利用outputstream對象write出來即可，最後記得關閉。
java.io.OutputStream os = response.getOutputStream();
os.write(buf, 0, readSize);

⑺ 我想問如何用java語言寫連接mysql資料庫的介面，使其他的語言的程序能夠通過我這個介面訪問數據

你好 我寫下思路
1 創建一個javaweb工程 該工程部署再伺服器中 你可以訪問鏈接 例如 http localhost 8080/test/user?m=delete&id=1
這個鏈接的功能刪除id為1 的user ，這在你test工程裡面實現 屬於javaweb開發本身的知識 ，然後你把這個鏈接給別人 因為是http請求 什麼語言都可以的 例如php和.net都可以創建http請求 他們只需要把id值改成2 或者3 不就可以刪除用戶2或者用戶3了嘛
聚爾淘 juertao.com 技術部工程師為你解答

⑻ 如何為sql server資料庫寫一個編程介面，需要注意什麼問題

編程寫一個連接池
用的時候從池中拿出connection，不用了就還回去
每次取的時候判斷是否為null，是就給個新的，不是就繼續讓他用

⑼ 做個資料庫介面

9.Sql Server7.0/2000資料庫
#import "c:\Program Files\Common Files\System\ADO\msado15.dll" \
no_namespace rename("EOF", "EndOfFile")
::CoInitialize(NULL); // 初始化OLE/COM庫環境 ，為訪問ADO介面做准備

_RecordsetPtr m_pRecordset("ADODB.Recordset");
_ConnectionPtr m_pConnection("ADODB.Connection");

_bstr_t bstrSQL("select * from stu_info"); //查詢語句
char * query_cmd = "DELETE FROM stu_info WHERE sname = 』本拉登』";

try
{
// 創建Connection對象
m_pConnection.CreateInstance("ADODB.Connection");
// 設置連接字元串，必須是BSTR型或者_bstr_t類型
_bstr_t strConnect= "Provider=SQLOLEDB;Server=(local);Database=student; uid=sa; pwd=123;";
//若資料庫在網路上則Server為形如(192.168.1.5,3340)
//用戶sa和密碼123隻是針對我的庫
m_pConnection->Open(strConnect,"","",adModeUnknown);
if(m_pConnection==NULL)
cerr<<"Lind data ERROR!\n";
// 創建記錄集對象
m_pRecordset.CreateInstance(__uuidof(Recordset));
// 取得表中的記錄
m_pRecordset->Open(bstrSQL,m_pConnection.GetInterfacePtr(),
adOpenDynamic,adLockOptimistic,adCmdText);

_variant_t vsnum,vsname,vsage,vssex,vsmajor; //對應庫中的snum,sname,sage,ssex,smajor
cout << "學號 姓名 年齡 姓別 專業";
cout << "\n----------------------------------------------------------------\n";

while (!m_pRecordset->EndOfFile)
{
vsnum = m_pRecordset->GetCollect(_variant_t((long)0));//這兒給欄位編號和欄位名都可以
vsname = m_pRecordset->GetCollect("sname");
vsage = m_pRecordset->GetCollect("sage");
vssex = m_pRecordset->GetCollect("ssex");
vsmajor = m_pRecordset->GetCollect("smajor");
if (vsnum.vt != VT_NULL && vsname.vt != VT_NULL && vsage.vt != VT_NULL
&& vssex.vt != VT_NULL && vsmajor.vt != VT_NULL)
{
cout.setf(ios::left);
cout << setw(14) << (char*)(_bstr_t)vsnum;
cout << setw(14) << (char*)(_bstr_t)vsname;
cout << setw(8) << vsage.lVal;
cout << setw(8) << (char*)(_bstr_t)vssex;
cout <<setw(20) << (char*)(_bstr_t)vsmajor;
cout.unsetf(ios::left);
cout << endl;
}
m_pRecordset->MoveNext(); ///移到下一條記錄
}
cout << "\n----------------------------------------------------------------\n";
cout << "\n請輸入你要添加的學生信息\n";
cout << "學號:";
cin >> student.snum;
cout << "\n姓名:";
cin >> student.sname;
cout << "\n年齡:";
cin >> student.sage;
cout << "\n姓別:";
cin >> student.ssex;
cout << "\n專業:";
cin >> student.smajor;
m_pRecordset->MoveFirst(); //移動到第一條記錄
m_pRecordset->AddNew(); ///添加新記錄
m_pRecordset->PutCollect("snum",_variant_t(student.snum));
m_pRecordset->PutCollect("sname",_variant_t(student.sname));
m_pRecordset->PutCollect("sage",_variant_t(student.sage));
m_pRecordset->PutCollect("ssex",_variant_t(student.ssex));
m_pRecordset->PutCollect("smajor",_variant_t(student.smajor));
m_pRecordset->Update();

m_pConnection->Execute(query_cmd,NULL,1); //用Execute執行sql語句來刪除
m_pRecordset->Close(); // 關閉記錄集
}
// 捕捉異常
catch(_com_error e)
{
// 顯示錯誤信息
cerr << "\nERROR:" << (char*)e.Description();//拋出異常
}
if(m_pConnection->State)
m_pConnection->Close();
::CoUninitialize();

3.顯示表格
/*
#import "c:\Program Files\Common Files\System\ADO\msado15.dll" \
no_namespace rename("EOF", "EndOfFile")
*/
CoInitialize(NULL);
_bstr_t varSource="Provider=Microsoft.Jet.OLEDB.4.0;Data Source=*.mdb";
//_bstr_t varSource="Data Source=myServerAddress;Initial Catalog=myDataBase;User Id=myUsername;Password=myPassword;"
_ConnectionPtr m_pConnection(_uuidof(Connection));
m_pConnection->Open(varSource,"","",adModeUnknow);
//打開屬性為默認（adModeRead(只讀)，adModeWrite(可寫)，adModeReadWrite(可讀寫)等）
_RecordsetPtr m_pSet(_uuid(Recordset));
try {
HRESULT hr=m_pSet->Open(%%1,m_pConnection.GetInterfacePtr(),
adOpenDynamic,adLockPessimistic,adCmdText);
}
catch(_com_error *e){
AfxMessageBox(e->ErrorMessage());
}
if(SUCCESSED(hr))
{
//表打開成功
}
FieldsPtr p_fields=m_pSet->Fields;
FieldPtr p_field;
_variant_t var_index;
LPCSTR field_name;
int index=0;
_bstr_t bstr_field_name;
int countfields=p_fields->GetCount();
CString *Column=new CString[countfields];
CListCtrl *pList=(CListCtrl*)GetDlgItem(%%1);//IDC_LIST_TABLEDATA
VERIFY(pList);
pList->DeleteAllItems();
for(index=0;index<countfields;index++)
{
var_index.vt=VT_I4;
var_index.IVal=index;
p_field=p_fields->Item[var_index];
bstr_field_name=p_field->GetName();
field_name=(LPCSTR)bstr_field_name;
Column[index]=field_name;
int ColumnWidth=Column[index].GetLength()*15;
pList->InsertColumn(index,field_name,LVCFMT_CENTER,ColumnWidth);
}
int i=0;
_bstr_t vCol;
//pList->SetTextBkColor(RGB(122,200,122));
//pList->SetTextColor(RGB(0,0,200));
while(!m_pSet->adoEOF)
{
pList->Insert(i,atoi(i));
for(int j=0;j<countfields;j++)
{
vCol=m_pSet->GetCollect((long)j);
pList->SetItemText(i,j,vCol);
}
m_pSet->MoveNext();
i++;
}
CoUninitialize(NULL);

4.操作表格
/*
#import "c:\Program Files\Common Files\System\ADO\msado15.dll" \
no_namespace rename("EOF", "EndOfFile")
*/
CoInitialize(NULL);
_bstr_t varSource="Provider=Microsoft.Jet.OLEDB.4.0;Data Source=*.mdb";
//_bstr_t varSource="Data Source=myServerAddress;Initial Catalog=myDataBase;User Id=myUsername;Password=myPassword;"
_ConnectionPtr m_pConnection(_uuidof(Connection));
m_pConnection->Open(varSource,"","",adModeUnknow);
//打開屬性為默認（adModeRead(只讀)，adModeWrite(可寫)，adModeReadWrite(可讀寫)等）
_RecordsetPtr m_pSet(_uuid(Recordset));
try {
HRESULT hr=m_pSet->Open(%%1,m_pConnection.GetInterfacePtr(),
adOpenDynamic,adLockPessimistic,adCmdText);
}
catch(_com_error *e){
AfxMessageBox(e->ErrorMessage());
}
if(SUCCESSED(hr))
{
//表打開成功
}
FieldsPtr p_fields=m_pSet->Fields;
FieldPtr p_field;
_variant_t var_index;
LPCSTR field_name;
int index=0;
_bstr_t bstr_field_name;
int countfields=p_fields->GetCount();
CString *Column=new CString[countfields];
CListCtrl *pList=(CListCtrl*)GetDlgItem(%%1);//IDC_LIST_TABLEDATA
VERIFY(pList);
pList->DeleteAllItems();
for(index=0;index<countfields;index++)
{
var_index.vt=VT_I4;
var_index.IVal=index;
p_field=p_fields->Item[var_index];
bstr_field_name=p_field->GetName();
field_name=(LPCSTR)bstr_field_name;
Column[index]=field_name;
int ColumnWidth=Column[index].GetLength()*15;
pList->InsertColumn(index,field_name,LVCFMT_CENTER,ColumnWidth);
}
int i=0;
_bstr_t vCol;
//pList->SetTextBkColor(RGB(122,200,122));
//pList->SetTextColor(RGB(0,0,200));
while(!m_pSet->adoEOF)
{
pList->Insert(i,atoi(i));
for(int j=0;j<countfields;j++)
{
vCol=m_pSet->GetCollect((long)j);
pList->SetItemText(i,j,vCol);
}
m_pSet->MoveNext();
i++;
}
CoUninitialize(NULL);

6.關閉時斷開連接
::ExitInstance()
{
if (adStateOpen == ADOConn->State)
ADOConn->Close();
ADOConn.Release();
if(adStateOpen == m_pADOset->State)
m_pADOset->Close();
m_pADOset.Release();
return CWinApp::ExitInstance();
}

22.批量執行SQL和存儲過程
22.1、如果用ODBC訪問資料庫的話，可參考下列代碼：
CDatabase * pDatabase = new CDatabase;
TRY
{
pDatabase->OpenEx( _T("DSN=ODBCName;UID=%%1;PWD=%%2"), CDatabase::noOdbcDialog);
}
CATCH (CDBException, e)
{
delete pDatabase;
return;
}END_CATCH
SQL.Format("exec sp_Name");//有參數的話直接寫再後面
pDatabase->ExecuteSQL(SQL);
pDatabase->Close();
delete pDatabase;

22.2、用ADO調用存儲過程
_ConnectionPtr Conn = NULL;
_RecordsetPtr Rs = NULL;
_CommandPtr Cmd = NULL;
CoInitialize(NULL);
Conn.CreateInstance ( __uuidof(Connection));
Rs.CreateInstance (__uuidof(Recordset));
Cmd.CreateInstance (__uuidof(Command));
Conn->Open(L"db", L"sa", L"", adOpenUnspecified); //打開正常
//如下為_CommandPtr對象參數的賦值和調用
Cmd->ActiveConnection = Conn;
Cmd->CommandText = "SP_TEST";
//資料庫中實際存在這個測試存儲過程，select * from atable,不傳遞參數
Cmd->CommandType = adCmdStoredProc;
Cmd->Parameters->Refresh();
Rs = Cmd->Execute( NULL,NULL, adCmdUnknown ); //COM出錯。
//注釋掉的代碼為直接的SQL語句提交，運行正確。
//Cmd->ActiveConnection=Conn;
//Cmd->CommandText = "select * from atable";
//Cmd->CommandType = adCmdText;
//Cmd->Parameters->Refresh();
//Rs = Cmd->Execute(NULL,NULL,adCmdUnknown);
Rs->Close();
Conn->Close();
CoUninitialize();

⑽ 如何寫通用的資料庫的crud介面

您好，您這樣：
package com.tgb.lk.demo.model;
import com.tgb.lk.ahibernate.annotation.Column;
import com.tgb.lk.ahibernate.annotation.Id;
//此處沒有加Table屬性,它是其他類的基類,本類中用@Column註解的欄位在子類中同樣會被創建到表中.
public class Person {
@Id
@Column(name = "id")
private int id; // 主鍵,int類型,資料庫建表時此欄位會設為自增長

@Column(name = "name", length = 20)
private String name; // 名字長度一般不會超過20個字元吧,length=20數據欄位的長度是20

@Column(name = "age", type = "INTEGER")
private int age; // 年齡一般是數值,用type = "INTEGER"規范一下吧.

// //假設您開始時沒有此屬性,程序開發中才想到此屬性,去掉代碼注釋試試吧,資料庫增刪改查不用修改任何代碼哦.
// @Column(name = "sex")
// private String sex;

// 有些欄位您可能不希望保存到資料庫中,不用@Column注釋就不會映射到資料庫.
private String noSaveFild;

//get和set方法.
//....

@Override
public String toString() {
return "id=" + id + ", name=" + name + ",age=" + age;
}
}<span style="font-size:18px;">
</span>
Teacher.java

[java] view plain
package com.tgb.lk.demo.model;
import com.tgb.lk.ahibernate.annotation.Column;
import com.tgb.lk.ahibernate.annotation.Table;

//自動生成的建表語句:
//crate table [t_teacher]: CREATE TABLE t_teacher (id INTEGER primary key autoincrement, title TEXT, name TEXT(20), age INTEGER )

@Table(name = "t_teacher")
public class Teacher extends Person {
@Column(name = "title")
private String title;// 職稱

//get和set方法.
//....

@Override
public String toString() {
return "Teacher [" + super.toString() + ",title=" + title + "]";
}
}<span style="font-size:18px;">
</span>
Student.java
[java] view plain
package com.tgb.lk.demo.model;

import com.tgb.lk.ahibernate.annotation.Column;
import com.tgb.lk.ahibernate.annotation.Table;

//自動生成的建表語句:
//CREATE TABLE t_student (id INTEGER primary key autoincrement, classes TEXT, teacher_id INTEGER, name TEXT(20), age INTEGER )

@Table(name = "t_student")
public class Student extends Person {

@Column(name = "teacher_id")
private int teacherId;// 班主任id

@Column(name = "classes")
private String classes;// 班級

//get和set方法
//...

@Override
public String toString() {
return "Student [" + super.toString() + ",teacherId=" + teacherId
+ ", classes=" + classes + "]";
}
}<span style="font-size:18px;">
</span>