倫倫3號Beta-Log

[MS-SQL]不具自動容錯移轉的鏡像設定

2011-06-25T04:08:00.000-07:00

序

以下的資料庫鏡像架構大致上就是

應用程式==data==>主體伺服器==data==>鏡像伺服器

環境

兩台一樣環境的伺服器

Windows Server 2003 R2
Microsoft SQL Server 2008 R2
Microsoft SQL Server Management Studio 10.0.1600.22

SQL Server服務啟動帳號設定

在windows服務(services.msc) 列表中,找到SQL Server，右鍵選內容或雙擊
後選擇登入頁，在此帳戶中這裡配置登錄用戶和密碼，這個地方建議兩台伺服器都配置一組一樣的帳號，並將此帳戶加到SQL Server的管理帳戶，後續的鏡像會用這組帳號繼續設定
SQL Server Agent 啟動帳號也一樣設置

主體伺服器備份

在主體伺服器用windows帳戶登入Management Studio工具，這個動作是為了後續使用語法產生SQL檔時才不會有權限錯誤
產生資料庫建立語法
以物件總管詳細資料選取需要鏡像的資料庫，並產生Create語法(選檔案即可產生.sql檔)

匯出每個資料庫的備份檔

backup database [DataBaseName1] to disk='D:\dbbackup\[DataBaseName1].bak'  with init
GO
backup database [DataBaseName2] to disk='D:\dbbackup\[DataBaseName2].bak'  with init
GO

匯出每個資料庫的記錄檔

BACKUP LOG [DataBaseName1] TO DISK = 'D:\dbbackup\[DataBaseName1].log'
GO
BACKUP LOG [DataBaseName2] TO DISK = 'D:\dbbackup\[DataBaseName2].log'
GO

還原資料到鏡像伺服器

將上一步驟產生的檔案(含*.sql、*.bak、*.log)所在dbbackup資料夾複製到鏡像資料庫
在鏡像伺服器用windows帳戶登入Management Studio工具
建立資料庫：以Management Studio開啟建立資料庫用的sql檔並執行，即可產生與主體伺服器相同名稱的資料庫

還原資料

restore database [DataBaseName1] from disk='D:\backupz\[DataBaseName1].bak' with replace,norecovery
GO
restore database [DataBaseName2] from disk='D:\backupz\[DataBaseName2].bak' with replace,norecovery
GO

還原記錄檔

RESTORE LOG [DataBaseName1] FROM DISK = 'D:\backupz\[DataBaseName1].log'  WITH FILE=1, NORECOVERY
GO
RESTORE LOG [DataBaseName2] FROM DISK = 'D:\backupz\[DataBaseName2].log'  WITH FILE=1, NORECOVERY
GO

成功後會看到建立起來的資料庫名稱後面會出現(正在還原...)的狀態

於主體伺服器啟動鏡像服務

在主體伺服器的資料庫上點右鍵，選屬性，並選擇[鏡像]頁籤。接著點選[設定安全性]鈕就會開啟[設定資料庫鏡像安全性精靈]
於見證伺服器選擇頁選擇否，不使用見證伺服器
第一次使用鏡像設定會選擇本機的鏡像服務Port與鏡像端點名稱，此處採用預設值即可
設定鏡像伺服器的連線資訊
服務帳戶不用設定
完成後就會進行設定，第一次設定時會自動產生服務端點，這時就會啟動服務的Port
完成後會詢問是否要啟動鏡像，選擇不要啟動鏡像。這時如果直接啟動如果連線網域名稱錯誤就會失敗(而且還不給設定…)
接著就可以在伺服器網路位址確認鏡像伺服器的連線資訊

需注意的是他有個奇怪的驗證，就是預設他會把鏡像伺服器的電腦名稱帶到鏡像的位址，但他的預設格式是[電腦名稱.網域名稱]，沒有網域名稱時就必須在電腦名稱後面加一個句點.，否則你就會看到下面的錯誤
啟動成功後如下圖
重覆此上述動作把所有資料庫的鏡像都啟動

[C#]MS-SQL資料庫存取函式

2011-06-24T01:23:00.000-07:00

序言

我將C#存取MS-SQL的程式包了一層方便使用。

環境

VS2008
MS-SQL 2008

存取函式類別

using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Text;
using System.Data;

namespace MyCommon.DAO
{

    /// 
    /// MS-SQL連線物件
    /// 
    public class MSSQLBaseIO
    {
        SqlConnection sqlConn = null;
        /// 
        /// 建立連線物件
        /// 
        /// 連線字串，如Data Source=localhost;Initial Catalog=dbName;User id=Account;Password=Password;
        public MSSQLBaseIO(string connectionString)
        {
            sqlConn = new SqlConnection(connectionString);
        }
        /// 
        /// 建立連線物件
        /// 
        /// 可為localhost / domainname  / 或 IP
        /// 若Host為IP，則需為true
        /// 不設定則填0，則會用MSSQL預設port
        /// 不設定則填null，express版預設為SQLEXPRESS，正式版預設為MSSQLSERVER，從服務組態可以看到
        /// 資料庫名稱
        /// 是否使用 Windows 整合驗証方式連線，false則必需填帳號密碼
        /// 登入帳號
        /// 登入密碼
        /// 連線逾期，不設定則填0
        public MSSQLBaseIO(string host,bool isHostIP,int port,
            string instanceName, string dbName,
            bool isIntegratedSecurity,
            string id, string password,
            int timeout)
        {
            StringBuilder connectionString = new StringBuilder();
            if (isHostIP) connectionString.Append("Data Source=tcp:" + host);
            else connectionString.Append("Data Source=" + host);
            if (instanceName != null) connectionString.Append("\\" + instanceName);
            if (port != 0) connectionString.Append("," + port);
            connectionString.Append(";");
            connectionString.Append("Initial Catalog=" + dbName + ";");
            if (isIntegratedSecurity) connectionString.Append("integrated security=true;");
            if (id!=null) connectionString.Append("User id=" + id + ";");
            if (password!=null) connectionString.Append("Password=" + password + ";");
            if (timeout>0) connectionString.Append("Connect Timeout=" + timeout + ";");
            sqlConn = new SqlConnection(connectionString.ToString());
        }
        /// 
        /// 取得目前連線物件
        /// 
        /// 
        public SqlConnection getConnection()
        {
            return sqlConn;
        }

        Exception _exception = null;
        /// 
        /// 取得上次執行後的錯誤
        /// 
        /// 
        public Exception getException(){
            return _exception;
        }
        /// 
        /// 關閉連線
        /// 
        public void closeConn()
        {
            closeConn(true);
        }
        /// 
        /// 關閉連線
        /// 
        /// 是否關閉連線
        public void closeConn(bool isCloseConn){
            if (sqlConn != null && isCloseConn && sqlConn.State!=System.Data.ConnectionState.Closed)
            {
                sqlConn.Close();
            }
        }
        /// 
        /// 取得新的Transaction物件
        /// 
        /// Transaction物件
        public SqlTransaction getNewTransaction()
        {
            if (sqlConn.State != System.Data.ConnectionState.Open)
                sqlConn.Open();
            return sqlConn.BeginTransaction();
        }

        /// 
        /// 執行SQL命令，執行後會關閉SQL連線
        /// 
        /// SQL命令
        /// 是否為預存程序
        /// 變動筆數
        public int ExecuteNonQuery(string sqlcmd, bool isStoredProcedure)
        {
            return ExecuteNonQuery(sqlcmd,isStoredProcedure, true);
        }
        /// 
        /// 執行SQL命令
        /// 
        /// SQL命令
        /// 是否為預存程序
        /// 是否關閉連線
        /// 變動筆數
        public int ExecuteNonQuery(string sqlcmd, bool isStoredProcedure, bool isCloseConn)
        {
            SqlParameter[] sqlparams = null;
            return ExecuteNonQuery(sqlcmd, ref sqlparams, isStoredProcedure, isCloseConn);
        }
        /// 
        /// 執行SQL命令
        /// 
        /// SQL命令
        /// 命令參數，可為null，參數名稱為 @參數名稱
        /// 是否為預存程序
        /// 是否關閉連線
        /// 變動筆數
        public int ExecuteNonQuery(string sqlcmd, ref SqlParameter[] sqlparams, bool isStoredProcedure, bool isCloseConn)
        {
            return ExecuteNonQuery(sqlcmd, ref sqlparams, isStoredProcedure, null, isCloseConn);
        }
        /// 
        /// 執行SQL命令
        /// 
        /// SQL命令
        /// 命令參數，可為null，參數名稱為 @參數名稱
        /// 是否為預存程序
        /// SqlTransaction，可為null
        /// 是否關閉連線
        /// 變動筆數
        public int ExecuteNonQuery(string sqlcmd, ref SqlParameter[] sqlparams,bool isStoredProcedure, SqlTransaction trans, bool isCloseConn)
        {
            int result = -1;
            _exception = null;
            try
            {
                if (sqlConn.State != System.Data.ConnectionState.Open)
                    sqlConn.Open();
                SqlCommand cmd;
                if (trans==null)
                    cmd = new SqlCommand(sqlcmd, sqlConn);
                else
                    cmd = new SqlCommand(sqlcmd, sqlConn, trans);
                if(isStoredProcedure)
                    cmd.CommandType = CommandType.StoredProcedure;
                if (sqlparams!=null)
                    cmd.Parameters.AddRange(sqlparams);
                result = cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                _exception = ex;
            }
            finally
            {
                closeConn(isCloseConn);
            }
            return result;
        }
        /// 
        /// 取得多列資料，執行後會關閉SQL連線
        /// 
        /// SQL命令
        /// 是否為預存程序
        /// 是否關閉連線
        /// 多列資料
        public List ExecuteReader(string sqlcmd, bool isStoredProcedure)
        {
            return ExecuteReader(sqlcmd, isStoredProcedure, true);
        }
        /// 
        /// 取得多列資料
        /// 
        /// SQL命令
        /// 是否為預存程序
        /// 是否關閉連線
        /// 多列資料
        public List ExecuteReader(string sqlcmd, bool isStoredProcedure, bool isCloseConn)
        {
            SqlParameter[] sqlparams = null;
            return ExecuteReader(sqlcmd, ref sqlparams, isStoredProcedure, isCloseConn);
        }
        /// 
        /// 取得多列資料
        /// 
        /// SQL命令
        /// 命令參數，可為null，參數名稱為 @參數名稱
        /// 是否為預存程序
        /// 是否關閉連線
        /// 多列資料
        public List ExecuteReader(string sqlcmd, ref SqlParameter[] sqlparams, bool isStoredProcedure, bool isCloseConn)
        {
            return ExecuteReader(sqlcmd, ref sqlparams, isStoredProcedure, null, isCloseConn);
        }
        /// 
        /// 取得多列資料
        /// 
        /// SQL命令
        /// 命令參數，可為null，參數名稱為 @參數名稱
        /// 是否為預存程序
        /// SqlTransaction，可為null
        /// 是否關閉連線
        /// 多列資料
        public List ExecuteReader(string sqlcmd, ref SqlParameter[] sqlparams, bool isStoredProcedure, SqlTransaction trans, bool isCloseConn)
        {
            List result = null;
            _exception = null;
            SqlDataReader reader = null;
            try
            {
                if (sqlConn.State != System.Data.ConnectionState.Open)
                    sqlConn.Open();
                SqlCommand cmd;
                if (trans == null)
                    cmd = new SqlCommand(sqlcmd, sqlConn);
                else
                    cmd = new SqlCommand(sqlcmd, sqlConn, trans);
                if (isStoredProcedure)
                    cmd.CommandType = CommandType.StoredProcedure;
                if (sqlparams != null)
                    cmd.Parameters.AddRange(sqlparams);
                reader = cmd.ExecuteReader();
                object[] item;
                if (reader.HasRows)
                {
                    result = new List();
                    while (reader.Read())
                    {
                        item = new object[reader.FieldCount];
                        for (int j = 0; j < reader.FieldCount; j++)
                        {
                            item[j] = reader[j];
                        }
                        result.Add(item);
                    }
                }
            }
            catch (Exception ex)
            {
                _exception = ex;
            }
            finally
            {
                if (reader!=null) reader.Close();
                closeConn(isCloseConn);
            }
            return result;
        }

        /// 
        /// 取得單一值，執行後會關閉SQL連線
        /// 
        /// SQL命令
        /// 是否為預存程序
        /// 單一值
        public object ExecuteScalar(string sqlcmd, bool isStoredProcedure)
        {
            return ExecuteScalar(sqlcmd, isStoredProcedure, true);
        }
        /// 
        /// 取得單一值
        /// 
        /// SQL命令
        /// 是否為預存程序
        /// 是否關閉連線
        /// 單一值
        public object ExecuteScalar(string sqlcmd, bool isStoredProcedure, bool isCloseConn)
        {
            SqlParameter[] sqlparams = null;
            return ExecuteScalar(sqlcmd, ref sqlparams, isStoredProcedure, isCloseConn);
        }
        /// 
        /// 取得單一值
        /// 
        /// SQL命令
        /// 命令參數，可為null，參數名稱為 @參數名稱
        /// 是否為預存程序
        /// 是否關閉連線
        /// 單一值
        public object ExecuteScalar(string sqlcmd,ref SqlParameter[] sqlparams, bool isStoredProcedure, bool isCloseConn)
        {
            return ExecuteScalar(sqlcmd,ref sqlparams, isStoredProcedure, null, isCloseConn);
        }
        /// 
        /// 取得單一值
        /// 
        /// SQL命令
        /// 命令參數，可為null，參數名稱為 @參數名稱
        /// 是否為預存程序
        /// SqlTransaction，可為null
        /// 是否關閉連線
        /// 單一值
        public object ExecuteScalar(string sqlcmd,ref SqlParameter[] sqlparams, bool isStoredProcedure, SqlTransaction trans, bool isCloseConn)
        {
            object result = null;
            _exception = null;
            try
            {
                if (sqlConn.State != System.Data.ConnectionState.Open)
                    sqlConn.Open();
                SqlCommand cmd;
                if (trans == null)
                    cmd = new SqlCommand(sqlcmd, sqlConn);
                else
                    cmd = new SqlCommand(sqlcmd, sqlConn, trans);
                if (isStoredProcedure)
                    cmd.CommandType = CommandType.StoredProcedure;
                if (sqlparams != null)
                    cmd.Parameters.AddRange(sqlparams);
                result = cmd.ExecuteScalar();
              
            }
            catch (Exception ex)
            {
                _exception = ex;
            }
            finally
            {
                closeConn(isCloseConn);
            }
            return result;
        }

        /// 
        /// 取得單一列資料，執行後會關閉SQL連線
        /// 
        /// SQL命令
        /// 是否為預存程序
        /// 單一列資料
        public object[] ExecuteReaderSingleRow(string sqlcmd, bool isStoredProcedure)
        {
            return ExecuteReaderSingleRow(sqlcmd, isStoredProcedure, true);
        }
        /// 
        /// 取得單一列資料
        /// 
        /// SQL命令
        /// 是否為預存程序
        /// 是否關閉連線
        /// 單一列資料
        public object[] ExecuteReaderSingleRow(string sqlcmd, bool isStoredProcedure, bool isCloseConn)
        {
            SqlParameter[] sqlparams = null;
            return ExecuteReaderSingleRow(sqlcmd, ref sqlparams, isStoredProcedure, isCloseConn);
        }
        /// 
        /// 取得單一列資料
        /// 
        /// SQL命令，參數部份以 @參數名稱 標示
        /// 命令參數，可為null，參數名稱為 @參數名稱
        /// 是否為預存程序
        /// 是否關閉連線
        /// 單一列資料
        public object[] ExecuteReaderSingleRow(string sqlcmd,ref SqlParameter[] sqlparams, bool isStoredProcedure, bool isCloseConn)
        {
            return ExecuteReaderSingleRow(sqlcmd,ref sqlparams, isStoredProcedure, null, isCloseConn);
        }
        /// 
        /// 取得單一列資料
        /// 
        /// SQL命令，參數部份以 @參數名稱 標示
        /// 命令參數，可為null，參數名稱為 @參數名稱
        /// 是否為預存程序
        /// SqlTransaction，可為null
        /// 是否關閉連線
        /// 單一列資料
        public object[] ExecuteReaderSingleRow(string sqlcmd, ref SqlParameter[] sqlparams, bool isStoredProcedure, SqlTransaction trans, bool isCloseConn)
        {
            object[] result = null;
            _exception = null;
            SqlDataReader reader = null;
            try
            {
                if (sqlConn.State != System.Data.ConnectionState.Open)
                    sqlConn.Open();
                SqlCommand cmd;
                if (trans == null)
                    cmd = new SqlCommand(sqlcmd, sqlConn);
                else
                    cmd = new SqlCommand(sqlcmd, sqlConn, trans);
                if (isStoredProcedure)
                    cmd.CommandType = CommandType.StoredProcedure;
                if (sqlparams != null)
                    cmd.Parameters.AddRange(sqlparams);
                reader = cmd.ExecuteReader(CommandBehavior.SingleRow);
                object[] item;
                if (reader.HasRows)
                {
                    reader.Read();
                    item = new object[reader.FieldCount];
                    for (int j = 0; j < reader.FieldCount; j++)
                    {
                        item[j] = reader[j];
                    }
                    result = item;
                }
            }
            catch (Exception ex)
            {
                _exception = ex;
            }
            finally
            {
                if (reader != null) reader.Close();
                closeConn(isCloseConn);
            }
            return result;
        }
    }
}

[C++]Oracle資料庫存取函式(OCCI)

2011-06-23T01:03:00.000-07:00

開發環境

VS2008
Oracle 10g Express Edition

下載OCCI函式庫

下載occivc9win32-111060-132181.zip，解壓縮到自行建立的lib目錄後可以得到目錄
下載instantclient-sdk-win32-11.2.0.1.0.zip，解壓縮後可在[instantclient_11_2\sdk\]目錄找到[include]
將上述兩個目錄複製到某個目錄下，如[D:\Project\CPPProject\occivc9win32-111060-132181]

設定開發專案

將[lib]目錄中的oraocci11.dll與oraocci11d.dll都複製到[C:\WINDOWS\system32]
於開發用的C++專案設定屬性：展開[組態屬性→C/C++→一般]，修改[其他Include目錄]，指到[include]目錄
展開[組態屬性→連結器→一般]，修改[其他程式庫目錄]，指到lib目錄
展開[組態屬性→連結器→輸入]，修改[其他相依性]，，增加[oraocci11d.lib]

資料庫連線函式庫

OracleIO.h

#pragma once
#include
namespace commonio {
 class OracleIO
 {
  private:
   oracle::occi::Environment *env;
   oracle::occi::Connection *conn;
   oracle::occi::Statement *stmt;
   oracle::occi::ResultSet *rs;
   const char* _ip;
   unsigned int _port;
   const char* _account;
   const char* _pswd;
   const char* _defaultDB;
  public:
   OracleIO(const char* ip,unsigned int port,const char* account,const char* pswd,const char* defaultDB);
   ~OracleIO(void);

   
   /**
   **取得連線
   **/
   oracle::occi::Connection *getConn();
   void closeConn();
   void closeStatement();
   /**
   **執行查詢
   **/
   oracle::occi::ResultSet *executeQuery(const char* sqlStr);
   /**
   **執行新增、更新、刪除
   **/
   unsigned int executeUpdate(const char* sqlStr);
 };
};

OracleIO.cpp

#include "StdAfx.h"
#include "OracleIO.h"
#include "CommonFunc.h"
#include 
using namespace std;
using namespace commonio;
using namespace oracle::occi;
OracleIO::OracleIO(const char* ip,unsigned int port,const char* account,const char* pswd,const char* defaultDB)
{
 _ip=ip;
 _port=port;
 _account=account;
 _pswd=pswd;
 _defaultDB=defaultDB;
 env = oracle::occi::Environment::createEnvironment("UTF8","UTF8",Environment::THREADED_MUTEXED);
 conn=NULL;
 stmt=NULL;
 rs=NULL;
}



OracleIO::~OracleIO(void)
{
 closeConn();
 oracle::occi::Environment::terminateEnvironment(env);
}

Connection* OracleIO::getConn(){
 if(conn==NULL){
  string port;
  commonio::CommonFunc::itostr(_port,port,10);
  string connectString="//";
  connectString=connectString + _ip+ ":" + port + "/" + _defaultDB;
  conn = env->createConnection(_account, _pswd, connectString);
 }
 return conn;
}
void OracleIO::closeConn(){
 if(conn!=NULL){
  closeStatement();
  env->terminateConnection(conn);
  conn=NULL;
 }
}
void OracleIO::closeStatement(){
 if(stmt!=NULL){
  if(rs!=NULL){
   stmt->closeResultSet(rs);
   rs=NULL;
  }
  conn->terminateStatement(stmt);
  stmt=NULL;
 }
}

ResultSet *OracleIO::executeQuery(const char* sqlStr){
 try{
  getConn();
  string sql=string(sqlStr);
  stmt = conn->createStatement(sql);
  rs = stmt->executeQuery();  
 }catch (SQLException &sqlExcp){
  cerr <createStatement(sql);
  result=stmt->executeUpdate();
  closeStatement();
 }catch (SQLException &sqlExcp){
  cerr <

額外函式

CommonFunc.h

#pragma once
using namespace std;
namespace commonio {
 class CommonFunc
 {
 public:
  static void itostr(int value, std::string& buf, int base);
 };
};

CommonFunc.cpp

#include "stdafx.h"
#include 
#include "CommonFunc.h"
using namespace std;
using namespace commonio;

void CommonFunc::itostr(int value, std::string& buf, int base){
 
 int i = 30;
 
 buf = "";
 
 for(; value && i ; --i, value /= base) buf = "0123456789abcdef"[value % base] + buf;
 
}

使用範例

#include "stdafx.h"
#include 
#include 
#include "OracleIO.h"
using namespace std;
using namespace commonio;

int main(int argc, _TCHAR* argv[])
{

 OracleIO oracleio=OracleIO("localhost",1521,"oracle","oracle","XE");
 /**
 **更新測試Start
 **/ 
 unsigned int changeNum= oracleio.executeUpdate("update test1 set testname='test123' where testsn=1");
 cout<<"changeNum:"< listOfColumns =rs->getColumnListMetaData();
 for(int i=0;inext())
 {
  for(int i=0;igetString(i+1)<<"\t";
  }
  cout <

[C++]MySQL資料庫存取函式(MySQL++)

2011-06-22T01:01:00.000-07:00

序言

此篇為研究C++存取MySQL所寫的函式。

環境

VS2008
mysql++-3.1.0
MySQL Server 5.1

編譯MySQL++函式庫

下載mysql++-3.1.0.tar.gz，解壓縮後可以得到[mysql++-3.1.0]目錄
進入[mysql++-3.1.0\vc2008\]目錄會找到[mysql++_mysqlpp.vcproj]專案，以Visual Studio 2008開啟
編譯時MySQL++會需要MySQL的版本定義標頭檔，函式庫預設MySQL安裝於[C:\Program Files\MySQL\MySQL Server 5.1]，所以需先確認是否有[C:\Program Files\MySQL\MySQL Server 5.1\include]與[C:\Program Files\MySQL\MySQL Server 5.1\lib\opt]是否存在，如果MySQL放在其他目錄，可透過專案屬性修改

開啟專案屬性
展開[組態屬性→C/C++→一般]，修改[其他Include目錄]，指到MySQL的安裝目錄中的include資料夾
展開[組態屬性→連結器→一般]，修改[其他程式庫目錄]，指到MySQL的安裝目錄中的lib\opt資料夾

建置專案
建置成功後會在[mysql++-3.1.0\vc2008\Debug]目錄下看到編譯完成的mysqlpp_d.dll、mysqlpp_d.lib

設定開發專案

將上一步產生的[mysqlpp_d.dll]複製到[C:\WINDOWS\system32]
於開發用的C++專案設定屬性：展開[組態屬性→C/C++→一般]，修改[其他Include目錄]，指到MySQL的安裝目錄中的include資料夾與mysql++函式庫的lib目錄
展開[組態屬性→連結器→一般]，修改[其他程式庫目錄]，指到MySQL的安裝目錄中的lib\opt資料夾與mysql++編譯後的Debug目錄
展開[組態屬性→連結器→輸入]，修改[其他相依性]，，增加[mysqlpp_d.lib]與 [libmysql.lib]

資料庫連線函式庫

MySQLIO.h

#pragma once

#include 

namespace commonio {

     class MySQLIO

     {

     private:

           mysqlpp::Connection _conn;

           const char* _ip;

           unsigned int _port;

           const char* _account;

           const char* _pswd;

           const char* _defaultDB;

           const char* _error;

           int _errnum;

     public:

           /**

           **MySQL資料庫連線物件

           **/

           MySQLIO(const char* ip,unsigned int port,const char* account,const char* pswd,const char* defaultDB);

           ~MySQLIO(void);

           /**

           **錯誤訊息

           **/

           const char* error();

           int errnum();

           /**

           **取得連線

           **/

           mysqlpp::Connection getConn(){return _conn;}

           /**

           **執行查詢

           **/

           mysqlpp::StoreQueryResult executeQuery(const char* sqlStr);

           /**

           **執行查詢

           **/

           mysqlpp::StoreQueryResult executeQuery(const char* sqlStr,mysqlpp::SQLQueryParms & param);

           /**

           **執行新增、更新、刪除

           **/

           mysqlpp::SimpleResult executeUpdate(const char* sqlStr);

           /**

           **執行新增、更新、刪除

           **/

           mysqlpp::SimpleResult executeUpdate(const char* sqlStr,mysqlpp::SQLQueryParms & param);

     };

};

MySQLIO.cpp

#include "stdafx.h"

#include "MySQLIO.h"

 

using namespace std;

using namespace commonio;

MySQLIO::MySQLIO(const char* ip,unsigned int port,const char* account,const char* pswd,const char* defaultDB):_conn(false)

{

     _ip=ip;

     _port=port;

     _account=account;

     _pswd=pswd;

     _defaultDB=defaultDB;

     _conn.set_option(new mysqlpp::SetCharsetNameOption("utf8") );

}

const char* MySQLIO::error(){return _error;}

int MySQLIO::errnum(){return _errnum;}

mysqlpp::StoreQueryResult MySQLIO::executeQuery(const char* sqlStr){

     _error=NULL;

     _errnum=0;

     

     try{

           if(!_conn.connected()) {

                if(!_conn.connect(_defaultDB, _ip,

                     _account, _pswd,_port)){

                           _error=_conn.error();

                           _errnum=_conn.errnum();

                           

                }

           }

           if(_conn.connected()) {

                mysqlpp::Query query = _conn.query(sqlStr);

                if (mysqlpp::StoreQueryResult res = query.store()) {

                     query.reset();

                     return res;

                }else{

                     _error=query.error();

                     _errnum=query.errnum();

                     

                }

           }

     }catch(const mysqlpp::ConnectionFailed &e){

           _error=e.what();

           _errnum=e.errnum();

     }catch(const mysqlpp::BadQuery &e){        

           _error=e.what();

           _errnum=e.errnum();

     }catch (const mysqlpp::BadConversion & e) {

           _error=e.what();

     }catch (const mysqlpp::BadFieldName & e) {

           _error=e.what();

     }catch (const mysqlpp::BadIndex & e) {

           _error=e.what();

     }catch (const mysqlpp::BadInsertPolicy & e) {

           _error=e.what();

     }catch (const mysqlpp::BadOption & e) {

           _error=e.what();

     }catch (const mysqlpp::BadParamCount & e) {

           _error=e.what();

     }catch (const mysqlpp::Exception& e) {

           _error=e.what();

     }

     return mysqlpp::StoreQueryResult();

 

}

mysqlpp::StoreQueryResult MySQLIO::executeQuery(const char* sqlStr,mysqlpp::SQLQueryParms & param){

     _error=NULL;

     _errnum=0;

     

     try{

           if(!_conn.connected()) {

                if(!_conn.connect(_defaultDB, _ip,

                     _account, _pswd,_port)){

                           _error=_conn.error();

                           _errnum=_conn.errnum();

                           

                }

           }

           if(_conn.connected()) {

                mysqlpp::Query query = _conn.query(sqlStr);

                query.parse();

                if (mysqlpp::StoreQueryResult res = query.store(param)) {

                     query.reset();

                     return res;

                }else{

                     _error=query.error();

                     _errnum=query.errnum();

                     

                }

           }

     }catch(const mysqlpp::ConnectionFailed &e){

           _error=e.what();

           _errnum=e.errnum();

     }catch(const mysqlpp::BadQuery &e){        

           _error=e.what();

           _errnum=e.errnum();

     }catch (const mysqlpp::BadConversion & e) {

           _error=e.what();

     }catch (const mysqlpp::BadFieldName & e) {

           _error=e.what();

     }catch (const mysqlpp::BadIndex & e) {

           _error=e.what();

     }catch (const mysqlpp::BadInsertPolicy & e) {

           _error=e.what();

     }catch (const mysqlpp::BadOption & e) {

           _error=e.what();

     }catch (const mysqlpp::BadParamCount & e) {

           _error=e.what();

     }catch (const mysqlpp::Exception& e) {

           _error=e.what();

     }

     return mysqlpp::StoreQueryResult();

}

 

 

mysqlpp::SimpleResult MySQLIO::executeUpdate(const char* sqlStr){

     _error=NULL;

     _errnum=0;

     

     try{

           if(!_conn.connected()) {

                if(!_conn.connect(_defaultDB, _ip,

                     _account, _pswd,_port)){

                           _error=_conn.error();

                           _errnum=_conn.errnum();

                }

           }

           if(_conn.connected()) {

                mysqlpp::Query query = _conn.query(sqlStr);

                query.parse();

                if (mysqlpp::SimpleResult res = query.execute()) {

                     query.reset();

                     return res;

                }else{

                     _error=query.error();

                     _errnum=query.errnum();

                     

                }

           }

     }catch(const mysqlpp::ConnectionFailed &e){

           _error=e.what();

           _errnum=e.errnum();

     }catch(const mysqlpp::BadQuery &e){        

           _error=e.what();

           _errnum=e.errnum();

     }catch (const mysqlpp::BadConversion & e) {

           _error=e.what();

     }catch (const mysqlpp::BadFieldName & e) {

           _error=e.what();

     }catch (const mysqlpp::BadIndex & e) {

           _error=e.what();

     }catch (const mysqlpp::BadInsertPolicy & e) {

           _error=e.what();

     }catch (const mysqlpp::BadOption & e) {

           _error=e.what();

     }catch (const mysqlpp::BadParamCount & e) {

           _error=e.what();

     }catch (const mysqlpp::Exception& e) {

           _error=e.what();

     }

     return mysqlpp::SimpleResult();

}

 

mysqlpp::SimpleResult MySQLIO::executeUpdate(const char* sqlStr,mysqlpp::SQLQueryParms & param){

     _error=NULL;

     _errnum=0;

     

     try{

           if(!_conn.connected()) {

                if(!_conn.connect(_defaultDB, _ip,

                     _account, _pswd,_port)){

                           _error=_conn.error();

                           _errnum=_conn.errnum();

                }

           }

           if(_conn.connected()) {

                mysqlpp::Query query = _conn.query(sqlStr);

                query.parse();

                if (mysqlpp::SimpleResult res = query.execute(param)) {

                     query.reset();

                     return res;

                }else{

                     _error=query.error();

                     _errnum=query.errnum();

                     

                }

           }

     }catch(const mysqlpp::ConnectionFailed &e){

           _error=e.what();

           _errnum=e.errnum();

     }catch(const mysqlpp::BadQuery &e){        

           _error=e.what();

           _errnum=e.errnum();

     }catch (const mysqlpp::BadConversion & e) {

           _error=e.what();

     }catch (const mysqlpp::BadFieldName & e) {

           _error=e.what();

     }catch (const mysqlpp::BadIndex & e) {

           _error=e.what();

     }catch (const mysqlpp::BadInsertPolicy & e) {

           _error=e.what();

     }catch (const mysqlpp::BadOption & e) {

           _error=e.what();

     }catch (const mysqlpp::BadParamCount & e) {

           _error=e.what();

     }catch (const mysqlpp::Exception& e) {

           _error=e.what();

     }

     return mysqlpp::SimpleResult();

}

 

MySQLIO::~MySQLIO(void)

{    

}

使用範例

#include "stdafx.h"

#include 

#include "MySQLIO.h"

using namespace std;

using namespace commonio;

 

int main(int argc, _TCHAR* argv[])

{

     string data;

 

     MySQLIO mysqlio("localhost",3306,"root",NULL,"pklogdb");

     mysqlpp::SQLQueryParms params;

           params << 2;

     if (mysqlpp::StoreQueryResult res = mysqlio.executeQuery("select * from gametypetab where gameType=%0q",params)) {

           mysqlpp::StoreQueryResult::const_iterator it;

           mysqlpp::Row::const_iterator colit;

           for (it = res.begin(); it != res.end(); ++it) {

                mysqlpp::Row row = *it;

                cout << '\t';

                for (colit = row.begin(); colit != row.end(); ++colit) {

                     if(colit->is_null()){

                           cout << "\t (NULL)"<< endl;

                     }else{

                           string col(*colit);

                           cout << '\t' << col << endl;                         

                     }

                }

                cout << endl;

           }

           params.clear();

           string value("TEST");

           params<0){

                cerr << "success update"<< endl;

           }

     }else{

           cerr << "Failed to get item list: "<< endl;

           return 1;

     }

 

    return 0;

}

[C++]Http Get與Post函式(Curl)

2011-06-21T00:36:00.000-07:00

序言

此篇記錄我使用Curl函式庫來達成Http的Get與Post方法。

開發環境

VS2008
curl-7.21.4

編譯Curl函式庫

下載curl-7.21.4.zip，解壓縮後可以得到[curl-7.21.4]目錄
進入[curl-7.21.4]目錄會找到[vc6curl.dsw]專案，以Visual Studio 2008開啟
建置專案
建置成功後會在[curl-7.21.4\lib\DLL-Debug]目錄下看到編譯完成的libcurld.dll、libcurld_imp.lib

設定開發專案

將上一步產生的[libcurld.dll]複製到[C:\WINDOWS\system32]
於開發用的C++專案設定屬性：展開[組態屬性→C/C++→一般]，修改[其他Include目錄]，指到[curl-7.21.4]目錄中的include資料夾
展開[組態屬性→連結器→一般]，修改[其他程式庫目錄]，指到[curl-7.21.4\lib\DLL-Debug]目錄
展開[組態屬性→連結器→輸入]，修改[其他相依性]，，增加[libcurld_imp.lib]

Http連線函式庫

HttpIO.h

#pragma once
#include 
using namespace std;
namespace commonio {
 class HttpIO
 {
 public:
  /**
  **post方法
  **isRedirect:是否依head redirect
  **param:傳參數，如val1=123&val2=abc
  **timeout:等待回應逾期時間(秒)，為不限制
  **/
  static string doPost(string URL,bool isRedirect,string param="",long timeout=0);
  /**
  **get方法
  **isRedirect:是否依head redirect
  **timeout:等待回應逾期時間(秒)，為不限制
  **/
  static string doGet(string URL,bool isRedirect,long timeout=0);
 };
};

HttpIO.cpp

#include "StdAfx.h"
#include 
//#include 
#include 
#include "HttpIO.h"

using namespace std;
using namespace commonio;


// This is the writer call back function used by curl
size_t writer (char *data, size_t size, size_t nmemb, std::string *buffer)
{
    size_t result = 0;
    if (buffer != NULL)
    {
        buffer->append (data, size * nmemb);
        result = size * nmemb;
    }
    return result;
}    



string HttpIO::doPost(string URL,bool isRedirect,string param,long timeout)
{
    CURL *curl;
    CURLcode cc;
    string bufferdata;
 string error;
 //string user_agent("Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)");
 if ((curl = curl_easy_init()) == NULL)
        exit(1);
 curl_easy_setopt(curl, CURLOPT_ERRORBUFFER, error);
    curl_easy_setopt(curl, CURLOPT_URL, URL.c_str()); // URL used for posting
 //curl_easy_setopt(curl, CURLOPT_USERAGENT, user_agent);
 

 if(isRedirect) curl_easy_setopt(curl, CURLOPT_FOLLOWLOCATION, 1); //Redirect
 if(timeout>0) curl_easy_setopt(curl, CURLOPT_TIMEOUT, timeout); //times out after second
    curl_easy_setopt(curl, CURLOPT_POST, 1);//Tell libcurl to use POST
 curl_easy_setopt(curl, CURLOPT_POSTFIELDS, param.c_str());
    curl_easy_setopt (curl, CURLOPT_WRITEFUNCTION,   writer);
    curl_easy_setopt (curl, CURLOPT_WRITEDATA,&bufferdata);
    //curl_easy_setopt(curl, CURLOPT_VERBOSE, 1);  //Debug
    //cc=curl_easy_setopt(curl, CURLOPT_HEADER, 1);    //Debug
 cc = curl_easy_perform(curl);
 
    curl_easy_cleanup(curl);
    if(cc == CURLE_OK)
        {
            string data;
            data=bufferdata;
            bufferdata="";
   return data;
        }      
        else
        {
            //cout << "Error: [" << cc << "] - "<< error;
   string data("");
   return data;
        }
}

string HttpIO::doGet(string URL,bool isRedirect,long timeout)
{
    CURL *curl;
    CURLcode cc;

    string bufferdata;
 string error;
    if ((curl = curl_easy_init()) == NULL)
        exit(1);
 curl_easy_setopt(curl, CURLOPT_ERRORBUFFER, error);
    curl_easy_setopt(curl, CURLOPT_URL, URL.c_str()); // URL used for posting
 if(isRedirect) curl_easy_setopt(curl, CURLOPT_FOLLOWLOCATION, 1); //Redirect
 if(timeout>0) curl_easy_setopt(curl, CURLOPT_TIMEOUT, timeout); //times out after second
    curl_easy_setopt (curl, CURLOPT_WRITEFUNCTION,   writer);
    curl_easy_setopt (curl, CURLOPT_WRITEDATA,&bufferdata);
 //cc=curl_easy_setopt(curl, CURLOPT_HEADER, 1);    //Debug
    cc = curl_easy_perform(curl);
    curl_easy_cleanup(curl);
    if(cc == CURLE_OK)
        {
            string data;
            data=bufferdata;
            bufferdata="";
   return data;
        }      
        else
        {
            //cout << "Error: [" << cc << "] - "<< error;
   string data("");
   return data;
        }
}

額外函式

CommonFunc.h

#pragma once
using namespace std;
namespace commonio {
 class CommonFunc
 {
 public:
  static void str_split(const string& str,
        vector& tokens,
        const string& delimiters = " ");
  static vector> paramToArray(string param);
 };
};

CommonFunc.cpp

#include "stdafx.h"

#include 
#include 
#include "CommonFunc.h"
using namespace std;
using namespace commonio;
void CommonFunc::str_split(const string& str,
                      vector& tokens,
                      const string& delimiters){
    // Skip delimiters at beginning.
    string::size_type lastPos = str.find_first_not_of(delimiters, 0);
    // Find first "non-delimiter".
    string::size_type pos     = str.find_first_of(delimiters, lastPos);

    while (string::npos != pos || string::npos != lastPos)
    {
        // Found a token, add it to the vector.
        tokens.push_back(str.substr(lastPos, pos - lastPos));
        // Skip delimiters.  Note the "not_of"
        lastPos = str.find_first_not_of(delimiters, pos);
        // Find next "non-delimiter"
        pos = str.find_first_of(delimiters, lastPos);
    }
}


vector> CommonFunc::paramToArray(string param){
   vector>  arr;
   vector p;
   CommonFunc::str_split(param,p,"&");
   if (param.find("&")>-1) {
    vector p2;
    int j = 0;
    for (unsigned int i = 0; i < p.size(); i++) {
     if (p[i].find_first_of("amp;")==0) {
      p2[j - 1]=p2[j - 1] + "&" + p[i].substr(4);
      j--;
     }
     p2.push_back(p[i]);
     j++;
    }
    p=p2;
   }

   for (unsigned int i = 0; i < p.size(); i++) {
    vector item;
    CommonFunc::str_split(p[i],item,"=");
    if (item.size() == 2) {
     arr.push_back(item);
    }
   }
   return arr;
  }

使用範例程式

#include "stdafx.h"
#include 
#include 
#include "HttpIO.h"
using namespace std;
using namespace commonio;

int main(int argc, _TCHAR* argv[])
{
 string data=HttpIO::doGet("http://www.google.com",false);
 cout << '\t' << data << endl;
    return 0;
}

[Java]Http Get與Post函式2(HttpURLConnection)

2011-03-29T18:59:00.000-07:00

序言

之前我發的一篇[Http Get與Post函式]中已經實現了可維持Session狀態的HTTP連線函式，但我發現了Apache提供的這個Client在Windows下會有連線數上限的問題(聽說好像調整XP連線數可以解決)。
另外，有的時候使用HTTP連線也不一定需要維持Session狀態，這時候其實就不需要另外加入Apache的http client的JAR。
因此我還是整理一下如果一個不維持Session狀態的HTTP Client連線怎麼達成。

函式原始碼

參數轉換函式

package common.control;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.HashMap;

public class HTTPParseFunc {

 /**
  * hashMapToString
  * 
  * @param map
  * @param charset編碼
  *            ，如HTTP.UTF_8
  * @return
  * @throws UnsupportedEncodingException
  */
 @SuppressWarnings("unchecked")
 public static String hashMapToString(HashMap<String, String> map,
   String charset) throws UnsupportedEncodingException {
  StringBuffer result = new StringBuffer();
  java.util.Iterator it = map.entrySet().iterator();
  boolean isfirst = true;
  while (it.hasNext()) {
   java.util.Map.Entry entry = (java.util.Map.Entry) it.next();
   if (isfirst) {
    isfirst = false;
   } else {
    result.append("&");
   }
   result
     .append(URLEncoder.encode(entry.getKey().toString(),
       charset));
   result.append("=");
   result.append(URLEncoder.encode(entry.getValue().toString(),
     charset));
  }
  return result.toString();
 }
 /**
  * 將inputStream轉為String
  * 
  * @param is
  *            inputStream
  * @param charset
  *            編碼，如HTTP.UTF_8
  * @return inputStream的內容
  * @throws UnsupportedEncodingException
  */
 public static String inputStream2String(InputStream is, String charset)
   throws UnsupportedEncodingException {
  BufferedReader in = new BufferedReader(new InputStreamReader(is,
    charset));
  StringBuffer buffer = new StringBuffer();
  String line = "";
  try {
   boolean isfirst = true;
   while ((line = in.readLine()) != null) {
    if (!isfirst) {
     buffer.append("\n");
    } else {
     isfirst = false;
    }
    buffer.append(line);
   }
  } catch (IOException e) {
   e.printStackTrace();
  }

  return buffer.toString();
 }

 /**
  * HTTP 傳輸參數分割
  * @param param 如name1=value1&name2=value2
  * @return
  * @throws UnsupportedEncodingException
  */
  public static ArrayList<String[]> paramToArray(String param)
    throws UnsupportedEncodingException {
   ArrayList<String[]> arr = null;
   String[] p = param.split("&");
   if (param.toLowerCase().contains("&amp;")) {
    ArrayList<String> p2 = new ArrayList<String>();
    int j = 0;
    for (int i = 0; i < p.length; i++) {
     if (p[i].toLowerCase().startsWith("amp;")) {
      p2.set(j - 1, p2.get(j - 1) + "&amp;" + p[i].substring(4));
      j--;
     }
     p2.add(p[i]);
     j++;
    }
    p2.toArray(p);
   }

   for (int i = 0; i < p.length; i++) {
    String[] item = p[i].split("=");
    if (item.length == 2) {
     if (arr == null)
      arr = new ArrayList<String[]>();
     // item[0]=URLDecoder.decode(item[0],charset);
     // item[1]=URLDecoder.decode(item[1],charset);
     arr.add(item);
    }
   }
   return arr;
  }
}

連線參數模型

package common.model;

public class HTTPResponse {
 String html=null;
 Integer statusCode=null;
 public String getHtml() {
  return html;
 }
 public void setHtml(String html) {
  this.html = html;
 }
 public Integer getStatusCode() {
  return statusCode;
 }
 public void setStatusCode(Integer statusCode) {
  this.statusCode = statusCode;
 }
}

HTTP連線函式

package common;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.Proxy;
import java.net.URL;
import java.util.HashMap;

import common.control.HTTPParseFunc;
import common.model.HTTPResponse;



public class HTTPBaseIO2 {
 public enum Method {
  get, post
 }
 /**
  * 送出Request
  * @param urlpath URL
  * @param method HTTPBaseIO2.Method.get/post
  * @param params HashMap<Name, Value>
  * @param charset UTF-8
  * @param timeout 連線逾時null:不設限/millisecond
  * @return 回傳的html
  * @throws UnsupportedEncodingException
  */
 public static HTTPResponse doSend(String urlpath, Method method,
   HashMap<String, String> params, String charset,boolean isAutoRedirect, Integer timeout,Proxy proxy) throws UnsupportedEncodingException {
  HTTPResponse result=new HTTPResponse();
  String param=null;
  if(params!=null){
   param=HTTPParseFunc.hashMapToString(params, charset);
  }
  if(method==Method.post){
   result=sendPost(urlpath,param,charset,isAutoRedirect,timeout,proxy);
  }else{
   result=sendGet(urlpath,param,charset,isAutoRedirect,timeout,proxy);
  }
  return result;
 }
 /**
  * 向指定URL發送GET方法的請求
  * 
  * @param url
  *            發送請求的URL
  * @param param
  *            請求參數，請求參數應該是name1=value1&name2=value2的形式。
  * @return URL所代表遠程資源的響應
  */
 public static HTTPResponse sendGet(String url, String params, String charset,boolean isAutoRedirect, Integer timeout,Proxy proxy) {
  HTTPResponse result=new HTTPResponse();
  HttpURLConnection conn=null;
  BufferedReader in = null;
  try {
   String urlName = url;
   if(params!=null) urlName+= "?" + params;
   URL realUrl = new URL(urlName);

   HttpURLConnection.setFollowRedirects(isAutoRedirect);
   // 打開和URL之間的連接 
   if(proxy!=null) 
    conn = (HttpURLConnection)realUrl.openConnection(proxy);
   else
    conn = (HttpURLConnection)realUrl.openConnection();
   if(timeout!=null) conn.setConnectTimeout(timeout);
   // 設置通用的請求屬性
   conn.setRequestProperty("accept", "*/*");
   conn.setRequestProperty("connection", "Keep-Alive");
   conn.setRequestProperty("user-agent",
     "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)");
   // 建立實際的連接
   conn.connect();
   result.setHtml(HTTPParseFunc.inputStream2String(conn.getInputStream(), charset));
  } catch (Exception e) {
   e.printStackTrace();
   result=null;
  }
  // 使用finally塊來關閉輸入流
  finally {
   try {
    if (conn != null){
     if(conn.getResponseCode()!=HttpURLConnection.HTTP_OK)
      result=null;
     result.setStatusCode(conn.getResponseCode());
    }
   } catch (Exception e) {
   }
   try {
    if (in != null) {
     in.close();
    }
    if (conn != null){
     conn.disconnect();
           }
   } catch (IOException ex) {
    ex.printStackTrace();
   }
  }
  return result;
 }

 /**
  * 向指定URL發送POST方法的請求
  * 
  * @param url
  *            發送請求的URL
  * @param param
  *            請求參數，請求參數應該是name1=value1&name2=value2的形式。
  * @return URL所代表遠程資源的響應
  */
 public static HTTPResponse sendPost(String url, String params, String charset,boolean isAutoRedirect, Integer timeout,Proxy proxy) {
  HTTPResponse result=new HTTPResponse();
  PrintWriter out = null;
  BufferedReader in = null;
  HttpURLConnection conn=null;
  try {
   URL realUrl = new URL(url);
   // 打開和URL之間的連接 

   HttpURLConnection.setFollowRedirects(isAutoRedirect);
   if(proxy!=null) 
    conn = (HttpURLConnection)realUrl.openConnection(proxy);
   else
    conn = (HttpURLConnection)realUrl.openConnection();
   if(timeout!=null) conn.setConnectTimeout(timeout);
   // 設置通用的請求屬性
   conn.setRequestProperty("accept", "*/*");
   conn.setRequestProperty("connection", "Keep-Alive");
   conn.setRequestProperty("user-agent",
     "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1)");
   // 發送POST請求必須設置如下兩行
   conn.setDoOutput(true);
   conn.setDoInput(true);
   // 獲取URLConnection對象對應的輸出流
   out = new PrintWriter(conn.getOutputStream());
   // 發送請求參數
   if(params!=null) out.print(params);
   // flush輸出流的緩衝
   out.flush();
   result.setHtml(HTTPParseFunc.inputStream2String(conn.getInputStream(), charset));
   
  } catch (Exception e) {
   e.printStackTrace();
   result=null;
  }
  // 使用finally塊來關閉輸出流、輸入流
  finally {
   try {
    if (conn != null){
     if(conn.getResponseCode()!=HttpURLConnection.HTTP_OK)
      result=null;
     result.setStatusCode(conn.getResponseCode());
    }
   } catch (Exception e) {
   }
   try {
    if (out != null) {
     out.close();
    }
    if (in != null) {
     in.close();
    }
   } catch (IOException ex) {
    ex.printStackTrace();
   }
   if (conn != null){
    conn.disconnect();
          }
  }
  return result;
 }
 

}

使用範例程式

package common.test;

import java.util.HashMap;


import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import common.HTTPBaseIO2;
import common.model.HTTPResponse;

public class HTTPBaseIO2Test {

 @Before
 public void setUp() throws Exception {
 }

 @After
 public void tearDown() throws Exception {
 }

 @Test
 public void testDoGet() {
  String urltest = "http://localhost:8080/Test/Test1" ;
  String charset="UTF-8";
  HashMap<String, String> params=new HashMap<String, String>();
  try {
   params.put("val", "測試&測試");
   HTTPResponse html=HTTPBaseIO2.doSend(urltest, HTTPBaseIO2.Method.get, params, charset,true,null,null);
   System.out.println("testDoGet:"+html.getHtml());
  } catch (Exception e) {
   e.printStackTrace();
  }
 }

 @Test
 public void testDoPost() {
  String urltest = "http://localhost:8080/Test/Test1" ;
  String charset="UTF-8";
  HashMap<String, String> params=new HashMap<String, String>();
  try {
   params.put("val", "測試1&測試1");
   HTTPResponse html=HTTPBaseIO2.doSend(urltest, HTTPBaseIO2.Method.post, params, charset,true,null,null);
   System.out.println("testDoPost:"+html.getHtml());
   params.clear();
   params.put("val", "測試2&測試2");
   html=HTTPBaseIO2.doSend(urltest, HTTPBaseIO2.Method.post, params, charset,true,null,null);
   System.out.println("testDoPost:"+html.getHtml());
  } catch (Exception e) {
   e.printStackTrace();
  }
 }

}

[CentOS]JBoss5.1安裝

2010-12-30T19:11:00.000-08:00

序言

此篇簡單的記錄JBoss在CentOS的安裝步驟。

環境

OS:CentOS 4.8
JVM:JDK 1.6.0 update 20 (安裝過程參考)

安裝步驟

到官方網站下載JBoss的5.1.0版的zip檔如[jboss-5.1.0.GA.zip]
到[/usr/local/]目錄下解壓縮這個zip檔
```
#cd /usr/local/
#unzip jboss-5.1.0.GA.zip
```
建立環境變數[JBOSS_HOME]，在這邊有兩種方式選一種來就可以了
- 修改[/etc/profile]，可以用如[vi /etc/profile]命令修改，增加已下內容在最後一行：
```
export JBOSS_HOME=/usr/local/jboss-5.1.0.GA
export PATH=$PATH:$JBOSS_HOME/bin
```
- 建立一個[jboss.sh]在[/etc/profile.d]目錄，如[vi /etc/profile.d/jboss.sh]，內容如下：
```
JBOSS_HOME=/usr/local/jboss-5.1.0.GA
PATH=$PATH:$JBOSS_HOME/bin
export JBOSS_HOME PATH
```
登出再登入OS
執行JBoss看看有沒有辦法啟動，測試網址為http://localhost:8080/
```
#sh $JBOSS_HOME/bin/run.sh -b 0.0.0.0
```
- 如果看到以下錯誤訊息而無法啟動，試著修改[/usr/local/jboss-5.1.0.GA/bin/run.conf]這個檔案中的 java [-Xmx]與[-XX:MaxPermSize]這兩個參數的大小
```
Error occurred during initialization of VM
Could not reserve enough space for object heap
Could not create the Java virtual machine.
```
如果要將JBoss已背景方式執行，並在OS啟動時自動啟動，可參考 http://community.jboss.org/wiki/startjbossonbootwithlinux或 http://amjet.dyndns.biz/blog/IT/?p=297
- 增加jboss帳號與修改目錄權限
```
#useradd jboss
#cd /usr/local/jboss-5.1.0.GA
#chmod -R 700 ./
```
- 修改[/usr/local/jboss-5.1.0.GA/bin/run.conf]檔，將以下內容加在最後一行
```
JAVA_HOME=/usr/java/latest
JBOSS_HOME=/usr/local/jboss-5.1.0.GA
JBOSS_HOST=0.0.0.0
JAVAPTH=/usr/java/latest
```
- 修改[/usr/local/jboss-5.1.0.GA/bin/jboss_init_redhat.sh]檔，將以下內容加在第一行
```
. /usr/local/jboss-5.1.0.GA/bin/run.conf
```
- 修改[/etc/rc.local]檔，將以下內容加在最後一行
```
/usr/local/jboss-5.1.0.GA/bin/jboss_init_redhat.sh start
```
- 如果你想開啟/關閉JBoss就執行以下命令
```
/usr/local/jboss-5.1.0.GA/bin/jboss_init_redhat.sh start
/usr/local/jboss-5.1.0.GA/bin/jboss_init_redhat.sh stop
```

[CentOS]JDK(Java)安裝

2010-12-29T18:51:00.000-08:00

序言

此篇簡單的記錄JDK在CentOS的安裝步驟，下一篇將會搭配這個Java環境安裝JBoss。

環境

OS:CentOS 4.8

安裝步驟

到官方網站下載JDK的Linux版的RPM檔如[jdk-6u20-linux-i586-rpm.bin]
執行安裝命令[sh jdk-6u20-linux-i586-rpm.bin]，此時會要求你同意授權條件。安裝完成後預設的安裝路徑會帶版號，如[/usr/java/jdk1.6.0_20]。建立一個jdk的目錄連結。
```
#sh jdk-6u20-linux-i586-rpm.bin
#cd /usr/local
#ln –s /usr/java/jdk1.6.0_20 jdk
```

將此JVM加入系統可用Java

#alternatives --install /usr/bin/java java /usr/java/latest 99

修改系統預設Java，執行此命令會要你選擇可用的Java編號
```
#alternatives --config java
```
輸入已下命令確認是否有出現JAVA版本
```
#java –version
```

建立環境變數[JAVA_HOME]，在這邊有兩種方式選一種來就可以了

修改[/etc/profile]，可以用如[vi /etc/profile]命令修改，內容如下：

export JAVA_HOME=/usr/java/latest
export CLASSPATH=.:$JAVA_HOME/jre/lib/rt.jar:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export PATH=$PATH:$JAVA_HOME/bin

建立一個[java.sh]在[/etc/profile.d]目錄，如[vi /etc/profile.d/java.sh]，內容如下：

JAVA_HOME=/usr/java/latest
CLASSPATH=.:$JAVA_HOME/lib.tools.jar
PATH=$JAVA_HOME/bin:$PATH
export JAVA_HOME CLASSPATH PATH

登出再登入OS
輸入已下命令確認是否有出現環境變數值
```
#echo $JAVA_HOME
```

[CentOS]MySQL安裝

2010-12-28T23:35:00.000-08:00

序言

我依據我自己的環境記錄下我的安裝步驟以供自己參考。

環境

OS:CentOS 4.8

安裝步驟

到官方網站下載MySQL的Linux版的TAR檔如[mysql-5.1.45-linux-i686-glibc23.tar.gz]

依據官方安裝步驟如下，執行最後一步會啟動MySQL

#groupadd mysql
#useradd -g mysql mysql
#cd /usr/local
#gunzip < /path/to/mysql-5.1.45-linux-i686-glibc23.tar.gz | tar xvf -
#ln -s /usr/local/mysql-5.1.45-linux-i686-glibc23 mysql
#cd mysql
#chown -R mysql .
#chgrp -R mysql .
#scripts/mysql_install_db --user=mysql
#chown -R root .
#chown -R mysql data
#bin/mysqld_safe --user=mysql &

如果有其他非本機的Client要連現這台DB需建立帳號，如果不綁IP安全性(代表從任何IP都能以該帳號連線)的帳號建立方式如下
- 進入mysql命令模式
```
# /usr/local/mysql/bin/mysql -u root
```
- 建立帳號
```
mysql>grant all on *.* to 帳號@ identified by '密碼' with grant option;
mysql>FLUSH PRIVILEGES;
mysql>quit;
```

關閉MySQL

#/usr/local/mysql/bin/mysqladmin -u root shutdown

啟動MySQL
```
#/usr/local/mysql/bin/mysqld_safe &
```
資料庫參數設定檔應該是在/etc/my.cnf，如果沒有可以從/usr/local/mysql-5.1.45-linux-i686-glibc23/support-files底下的*.cnf中挑適合的放在/etc/my.cnf
- my-innodb-heavy-4G.cnf: 這是一個針對 4G RAM（主要運行只有 InnoDB 表的 MySQL 並使用幾個連接數執行複雜的查詢)。
- my-huge.cnf: 適合 1GB - 2GB RAM的主機使用。
- my-large.cnf: 適合 512MB RAM的主機使用。
- my-medium.cnf: 只有 32MB - 64MB RAM 的主機使用，或者有 128MB RAM 但需要運行其他伺服器，例如 web server。
- my-small.cnf: 記憶體少於 64MB 時適用這個，MySQL 會佔用較少資源。

將MySQL設為在OS啟動時自動啟動

#cp /usr/local/mysql-5.1.45-linux-i686-glibc23/support-files/mysql.server /etc/rc.d/init.d/mysqld
#chmod 700 /etc/init.d/mysqld
#chkconfig --add mysqld
#chkconfig --level 345 mysqld on

[4Shared]網路硬碟上傳下載教學(Desktop程式版)

2010-12-28T22:28:00.000-08:00

序言

幾年前曾經為了分享照片給別人，所以我曾經開發過一個FriendShare的網站。
不過當時是因為自己有個上傳速度夠快的環境所以架站很方便，這個網站也隨著這樣的環境消失而消失了。
後來我找了幾個免費的網路硬碟服務想看看有沒有能方便使用，限制的部份與我的使用習慣較不抵觸的環境，但一直都沒有結論。
最近分享照片時我心血來潮又找了一回，發現4shared的網路評價不錯，限制又比較符合我所想的。
除了網頁上傳下載外，它自己也有提供上傳下載的程式可用(連手機版的都有，可惜還沒有Android版)~
我試了一下還滿好用的，不過網路上對程式版使用這部份的網路教學好像沒看到，所以我就乾脆自己寫。
希望有要分享照片的朋友能學會使用，以後就不用MSN傳半天傳不到我手裡了。

以下我分成三部份來跟大家介紹這個網路硬碟的桌面程式使用方式

服務限制
桌面程式安裝與帳號申請
上傳教學
下載教學

服務限制

在大家很開心的分享檔案之前，我建議還是要看一下免費帳號的限制，免得被砍帳號都不知道：

三十天內沒登入，你就會被砍帳號與檔案。只要你沒被砍帳號，檔案都有效~
(基本上我想分享檔案後30天內大概想要檔案的人都抓完了，所以真的被砍帳號下回要分享時再申請一次帳號就不成問題了)
空間限制：每個帳號10G，上傳的一個檔案上限200MB(付費帳號就不同了)

完整內容請參考官方的使用條款

桌面程式安裝與帳號申請

到http://www.4shared.com/首頁的下載4shared 桌面程式，下載完後開使安裝

安裝過程中有出現是不是要安裝Tool bar，這個看個人，我圖上的操作是不安裝

安裝完成後啟動程式

程式剛啟動時回讓你選【我是4Shared新手】，就是要註冊一個帳號。註冊時選擇計劃【Free】就是免費帳號

或是你已經有帳號就選登錄現有帳戶。
登入成功後，會顯示使用提示，然後告訴你它有個同步用的資料夾讓你可以指定，這些看看就選跳過與結束就可以了，這看個人使用需求自己玩玩看吧。

上傳教學

上傳的時候壓縮時選一下分割檔為200Mb，這樣上傳才不會失敗。
然後在右下角的上傳區選擇要上傳的檔案(也可以點upload鈕選檔案或目錄)
選好檔案就會看到它開始上傳了
上傳完成就會出現在上面的區塊，這時想要把上傳的檔案分享給別人，只要右鍵選獲得鍊結
然後選擇下面的連結，再點複製，就會得到檔案連結，就可以把這個下載連結告訴要分享的人囉。

下載教學

(最近發現JDownloader這個工具可以很方便的下載4Shared的檔案，教學與下載文可參考[下載&教學] JDownloader 0.9.581 中文免安裝版 ~ 最強的免費空間下載器 by 海芋)

拿到別人分享的連結一打開，就會出現這個畫面。這時你有兩種下載的方式：
第一種就是選【現在下載】(這個方式要等倒數，沒耐心請直接往下看第二種方式)
就會進到一個倒數的畫面
倒數結束就會出現【現在下載檔案】可以點選下載。
第二種就是點選加到我的帳戶(如果檔案本來就是你的就沒這項，你就直接到程式介面就能下載了)
然後沒登入的話就會要你登入，登入後會看到一個網頁版的檔案管理畫面，不過我們要下載是用程式下載，所以回到桌面程式畫面。
這時如果你的檔案中沒出現剛才的檔案就右鍵選單選【Reflash】
然後就可以選想下載的檔案來下載了。
第一次下載會問你要下載到哪
這就是下載中的樣子

總結

上手後就超簡單的，當然如果不安裝桌面程式的人也可以用網頁登入管理檔案或是找免安裝版的來用

[Java]Http Get與Post函式(Apache HttpClient)

2010-03-29T23:27:00.000-07:00

序言

要達到基本的Http get與post方法取得網站內容，Java內的URLConnection就可以達成。
但我實作時發現它太過於底層，以致於我不知該如何做到關於Session狀態的延續，也就是不能夠在完成登入後，保留住登入狀態然後進入下個動作。
於是就尋求別的作法，最後發現了Apache有提供了HttpClient套件的JAR檔，能讓我們用更簡單的方式達成工作。
在此參考網路上的文章：用HttpClient來模擬瀏覽器GET,POST，加上可自動轉導的功能，包成函式。
另外再加上可用三種類型來設定傳遞的參數，並控制其連線與中斷狀態。

下載套件

到HttpClient Download下載套件，選擇Binary with dependencies的版本(如4.0.1.zip)，
我們需要的JAR在該壓縮檔中的lib目錄下。會用到的JAR檔有三個：

commons-logging-1.1.1.jar
httpclient-4.0.1.jar
httpcore-4.0.1.jar

函式原始碼

參數轉換函式

package common.control;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.HashMap;

public class HTTPParseFunc {

 /**
  * hashMapToString
  * 
  * @param map
  * @param charset編碼
  *            ，如HTTP.UTF_8
  * @return
  * @throws UnsupportedEncodingException
  */
 @SuppressWarnings("unchecked")
 public static String hashMapToString(HashMap<String, String> map,
   String charset) throws UnsupportedEncodingException {
  StringBuffer result = new StringBuffer();
  java.util.Iterator it = map.entrySet().iterator();
  boolean isfirst = true;
  while (it.hasNext()) {
   java.util.Map.Entry entry = (java.util.Map.Entry) it.next();
   if (isfirst) {
    isfirst = false;
   } else {
    result.append("&");
   }
   result
     .append(URLEncoder.encode(entry.getKey().toString(),
       charset));
   result.append("=");
   result.append(URLEncoder.encode(entry.getValue().toString(),
     charset));
  }
  return result.toString();
 }
 /**
  * 將inputStream轉為String
  * 
  * @param is
  *            inputStream
  * @param charset
  *            編碼，如HTTP.UTF_8
  * @return inputStream的內容
  * @throws UnsupportedEncodingException
  */
 public static String inputStream2String(InputStream is, String charset)
   throws UnsupportedEncodingException {
  BufferedReader in = new BufferedReader(new InputStreamReader(is,
    charset));
  StringBuffer buffer = new StringBuffer();
  String line = "";
  try {
   boolean isfirst = true;
   while ((line = in.readLine()) != null) {
    if (!isfirst) {
     buffer.append("\n");
    } else {
     isfirst = false;
    }
    buffer.append(line);
   }
  } catch (IOException e) {
   e.printStackTrace();
  }

  return buffer.toString();
 }

 /**
  * HTTP 傳輸參數分割
  * @param param 如name1=value1&name2=value2
  * @return
  * @throws UnsupportedEncodingException
  */
  public static ArrayList<String[]> paramToArray(String param)
    throws UnsupportedEncodingException {
   ArrayList<String[]> arr = null;
   String[] p = param.split("&");
   if (param.toLowerCase().contains("&amp;")) {
    ArrayList<String> p2 = new ArrayList<String>();
    int j = 0;
    for (int i = 0; i < p.length; i++) {
     if (p[i].toLowerCase().startsWith("amp;")) {
      p2.set(j - 1, p2.get(j - 1) + "&amp;" + p[i].substring(4));
      j--;
     }
     p2.add(p[i]);
     j++;
    }
    p2.toArray(p);
   }

   for (int i = 0; i < p.length; i++) {
    String[] item = p[i].split("=");
    if (item.length == 2) {
     if (arr == null)
      arr = new ArrayList<String[]>();
     // item[0]=URLDecoder.decode(item[0],charset);
     // item[1]=URLDecoder.decode(item[1],charset);
     arr.add(item);
    }
   }
   return arr;
  }
}

HTTP連線函式

package common;

import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.util.HashMap;
import java.util.List;

import org.apache.http.Header;
import org.apache.http.HttpEntity;
import org.apache.http.HttpHost;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpUriRequest;
import org.apache.http.conn.params.ConnRoutePNames;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.params.HttpConnectionParams;
import org.apache.http.params.HttpParams;

import common.control.HTTPParseFunc;

public class HTTPBaseIO {
 public enum Method {
  get, post
 }

 private DefaultHttpClient httpclient = null;
 private boolean isClosedConn = false;
 private String newuri = null;
 private int statuscode = HttpStatus.SC_NO_CONTENT;

 private HttpHost proxy = null;

 private Integer timeout=null;
 
 public HTTPBaseIO(){
  
 }
 public HTTPBaseIO(String proxyIP,int proxyPort){
  setProxy(proxyIP,proxyPort);
 }
 public HTTPBaseIO(HttpHost proxy){
  setProxy(proxy);
 }
 
 /**
  * 取得使用的proxy
  */
 public HttpHost getProxy() {
  return proxy;
 }

 /**
  * 設定proxy
  */
 public void setProxy(HttpHost proxy) {
  this.proxy = proxy;
 }

 /**
  * 設定proxy
  * 
  * @param ip
  *            proxy的IP(hostname)
  * @param port
  *            proxy的Port
  */
 public void setProxy(String ip, int port) {
  if(ip!=null)
   proxy = new HttpHost(ip, port);
 }

 /**
  * 取得回應後所得到的代碼，可參考org.apache.http.HttpStatus類別
  * 
  * @return org.apache.http.HttpStatus
  */
 public int getStatuscode() {
  return statuscode;
 }

 /**
  * 如果是轉導的狀態所得到的URI
  * 
  * @return
  */
 public String getNewuri() {
  return newuri;
 }

 public void resetNewuri() {
  newuri = null;
 }

 /**
  * 取得連線物件
  * 
  * @return
  */
 public DefaultHttpClient getHttpclient() {
  return httpclient;
 }

 /**
  * 設定連線物件
  * 
  * @param httpclient
  */
 public void setHttpclient(DefaultHttpClient httpclient) {
  this.httpclient = httpclient;
 }

 /**
  * 是否已關閉連線
  * 
  * @return
  */
 public boolean isClosedConn() {
  return isClosedConn;
 }

 /**
  * 關閉連線
  */
 public void closeConn() {
  closeConn(true);
 }

 /**
  * 關閉連線
  * 
  * @param isCloseConn
  *            是否關閉
  */
 public void closeConn(boolean isCloseConn) {
  if (isCloseConn && httpclient != null && !isClosedConn) {
   httpclient.getConnectionManager().shutdown();
   httpclient = null;
   isClosedConn = true;
  }
 }

 public void setHttpConnectionFactoryTimeout(Integer milliseconds){
  timeout=milliseconds;
 }
 
 /**
  * 取得網頁內容
  * 
  * @param urlpath
  *            網址
  * @param method
  *            Method.get or Method.post
  * @param params
  *            參數
  * @param charset
  *            編碼，如HTTP.UTF_8
  * @param isAutoRedirect
  *            如果網頁回應狀態為轉導到新網頁，且Header的location有值，則自己以location所指網址取得內容
  * @param isCloseConn
  *            是否關閉連線
  * @return 失敗回傳null，成功回傳網頁HTML
  * @throws ClientProtocolException
  * @throws IOException
  */
 public String doSend(String urlpath, Method method, String params,
   String charset, boolean isAutoRedirect, boolean isCloseConn)
   throws ClientProtocolException, IOException {
  return doSendBase(urlpath, method, StringToHttpEntity(params, charset),
    charset, isAutoRedirect, isCloseConn);
 }

 /**
  * 取得網頁內容
  * 
  * @param urlpath
  *            網址
  * @param method
  *            Method.get or Method.post
  * @param params
  *            參數
  * @param charset
  *            編碼，如HTTP.UTF_8
  * @param isAutoRedirect
  *            如果網頁回應狀態為轉導到新網頁，且Header的location有值，則自己以location所指網址取得內容
  * @param isCloseConn
  *            是否關閉連線
  * @return 失敗回傳null，成功回傳網頁HTML
  * @throws ClientProtocolException
  * @throws IOException
  */
 public String doSend(String urlpath, Method method,
   List<NameValuePair> params, String charset, boolean isAutoRedirect,
   boolean isCloseConn) throws ClientProtocolException, IOException {
  return doSendBase(urlpath, method, ListToHttpEntity(params, charset),
    charset, isAutoRedirect, isCloseConn);
 }

 /**
  * 取得網頁內容
  * 
  * @param urlpath
  *            網址
  * @param method
  *            Method.get or Method.post
  * @param params
  *            參數
  * @param charset
  *            編碼，如HTTP.UTF_8
  * @param isAutoRedirect
  *            如果網頁回應狀態為轉導到新網頁，且Header的location有值，則自己以location所指網址取得內容
  * @param isCloseConn
  *            是否關閉連線
  * @return 失敗回傳null，成功回傳網頁HTML
  * @throws ClientProtocolException
  * @throws IOException
  */
 public String doSend(String urlpath, Method method,
   HashMap<String, String> params, String charset,
   boolean isAutoRedirect, boolean isCloseConn)
   throws ClientProtocolException, IOException {
  return doSendBase(urlpath, method,
    HashMapToHttpEntity(params, charset), charset, isAutoRedirect,
    isCloseConn);
 }

 /**
  * 取得網頁內容
  * 
  * @param urlpath
  *            網址
  * @param method
  *            Method.get or Method.post
  * @param params
  *            參數
  * @param charset
  *            編碼，如HTTP.UTF_8
  * @param isAutoRedirect
  *            如果網頁回應狀態為轉導到新網頁，且Header的location有值，則自己以location所指網址取得內容
  * @param isCloseConn
  *            是否關閉連線
  * @return 失敗回傳null，成功回傳網頁HTML
  * @throws ClientProtocolException
  * @throws IOException
  */
 public String doSendBase(String urlpath, Method method, HttpEntity params,
   String charset, boolean isAutoRedirect, boolean isCloseConn)
   throws ClientProtocolException, IOException {
  String responseBody = null;
  HttpUriRequest httpgetpost = null;

  statuscode = HttpStatus.SC_NO_CONTENT;
  try {
   if (httpclient == null || isClosedConn())
    httpclient = new DefaultHttpClient();

   if (proxy != null)
    httpclient.getParams().setParameter(
      ConnRoutePNames.DEFAULT_PROXY, proxy);

   if(timeout!=null){
    HttpParams param = httpclient.getParams();
    HttpConnectionParams.setConnectionTimeout(param, timeout);
    HttpConnectionParams.setSoTimeout(param, timeout);
   }
    
   
   if (method == Method.post) {
    httpgetpost = new HttpPost(urlpath);
    if (params != null) {
     ((HttpPost) httpgetpost).setEntity(params);
    }
   } else {
    if (params != null) {
     urlpath += "?"
       + HTTPParseFunc.inputStream2String(params.getContent(), charset);
    }
    httpgetpost = new HttpGet(urlpath);
   }

   HttpResponse response = httpclient.execute(httpgetpost);
   statuscode = response.getStatusLine().getStatusCode();
   if ((statuscode == HttpStatus.SC_MOVED_TEMPORARILY)
     || (statuscode == HttpStatus.SC_MOVED_PERMANENTLY)
     || (statuscode == HttpStatus.SC_SEE_OTHER)
     || (statuscode == HttpStatus.SC_TEMPORARY_REDIRECT)) {
    Header header = response.getFirstHeader("location");

    if (header != null) {
     newuri = header.getValue();
     if ((newuri == null) || (newuri.equals("")))
      newuri = "/";
     if (isAutoRedirect) {
      httpgetpost.abort();
      httpgetpost = null;
      responseBody = doSendBase(newuri, Method.get, null,
        charset, true, false);
     }
    }
   } else if (statuscode == HttpStatus.SC_OK) {
    responseBody = HTTPParseFunc.inputStream2String(response.getEntity()
      .getContent(), charset);
   }
  } catch (ClientProtocolException e) {
   throw e;
  } catch (IOException e) {
   throw e;
  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   if (httpgetpost != null) {
    httpgetpost.abort();
    httpgetpost = null;
   }
   closeConn(isCloseConn);
  }
  return responseBody;
 }

 /**
  * List<NameValuePair>轉為HttpEntity
  * 
  * @param nvps
  * @param charset
  *            編碼，如HTTP.UTF_8
  * @return
  * @throws UnsupportedEncodingException
  */
 public static HttpEntity ListToHttpEntity(List<NameValuePair> nvps,
   String charset) throws UnsupportedEncodingException {
  HttpEntity result = null;
  if (nvps != null && nvps.size() > 0) {
   result = new UrlEncodedFormEntity(nvps, charset);

  }
  return result;
 }

 /**
  * String to HttpEntity(
  * 
  * @param nvps
  * @param charset
  *            編碼，如HTTP.UTF_8
  * @return
  * @throws UnsupportedEncodingException
  */
 public static HttpEntity StringToHttpEntity(String nvps, String charset)
   throws UnsupportedEncodingException {
  HttpEntity result = null;
  if (nvps != null) {
   StringEntity reqEntity = new StringEntity(nvps, charset);
   reqEntity.setContentType("application/x-www-form-urlencoded");
   result = reqEntity;
  }
  return result;
 }

 /**
  * HashMap To HttpEntity
  * 
  * @param nvps
  * @param charset
  *            編碼，如HTTP.UTF_8
  * @return
  * @throws UnsupportedEncodingException
  */
 public static HttpEntity HashMapToHttpEntity(HashMap<String, String> nvps,
   String charset) throws UnsupportedEncodingException {
  HttpEntity result = null;
  if (nvps != null) {
   result = new StringEntity(HTTPParseFunc.hashMapToString(nvps, charset), charset);
   try {
    result = StringToHttpEntity(HTTPParseFunc.inputStream2String(result
      .getContent(), charset), charset);
   } catch (IllegalStateException e) {
    e.printStackTrace();
   } catch (IOException e) {
    e.printStackTrace();
   }
  }
  return result;
 }

}

使用範例程式

package common.test;

import static org.junit.Assert.*;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

import org.apache.http.NameValuePair;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import common.HTTPBaseIO;
import common.control.HTTPParseFunc;

public class HTTPBaseIOTest {

 @Before
 public void setUp() throws Exception {
 }

 @After
 public void tearDown() throws Exception {
 }

 @Test
 public void testDoGet() {
  String urltest = "http://www.google.com.tw";
  String charset = "UTF-8";
  HTTPBaseIO.Method method = HTTPBaseIO.Method.get;
  HTTPBaseIO reqClient = new HTTPBaseIO();
  try {
   String html = reqClient.doSendBase(urltest, method, null, charset,
     false, false);
   System.out.println(html);
   if (html == null)
    fail("Client get nothing");
  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   reqClient.closeConn();
  }
 }

 @Test
 public void testDoPost() {
  String urlserv1 = "http://localhost/Test1/Serv1";
  String urlserv2 = "http://localhost/Test1/Serv2";
  String charset = HTTP.UTF_8;
  HTTPBaseIO.Method method = HTTPBaseIO.Method.post;
  HTTPBaseIO reqClient = new HTTPBaseIO();
  try {
   HashMap<String, String> map = new HashMap<String, String>();
   map.put("jobname", "login");
   map.put("id", "aaa");
   map.put("pswd", "1234");
   String html = reqClient.doSend(urlserv1, method, map, charset,
     false, false);
   System.out.println(html);

   ArrayList<String[]> arr = HTTPParseFunc.paramToArray(html);
   for (int i = 0; i < arr.size(); i++)
    System.out.println(arr.get(i)[0] + "=" + arr.get(i)[1]);
   if (html == null)
    fail("Login get nothing");

   String param = "jobname=getname";
   html = reqClient.doSend(urlserv1, method, param, charset, false,
     false);
   System.out.println(html);
   if (html == null)
    fail("getname get nothing");

   List<NameValuePair> nvps = new ArrayList<NameValuePair>();
   nvps.add(new BasicNameValuePair("jobname", "loadserv2"));
   nvps.add(new BasicNameValuePair("name", "aaa"));
   reqClient.resetNewuri();
   html = reqClient.doSend(urlserv1, method, nvps, charset, true,
     false);
   if (html == null)
    fail("loadserv2 get nothing");
   nvps.clear();
   if (reqClient.getNewuri() != null && html != null) {
    nvps.add(new BasicNameValuePair("jobname", "getname2"));
    html = reqClient.doSend(urlserv2, method, nvps, charset, false,
      false);
    System.out.println(html);
    if (html == null)
     fail("Name get nothing");
    nvps.clear();
   }
   nvps.clear();

   nvps.add(new BasicNameValuePair("jobname", "Logout"));
   html = reqClient.doSend(urlserv1, method, nvps, charset, false,
     false);
   System.out.println(html);
   if (html == null)
    fail("Logout get nothing");
   nvps.clear();
  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   reqClient.closeConn();
  }
 }

}

總結

在範例的地方我假設了兩個servlet用來接收傳遞的參數，這部份可能不能直接執行，不過函式我測試過是沒問題的。
使用時可選擇用Hashmap、String、或是List作為參數設定，我分別在範例中都使用過了。
轉跳時可用getNewuri函式來確認是否有取得轉跳的網址，用回傳的html來確認是否有抓到回應的內容。
PS.我發現了Apache提供的這個Client在Windows下會有連線數上限的問題(聽說好像調整XP連線數可以解決)。

[JBoss]Java的工作排程套件-Quartz

2010-03-04T00:40:00.000-08:00

序言

作為一個Application Server，JBoss裡的應用程式開發起來主要都是被動的等待Client呼叫啟動。但實際應用上還是有可能需要有個程序能夠在特定時間執行某些命令，例如於午夜12點整進行資料的Reset這種工作。
在不依賴作業系統或是另外執行一支程式處裡工作的狀況，其實JBoss預設就有推薦使用的工作排程套件-Quartz。
就Quartz的功能而言，有的功能是與Java內建的Timer重複的，但它功能更多更強大，所以相對的要做一些設定才能使用。
以下我就舉幾個我用的方法來一探Quartz的設定(當然，這不見得是最好的作法)。

開發環境

Java Runtime: JDK 6 update 17
Java IDE: Eclipse Java EE IDE for Web Developers
Application Server: JBoss 5.1.0 GA
Quartz：1.7.3

JBoss設定

JBoss內建就有Quartz的套件，但版本很老舊，從網路上得到的資訊來看，可能會有一些問題存在。
因此建議的作法是把內建的套件刪除掉，換上新的版本。

刪除Jboss下common\lib\目錄的quartz.jar檔
刪除Jboss下server發佈目錄下的quartz-ra.rar，如jboss\server\default\deploy目錄的quartz-ra.rar
quartz套件的壓縮檔打開，將裡面的quartz-all-1.7.3.jar檔案複製到jboss\common\lib(或jboss\server\default\lib)

Quartz設定檔

Quartz 提供了兩種不同的方式用來把排程工作存在記憶體(RAMJobStore)或資料庫(JDBCJobStore。)中。

RAMJobStore:是預設的方法，因為所有資料都存在記憶體中，所以速度最快，但是如果伺服器停止後，所有排程的工作都會消失
JDBCJobStore:透過 JDBC 把所有工作排成資訊存在資料庫中，但代價就是效能降低和設定複雜度的提高(尤其是有參數要透過JobDataMap在工作執行時使用時)。

在這邊我使用最簡單的RAMJobStore來進行工作排程。
這時會需要建立一個設定檔【quartz-service.xml】來設定工作排程套件的參數。這個檔案會放在JBoss的發佈目錄下，如jboss\server\default\deploy

<?xml version="1.0" encoding="UTF-8"?>

<server>

        <mbean code="org.quartz.ee.jmx.jboss.QuartzService" name="user:service=QuartzService,name=QuartzService">
            <attribute name="JndiName">Quartz</attribute>
            <attribute name="StartScheduler">true</attribute>
            <attribute name="Properties">
                org.quartz.scheduler.instanceName = DefaultQuartzScheduler
                org.quartz.scheduler.rmi.export = false
                org.quartz.scheduler.rmi.proxy = false
                org.quartz.scheduler.xaTransacted = false
                
                org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
                org.quartz.threadPool.threadCount = 5
                org.quartz.threadPool.threadPriority = 4

                org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore     
            </attribute>
        </mbean>

</server>

工作類別

工作要執行的內容必須實作【org.quartz.Job】介面，如

package control;

import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class MyJob implements Job {
 static int jobs=0;
 @Override
 public void execute(JobExecutionContext arg0) throws JobExecutionException {
  JobDataMap dataMap = arg0.getJobDetail().getJobDataMap();
  Object data1 =dataMap.get("data1");
  Object data2 =dataMap.get("data2");
  System.out.println("Start MyJob");
  System.out.println("data1="+data1);
  System.out.println("data2="+data2);
 }

}

排程工作

排程的方式有兩種，一種是設定多久執行工作一次(SimpleTrigger)，一種是設定什麼時間要執行工作一次(CronTrigger)。

兩者最主要差別在於描述方式。相同的是兩者都可以設定排程啟動時間，結束時間，重複次數等設定。

使用SimpleTrigger

 String groupName = "Default";  //工作群組
 String jobName = "MySimpleJob"; //工作名稱
 InitialContext ctx;
 ctx = new InitialContext();
 Scheduler scheduler = (Scheduler) ctx.lookup("Quartz");
 //如果工作已排程，則刪除同樣工作群組-工作名稱的工作
 if (scheduler.getJobDetail(jobName, groupName) != null) {
  scheduler.deleteJob(jobName, groupName);
 }
 JobDetail jobDetail = new JobDetail(jobName, groupName,MyJob.class); //設定工作執行的類別為MyJob
 //設定要傳給工作的參數
 jobDetail.getJobDataMap().put("data1", "Job1");
 jobDetail.getJobDataMap().put("data2", jobName);
 SimpleTrigger simpleTrigger = new SimpleTrigger(jobName, groupName); //Trigger也會設定群組與名稱，但我不確定是有什麼功用
 simpleTrigger.setRepeatCount(-1);          //設定-1無限次重複，如果設為0則就只會執行一次
 simpleTrigger.setRepeatInterval(15*60*1000);       //每15分鐘做一次
 
 Calendar curCal = Calendar.getInstance();
 curCal.add(Calendar.MINUTE, 10);
 simpleTrigger.setStartTime(curCal.getTime()); //現在時間的10分鐘後啟動工作，如果不設定的話排程開始就會執行第一次
 
 scheduler.scheduleJob(jobDetail, simpleTrigger);
 if (!scheduler.isShutdown()) {
  scheduler.start();
 }

使用CronTrigger

 String groupName = "Default";  //工作群組
 String jobName = "MyCronJob"; //工作名稱
 InitialContext ctx;
 ctx = new InitialContext();
 Scheduler scheduler = (Scheduler) ctx.lookup("Quartz");
 //如果工作已排程，則刪除同樣工作群組-工作名稱的工作
 if (scheduler.getJobDetail(jobName, groupName) != null) {
  scheduler.deleteJob(jobName, groupName);
 }
 JobDetail jobDetail = new JobDetail(jobName, groupName,MyJob.class); //設定工作執行的類別為MyJob
 //設定要傳給工作的參數
 jobDetail.getJobDataMap().put("data1", "Job2");
 jobDetail.getJobDataMap().put("data2", jobName);
 CronTrigger trigger = new CronTrigger(jobName, groupName,"0 0 0 * * ?"); //每天0點整執行
 scheduler.scheduleJob(jobDetail, trigger);
 if (!scheduler.isShutdown()) {
  scheduler.start();
 }

在應用程式第一次被呼叫時排程工作

在Java Web Application中目前我還沒找到方法能在Jboss啟動時呼叫某個function，只能想到兩種方式當有第一個人啟動這個網站中的網頁時進行第一次的初始設定。
第一種方法是在static instance建立時在被New的物件建構函式中寫要做的工作，像是下面的程式。
但這種做法最大壞處是你沒辦法餵給它關於Web的Session、ServletContext等資訊，因為他是在Web內容還沒建立起來時就產生的。

import java.util.Calendar;

import javax.naming.InitialContext;

import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SimpleTrigger;

public class InitJob {
 private static InitJob instance=new InitJob();
 private InitJob(){
  try {
   String groupName = "Default";  //工作群組
   String jobName = "MySimpleJob"; //工作名稱
   InitialContext ctx;
   ctx = new InitialContext();
   Scheduler scheduler = (Scheduler) ctx.lookup("Quartz");
   //如果工作已排程，則刪除同樣工作群組-工作名稱的工作
   if (scheduler.getJobDetail(jobName, groupName) != null) {
    scheduler.deleteJob(jobName, groupName);
   }
   JobDetail jobDetail = new JobDetail(jobName, groupName,MyJob.class); //設定工作執行的類別為MyJob
   //設定要傳給工作的參數
   jobDetail.getJobDataMap().put("data1", "Job1");
   jobDetail.getJobDataMap().put("data2", jobName);
   SimpleTrigger simpleTrigger = new SimpleTrigger(jobName, groupName); //Trigger也會設定群組與名稱，但我不確定是有什麼功用
   simpleTrigger.setRepeatCount(-1);          //設定-1無限次重複，如果設為0則就只會執行一次
   simpleTrigger.setRepeatInterval(15*60*1000);       //每15分鐘做一次
   
   Calendar curCal = Calendar.getInstance();
   curCal.add(Calendar.MINUTE, 10);
   simpleTrigger.setStartTime(curCal.getTime()); //現在時間的10分鐘後啟動工作，如果不設定的話排程開始就會執行第一次
   
   scheduler.scheduleJob(jobDetail, simpleTrigger);
   if (!scheduler.isShutdown()) {
    scheduler.start();
   }
  } catch (Exception e) {
   System.err.println(e.getMessage());
  }
 }
}

第二種方法是在Session建立時，設定一個Static 布林變數來判斷是否是第一次啟動，然後在裡面執行要做的工作，像是下面的程式。但相對付出的代價就是每個人進來時都會判斷一次。
如果要用這種方法就要再專案的web.xml中增加listener標籤，如

<?xml version="1.0" encoding="UTF-8"?>
<web-app...>
...
  <listener>
    <listener-class>control.InitSession</listener-class>
  </listener>
...
</web-app>

程式如下

package control;

import javax.naming.InitialContext;
import javax.servlet.ServletContext;
import javax.servlet.http.HttpSession;
import javax.servlet.http.HttpSessionEvent;
import javax.servlet.http.HttpSessionListener;

import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;

public class InitSession implements HttpSessionListener {
 static boolean isInited=false;
 @Override
 public void sessionCreated(HttpSessionEvent arg0) {
  if(!isInited){
   //可取得Web相關的資訊
   ServletContext servletContext = arg0.getSession().getServletContext();
   HttpSession session = arg0.getSession();
   //工作設定
   String groupName = "Default";  //工作群組
   String jobName = "MyCronJob"; //工作名稱
   InitialContext ctx;
   ctx = new InitialContext();
   Scheduler scheduler = (Scheduler) ctx.lookup("Quartz");
   //如果工作已排程，則刪除同樣工作群組-工作名稱的工作
   if (scheduler.getJobDetail(jobName, groupName) != null) {
    scheduler.deleteJob(jobName, groupName);
   }
   JobDetail jobDetail = new JobDetail(jobName, groupName,MyJob.class); //設定工作執行的類別為MyJob
   //設定要傳給工作的參數
   jobDetail.getJobDataMap().put("data1", "Job2");
   jobDetail.getJobDataMap().put("data2", jobName);
   CronTrigger trigger = new CronTrigger(jobName, groupName,"0 0 0 * * ?"); //每天0點整執行
   scheduler.scheduleJob(jobDetail, trigger);
   if (!scheduler.isShutdown()) {
    scheduler.start();
   }
   isInited=true;
  }
 }

 @Override
 public void sessionDestroyed(HttpSessionEvent arg0) {  
 }
}

總結

以上就是在JBoss上面我使用Quartz的使用經驗，至於是否有更好的作法或是我的作法有什麼缺陷，歡迎留言告訴我，謝謝

參考資料

官方文件
關於Trigger的簡體中文說明 by 孺子牛

[Java]MySQL/Oracle資料庫存取函式

2010-02-01T01:32:00.000-08:00

序言

延續上一篇，這篇針對MySQL資料庫的存取寫出的函式提供給大家參考，開發環境與資料庫連接器的設定可參考上一篇。
我在這邊有兩種建立連線物件的方式，預設是來自JNDI的連線設定，另一種是直接產生的方式，可在建立物件時做選擇。
使用範例的部分我改用JUnit來進行我自己的原始碼驗證，大家可直接參考呼叫的方式。
PS.2011/6/21 更新，加入Oracle的連線方法(但分頁查詢的函式只能用在MySQL)

原始碼函式類別

package common;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

public class DBBaseIO {
 private static boolean _isDebug=false;
 public enum DBType{
  MySQL
  ,Oracle
 }
 
 public static void setDebug(boolean isDebug) {
  _isDebug = isDebug;
 }

 public static boolean isIsdebug() {
  return _isDebug;
 }

 private Connection con = null; // Database objects
 public Connection getConnection() {
  return con;
 }

 private Statement stat = null;
 private ResultSet rs = null;
 private PreparedStatement pst = null;
 private boolean isClosed=false;
 public boolean isClosedConn(){
  return isClosed;
 }
 
 protected void finalize ()  {
        if(!isClosed)CloseConn();
    }
 
/**
 * 建立資料庫存取物件(使用JNDI XML設定，名稱為MySqlDS)
 * @throws SQLException
 * @throws NamingException
 */
 public DBBaseIO() throws SQLException, NamingException {
  setupConnMySQLByXML();
 }
 /**
  * 建立資料庫存取物件(使用JNDI XML設定)
  * @param dsName 設定名稱
  * @throws SQLException
  * @throws NamingException
  */
 public DBBaseIO(String dsName) throws SQLException, NamingException {
  setupConnMySQLByXML(dsName);
 }
 /**
  * 
  * @param sourceType
  * @throws ClassNotFoundException
  * @throws SQLException
  * @throws NamingException
  */
 public DBBaseIO(int sourceType) throws ClassNotFoundException, SQLException, NamingException{
  switch(sourceType){
   case 0:
    setupConnMySQL("localhost:3306", "root", "", "mysql");
    break;
   case 1:
    setupConnMySQLByXML();
    break;
  }  
 }
 /**
   * 建立資料庫存取物件
   * 
   * @param str_SQLIP
   *            資料庫IP
   * @param str_SQLID
   *            登入帳號
   * @param str_SQLPSWD
   *            登入密碼
   * @param str_SQLDefaultDBName
   *            預設資料庫
   * @throws SQLException 
   * @throws ClassNotFoundException 
   */
 public DBBaseIO(String str_SQLIP, String str_SQLID, String str_SQLPSWD,
   String str_SQLDefaultDBName) throws ClassNotFoundException, SQLException  {
  setupConnMySQL(str_SQLIP, str_SQLID, str_SQLPSWD, str_SQLDefaultDBName);
 }
 /**
   * 建立資料庫存取物件
   * 
   * @param dbtype
   *            資料庫類型
   * @param str_SQLIP
   *            資料庫IP
   * @param str_SQLID
   *            登入帳號
   * @param str_SQLPSWD
   *            登入密碼
   * @param str_SQLDefaultDBName
   *            預設資料庫
   * @throws SQLException 
   * @throws ClassNotFoundException 
   */
 public DBBaseIO(DBType dbtype,String str_SQLIP, String str_SQLID, String str_SQLPSWD,
   String str_SQLDefaultDBName) throws ClassNotFoundException, SQLException  {
  if(dbtype==DBType.MySQL)
   setupConnMySQL(str_SQLIP, str_SQLID, str_SQLPSWD, str_SQLDefaultDBName);
  else if(dbtype==DBType.Oracle)
   setupConnOracle(str_SQLIP, str_SQLID, str_SQLPSWD, str_SQLDefaultDBName);
  else
   throw new ClassNotFoundException("DBType un-define");
 }
 private void setupConnMySQLByXML() throws  NamingException, SQLException{setupConnMySQLByXML("MySqlDS"); }
 private void setupConnMySQLByXML(String name) throws  NamingException, SQLException{
  if(isIsdebug()){
   System.out.println("DataSource:"+"java:/" + name);
  }
  
  try{  
  InitialContext ctx = new InitialContext();
  DataSource ds = (DataSource)ctx.lookup("java:/" + name);
  con = ds.getConnection();
  } catch (NamingException e) {
   System.err.println("Connection XML Load Error :" + e.toString());
   throw e;
  } catch (SQLException e) {
   System.err.println("Get Connection Error :" + e.toString());
   throw e;
  }
 }

 private void setupConnMySQL(String str_SQLIP, String str_SQLID,
   String str_SQLPSWD, String str_SQLDefaultDBName)  throws ClassNotFoundException,SQLException {
  if(isIsdebug()){
   System.out.println("DataSource:"+"jdbc:mysql://" + str_SQLIP + "/"
     + str_SQLDefaultDBName
     + "?useUnicode=true&characterEncoding=UTF8");
   System.out.println("ID:"+str_SQLID+"\tPassword:"+str_SQLPSWD);
   System.out.println("JDBC Driver:" + "com.mysql.jdbc.Driver");
  }
  try {
   Class.forName("com.mysql.jdbc.Driver");
  
   con = DriverManager.getConnection("jdbc:mysql://" + str_SQLIP + "/"
     + str_SQLDefaultDBName
     + "?useUnicode=true&characterEncoding=UTF8", str_SQLID,
     str_SQLPSWD);
   
  } catch (ClassNotFoundException e) {
   System.err.println("DriverClassNotFound :" + e.toString());
   throw e;
  }
  catch (SQLException x) {
   System.err.println("Exception :" + x.toString());
   throw x;
  }
 }
 private void setupConnOracle(String str_SQLIP, String str_SQLID,
   String str_SQLPSWD, String str_SQLDefaultDBName)  throws ClassNotFoundException,SQLException {
  if(isIsdebug()){
   System.out.println("DataSource:"+"jdbc:oracle:thin:"+str_SQLID+"/"+str_SQLPSWD+"@//" + str_SQLIP + "/"
     + str_SQLDefaultDBName);
  }
  try {
   Class.forName("oracle.jdbc.OracleDriver");
  
   con = DriverManager.getConnection("jdbc:oracle:thin:"+str_SQLID+"/"+str_SQLPSWD+"@//" + str_SQLIP + "/"
     + str_SQLDefaultDBName);
   
  } catch (ClassNotFoundException e) {
   System.err.println("DriverClassNotFound :" + e.toString());
   throw e;
  }
  catch (SQLException x) {
   System.err.println("Exception :" + x.toString());
   throw x;
  }
 }

  /**
   * 執行insert update delete等更新指令用
   * 
   * @param str_SQL
   *            查詢語法
   * @return 資料庫變動筆數
   */
 public int executeUpdate(String str_SQL) throws SQLException,NullPointerException {
  return executeUpdate(str_SQL, null);
 }

  /**
   * 執行insert update delete等更新指令用
   * 
   * @param str_SQL
   *            查詢語法
   * @param param
   *            參數設定,SQL語法中以?指定，順序即為?的順序，如 where name=? (此參數可為null)
   * @return 資料庫變動筆數
   */
 public int executeUpdate(String str_SQL, Object[] param) throws SQLException ,NullPointerException{
  return executeUpdate(str_SQL, param, true);
 }

  /**
   * 執行insert update delete等更新指令用
   * 
   * @param str_SQL
   *            查詢語法
   * @param param
   *            參數設定,SQL語法中以?指定，順序即為?的順序，如 where name=? (此參數可為null)
   * @param isCloseConn
   *            是否關閉連線
   * @return 資料庫變動筆數
   */
 public int executeUpdate(String str_SQL, Object[] param, boolean isCloseConn) throws SQLException,NullPointerException {
  if(isIsdebug()){
   System.out.println("executeUpdate:"+str_SQL);
   if(param!=null)
   for(int i=0;i<param.length;i++)
    System.out.println("Parameter "+ i +":"+param[i]);
   System.out.println("isCloseConn :"+isCloseConn);
  }
  
  int result = 0;
  if (con != null) {
   try {
    int i = 0;
    if (param == null) {
     stat = con.createStatement();
     result = stat.executeUpdate(str_SQL);
    } else {
     pst = con.prepareStatement(str_SQL);
     for (i = 0; i < param.length; i++) {
      pst.setObject(i + 1, param[i]);
     }
     result = pst.executeUpdate();
     try {
      pst.clearParameters();
     } catch (Exception e) {
      CloseConn();
     }
    }
   } catch (SQLException e) {
    System.err.println("executeUpdate Exception :" + e.toString());
    throw e;
   } finally {
    CloseConn(isCloseConn);
   }
  } else {
   System.err.println("Connection is null");
   throw new NullPointerException("Connection is null");
  }
  return result;
 }
 
 
  /**
   * 批次執行SQL指令使用
   * 
   * @param str_SQL
   *            查詢語法的陣列
   * @param isCloseConn
   *            是否關閉連線
   * @return 資料庫變動筆數的陣列
   */
 public int[] executeBatch(String[] str_SQL, boolean isCloseConn) throws SQLException,NullPointerException {
  if(isIsdebug()){
   System.out.println("executeBatch:"+str_SQL);
  }
  
  int[] result=null;
  if (con != null) {
   try {
    int i = 0;
    stat = con.createStatement();
    for (i = 0; i < str_SQL.length; i++) {
     stat.addBatch(str_SQL[i]);
    }
    result=stat.executeBatch();
    if(isIsdebug()){
     System.out.println("executeBatch result:");
      for (i = 0; i < result.length; i++) {
       System.out.println(i+":"+result[i]);
      }
    }
   } catch (SQLException e) {
    System.err.println("executeBatch Exception :" + e.toString());
    throw e;
   } finally {
    CloseConn(isCloseConn);
   }
  } else {
   System.err.println("Connection is null");
   throw new NullPointerException("Connection is null");
  }
  return result;
 }
 
 /**
  * 批次執行SQL指令使用
  * @param str_SQL 查詢語法
  * @param param 以相同數量的參數形成的ArrayList
  * @param isCloseConn  是否關閉連線
  * @return   資料庫變動筆數的陣列
  * @throws SQLException
  * @throws NullPointerException
  */
 public int[] addBatch(String str_SQL, ArrayList<Object[]> param, boolean isCloseConn) throws SQLException,NullPointerException {

  int i = 0;
  int j = 0;
  if(isIsdebug()){
   System.out.println("executeBatch:"+str_SQL);
   if(param!=null)
    for (i = 0; i < param.size(); i++) {
     for (j = 0;j < param.get(i).length; j++) {
      System.out.println("Parameter "+ i+","+j +":"+param.get(i)[j]);
     }
    }
  }
  
  int[] result=null;
  if (con != null) {
   try {
     pst = con.prepareStatement(str_SQL);
     for (i = 0; i < param.size(); i++) {
      for (j = 0;j < param.get(i).length; j++) {
       pst.setObject(j + 1, param.get(i)[j]);
      }
      pst.addBatch();
     }
     result=pst.executeBatch(); 
     if(isIsdebug()){
      System.out.println("executeBatch result:");
       for (i = 0; i < result.length; i++) {
        System.out.println(i+":"+result[i]);
       }
     }
   } catch (SQLException e) {
    System.err.println("executeBatch Exception :" + e.toString());
    throw e;
   } finally {
    CloseConn(isCloseConn);
   }
  } else {
   System.err.println("Connection is null");
   throw new NullPointerException("Connection is null");
  }
  
  return result;
 }
 
  /**
   * 查詢資料
   * 
   * @param str_SQL
   *            查詢語法
   * @return 每列一筆資料，每筆資料的欄位存於 Object Array中
   */
 public ArrayList<Object[]> executeQuery(String str_SQL) throws SQLException,NullPointerException {
  return executeQuery(str_SQL, null);
 }
  /**
   * 查詢資料
   * 
   * @param str_SQL
   *            查詢語法
   * @param param
   *            參數設定,SQL語法中以?指定，順序即為?的順序，如 where name=? (此參數可為null)
   * @return 每列一筆資料，每筆資料的欄位存於 Object Array中
   */
 public ArrayList<Object[]> executeQuery(String str_SQL, Object[] param) throws SQLException,NullPointerException {
  return executeQuery(str_SQL, param, true);
 }

  /**
   * 查詢資料
   * 
   * @param str_SQL
   *            查詢語法
   * @param param
   *            參數設定,SQL語法中以?指定，順序即為?的順序，如 where name=? (此參數可為null)
   * @param isCloseConn
   *            是否關閉連線
   * @return 每列一筆資料，每筆資料的欄位存於 Object Array中
   */
 public ArrayList<Object[]> executeQuery(String str_SQL, Object[] param,
   boolean isCloseConn) throws SQLException,NullPointerException {
  if(isIsdebug()){
   System.out.println("executeQuery:"+str_SQL);
   if(param!=null)
   for(int i=0;i<param.length;i++)
    System.out.println("Parameter "+ i +":"+param[i]);
   System.out.println("isCloseConn :"+isCloseConn);
  }
  ArrayList<Object[]> result = new ArrayList<Object[]>();
  if (con != null) {
   try {
    int i = 0;
    if (param == null) {
     stat = con.createStatement();
     rs = stat.executeQuery(str_SQL);
    } else {
     pst = con.prepareStatement(str_SQL);
     for (i = 0; i < param.length; i++) {
      pst.setObject(i + 1, param[i]);
     }
     rs = pst.executeQuery();
     pst.clearParameters();
    }

    ArrayList<Object> arr;
    ResultSetMetaData rsMetaData = rs.getMetaData();
    int numberOfColumns = rsMetaData.getColumnCount();
    while (rs.next()) {
     arr = new ArrayList<Object>();
     for (i = 1; i < numberOfColumns + 1; i++) {
      arr.add(rs.getObject(i));
     }
     result.add(arr.toArray());
    }
   } catch (SQLException e) {
    System.err.println("executeQuery Exception :" + e.toString());
    throw e;
   } finally {
    CloseConn(isCloseConn);
   }
  } else {
   System.err.println("Connection is null");
   throw new NullPointerException("Connection is null");
  }
  return result;
 }

  /**
   * 查詢資料(請記得要關閉Result Set)
   * 
   * @param str_SQL
   *            查詢語法
   * @return 回傳查詢得到的result set
   */
 public ResultSet executeQueryResultset(String str_SQL) throws SQLException,NullPointerException {
  return executeQueryResultset(str_SQL,null);
 }
  /**
   * 查詢資料(請記得要關閉Connection)
   * 
   * @param str_SQL
   *            查詢語法
   * @param param
   *            參數設定,SQL語法中以?指定，順序即為?的順序，如 where name=? (此參數可為null)
   * @return 回傳查詢得到的result set
   */
 public ResultSet executeQueryResultset(String str_SQL, Object[] param) throws SQLException,NullPointerException {
  if(isIsdebug()){
   System.out.println("executeQuery:"+str_SQL);
   if(param!=null)
   for(int i=0;i<param.length;i++)
    System.out.println("Parameter "+ i +":"+param[i]);
  }
  
  ResultSet result = null;
  if (con != null) {
   try {
    int i = 0;
    if (param == null) {
     stat = con.createStatement();
     rs = stat.executeQuery(str_SQL);
    } else {
     pst = con.prepareStatement(str_SQL);
     for (i = 0; i < param.length; i++) {
      pst.setObject(i + 1, param[i]);
     }
     rs = pst.executeQuery();
     pst.clearParameters();
    }

    result=rs;
   } catch (SQLException e) {
    System.err.println("executeQueryResultset Exception :" + e.toString());
    throw e;
   }
  } else {
   System.err.println("Connection is null");
   throw new NullPointerException("Connection is null");
  }
  return result;
 }
 
 /**
   * 查詢資料，並傳回查詢所傳回的結果集第一個資料列的第一個資料行
   * 
   * @param str_SQL
   *            查詢語法
   * @return 每列一筆資料，每筆資料的欄位存於 Object Array中
   */
 public Object executescalar(String str_SQL) throws SQLException,NullPointerException {
  return executescalar(str_SQL, null);
 }
 /**
   * 查詢資料，並傳回查詢所傳回的結果集第一個資料列的第一個資料行
   * 
   * @param str_SQL
   *            查詢語法
   * @param param
   *            參數設定,SQL語法中以?指定，順序即為?的順序，如 where name=? (此參數可為null)
   * @return 每列一筆資料，每筆資料的欄位存於 Object Array中
   */
 public Object executescalar(String str_SQL, Object[] param) throws SQLException,NullPointerException {
  return executescalar(str_SQL, param, true);
 }

 /**
   * 查詢資料，並傳回查詢所傳回的結果集第一個資料列的第一個資料行
   * 
   * @param str_SQL
   *            查詢語法
   * @param param
   *            參數設定,SQL語法中以?指定，順序即為?的順序，如 where name=? (此參數可為null)
   * @param isCloseConn
   *            是否關閉連線
   * @return 每列一筆資料，每筆資料的欄位存於 Object Array中
   */
 public Object executescalar(String str_SQL, Object[] param,
   boolean isCloseConn) throws SQLException,NullPointerException {
  if(isIsdebug()){
   System.out.println("executeQuery:"+str_SQL);
   if(param!=null)
   for(int i=0;i<param.length;i++)
    System.out.println("Parameter "+ i +":"+param[i]);
   System.out.println("isCloseConn :"+isCloseConn);
  }
  Object result = null;
  if (con != null) {
   try {
    int i = 0;
    if (param == null) {
     stat = con.createStatement();
     rs = stat.executeQuery(str_SQL);
    } else {
     pst = con.prepareStatement(str_SQL);
     for (i = 0; i < param.length; i++) {
      pst.setObject(i + 1, param[i]);
     }
     rs = pst.executeQuery();
     pst.clearParameters();
    }

    ResultSetMetaData rsMetaData = rs.getMetaData();
    int numberOfColumns = rsMetaData.getColumnCount();
    if (rs.next() && numberOfColumns>=1) {
     result=rs.getObject(1);
    }
   } catch (SQLException e) {
    System.err.println("executescalar Exception :" + e.toString());
    throw e;
   } finally {
    CloseConn(isCloseConn);
   }
  } else {
   System.err.println("Connection is null");
   throw new NullPointerException("Connection is null");
  }
  return result;
 }


  /**
   * 執行SQL
   * 
   * @param str_SQL
   *            查詢語法
   * @return 是否成功
   */
 public boolean execute(String str_SQL) throws SQLException,NullPointerException {
  return execute(str_SQL, null);
 }

  /**
   * 執行SQL
   * 
   * @param str_SQL
   *            查詢語法
   * @param param
   *            參數設定,SQL語法中以?指定，順序即為?的順序，如 where name=? (此參數可為null)
   * @return 是否成功
   */
 public boolean execute(String str_SQL, Object[] param) throws SQLException,NullPointerException {
  return execute(str_SQL, param, true);
 }

  /**
   * 執行SQL
   * 
   * @param str_SQL
   *            查詢語法
   * @param param
   *            參數設定,SQL語法中以?指定，順序即為?的順序，如 where name=? (此參數可為null)
   * @param isCloseConn
   *            是否關閉連線
   * @return 是否成功
   */
 public boolean execute(String str_SQL, Object[] param, boolean isCloseConn) throws SQLException,NullPointerException {
  if(isIsdebug()){
   System.out.println("executeQuery:"+str_SQL);
   if(param!=null)
   for(int i=0;i<param.length;i++)
    System.out.println("Parameter "+ i +":"+param[i]);
   System.out.println("isCloseConn :"+isCloseConn);
  }
  boolean result = false;
  if (con != null) {
   try {
    int i = 0;
    if (param == null) {
     stat = con.createStatement();
     result = stat.execute(str_SQL);
    } else {
     pst = con.prepareStatement(str_SQL);
     for (i = 0; i < param.length; i++) {
      pst.setObject(i + 1, param[i]);
     }
     result = pst.execute();
     pst.clearParameters();
    }
   } catch (SQLException e) {
    System.err.println("execute Exception :" + e.toString());
    throw e;
   } finally {
    CloseConn(isCloseConn);
   }
  } else {
   System.err.println("Connection is null");
   throw new NullPointerException("Connection is null");
  }
  return result;
 }
/**
 * 關閉連線
 */
 public void CloseConn() {
  CloseConn(true);
 }

 /**
  * 關閉連線
  * @param isCloseConn  是否關閉Connection
  */
 public void CloseConn(boolean isCloseConn) {
  if(isIsdebug()){
   System.out.println("CloseConn:"+isCloseConn);
  }
  try {
   if (rs != null) {
    rs.close();
    rs = null;
   }
   if (stat != null) {
    stat.close();
    stat = null;
   }
   if (pst != null) {
    pst.close();
    pst = null;
   }
  } catch (SQLException e) {
   //System.err.println("Close Exception :" + e.toString());
  } finally {
   try {
    if (con != null && isCloseConn) {
     con.close();
     isClosed=true;
    }
   } catch (SQLException e) {
    //System.err.println("Close Exception :" + e.toString());
   }
  }
 }
 
 
 int allpage=0;
 
 public int getAllpage() {
  return allpage;
 }
 public void setAllpage(int allpage) {
  this.allpage = allpage;
 }
 /**
  * 查詢分頁資料
  * @param colunms
  * @param from
  * @param where
  * @param group
  * @param order
  * @param fpage
  * @param pages
  * @return
  * @throws SQLException
  * @throws NullPointerException
  */
 public ArrayList<Object[]> selectPage(String colunms,String from,String where,String group,String having,String order,int fpage,int pages) throws SQLException,NullPointerException{
  return selectPage(colunms,from,where,group,having,order,fpage,pages,null);
  }
 /**
  * 查詢分頁資料
  * @param colunms
  * @param from
  * @param where
  * @param group
  * @param order
  * @param fpage
  * @param pages
  * @param param
  * @return
  * @throws SQLException
  * @throws NullPointerException
  */
 public ArrayList<Object[]> selectPage(String colunms,String from,String where,String group,String having,String order,int fpage,int pages, Object[] param) throws SQLException,NullPointerException{
  return selectPage(colunms,from,where,group,having,order,fpage,pages,param,true);
  }
/**
 * 查詢分頁資料
 * @param colunms
 * @param from
 * @param where
 * @param group
 * @param order
 * @param fpage
 * @param pages
 * @param param
 * @param isCloseConn
 * @return
 * @throws SQLException
 * @throws NullPointerException
 */
 public ArrayList<Object[]> selectPage(String colunms,String from,String where,String group,String having,String order,int fpage,int pages, Object[] param, boolean isCloseConn) throws SQLException,NullPointerException{
  return selectPage(colunms, from, where, group, having, order, fpage, pages, true, 0, param, isCloseConn);
 }
 /**
  * 查詢分頁資料
  * @param colunms
  * @param from
  * @param where
  * @param group
  * @param having
  * @param order
  * @param fpage
  * @param pages
  * @param isCountPage
  * @param allpageCount
  * @param param
  * @param isCloseConn
  * @return
  * @throws SQLException
  * @throws NullPointerException
  */
 public ArrayList<Object[]> selectPage(String colunms,String from,String where,String group,String having,String order,int fpage,int pages,boolean isCountPage,int allpageCount, Object[] param, boolean isCloseConn) throws SQLException,NullPointerException{
  ArrayList<Object[]> result=null;
  try{
   String sql;
  if(!isCountPage){
   allpage=allpageCount;
  }else{
   int intRowCount;
   sql="select count(*) from (select ";
   if(colunms!=null){
    sql+="" + colunms + " \n ";
   }else{
    sql+="* \n "; 
   }
   sql+="from " + from.toString() + " \n ";
   if(where!=null){
    sql+="where " + where + " \n ";
   }
   if(group!=null){
    sql+="group by " + group + " \n ";
   }
   if(having!=null){
    sql+="having " + group + " \n ";
   }
   sql+=") selectcount \n ";
   
   Object temp=executescalar(sql,param,false);
   if(temp==null){
    return result;
   }
   intRowCount=Integer.parseInt(temp.toString());
   allpage=(intRowCount+fpage-1) / fpage;
  }
  int spage;
  
  if(pages > allpage ){// pages == 0){
   pages = 1;
  } 
  spage=(pages-1)*fpage;  
  //sql="select " + colunms + " \n from " + from + " \n where " + where + " \n order by " + order + " \n limit "+ spage +","+fpage  ;
  sql="select ";
  if(colunms!=null){
   sql+= colunms + " \n ";
  }else{
   sql+="* \n "; 
  }
  sql+="from " + from + " \n ";
  if(where!=null){
   sql+="where " + where + " \n ";
  }
  if(group!=null){
   sql+="group by " + group + " \n ";
  }
  if(having!=null){
   sql+="having " + group + " \n ";
  }
  if(order!=null){
   sql+="order by " + order + " \n ";
  }
  sql+="limit "+ spage +","+fpage;
  result=executeQuery(sql, param, false);
  } catch (NullPointerException e) {
   System.err.println("NullPointerException Exception :" + e.toString());
   throw e;
  } catch (SQLException e) {
   System.err.println("SQLException Exception :" + e.toString());
   throw e;
  } finally {
   CloseConn(isCloseConn);
  }
  return result;
 }
 
}

使用範例程式

package common.test;

import static org.junit.Assert.*;

import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.util.ArrayList;

import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import common.DBBaseIO;

public class DBBaseIOTest {

 DBBaseIO dbio;
 int m_id;
 
 String m_name;
 @Before
 public void setUp() throws Exception {
  dbio=new DBBaseIO(0);
  m_id=20100111;
  m_name="tester" + m_id;
 }

 @After
 public void tearDown() throws Exception {
  dbio.CloseConn();
  dbio=null;
 }

 @Test
 public void testExecuteString() {
  String msg="\n# testExecuteString\n Drop and Create :\t TestTable" + m_id;
  System.out.println(msg);//DROP TABLE IF EXISTS TestTable" + m_id + "; 
  String str_Sql = "CREATE TABLE  TestTable" + m_id + " ( " + 
     "`test_id` int(10) unsigned NOT NULL auto_increment, " +
     "`member_id` int(10) unsigned NOT NULL, "+
     "`member_name` varchar(45) NOT NULL, " +
     "PRIMARY KEY  (`test_id`) "+
   ") ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8; ";
  try{
   dbio.execute(str_Sql);
   
  }catch(Exception e){
   fail(msg + "\n\n" + str_Sql + "\n\nResult:" + e.getMessage());
  }
 }
 
 @Test
 public void testExecuteUpdateString() {
  String msg="\n# testExecuteUpdateString\n Insert :\tID=" + m_id + "\tName=" + m_name;
  System.out.println(msg);
  String str_Sql="Insert into TestTable" + m_id + " (member_id,member_name) values('" + m_id + "','" + m_name + "')";
  try{
   int result=dbio.executeUpdate(str_Sql);
   if(result<=0){
    fail(msg + "\n\n" + str_Sql + "\n\nResult:" + result);
   }
  }catch(Exception e){
   fail(msg + "\n\n" + str_Sql + "\n\nResult:" + e.getMessage());
  }  
 }

 @Test
 public void testExecuteQueryString() {
  String msg="\n# testExecuteQueryString\n Select ALL :";
  System.out.println(msg);
  String str_Sql="Select * from TestTable" + m_id + "";
  try{
   ArrayList<Object[]> result=dbio.executeQuery(str_Sql);
   if(result.size()<=0){
    fail(msg + "\n\n" + str_Sql + "\n\nResult:" + result);
   }else{
    for(int i=0;i<result.size();i++){
     for(int j=0;j<result.get(i).length;j++){
      System.out.print(result.get(i)[j] + "\t");
     }
     System.out.println();
    }
   }
  }catch(Exception e){
   fail(msg + "\n\n" + str_Sql + "\n\nResult:" + e.getMessage());
  }
 }

 @Test
 public void testexecuteQueryResultset() {
  String msg="\n# testexecuteQueryResultset\n Select ALL :";
  System.out.println(msg);
  String str_Sql="Select * from TestTable" + m_id + "";
  try{
   
   ResultSet rs=dbio.executeQueryResultset(str_Sql);
   ResultSetMetaData rsMetaData = rs.getMetaData();
   int numberOfColumns = rsMetaData.getColumnCount();
   while (rs.next()) {
    for (int i = 1; i < numberOfColumns + 1; i++) {
     System.out.print(rs.getObject(i) + "\t");
    }
    System.out.println();
   }
   
   dbio.CloseConn();
  }catch(Exception e){
   fail(msg + "\n\n" + str_Sql + "\n\nResult:" + e.getMessage());
  }
 }
 
 @Test
 public void testselectPage() {
  String msg="\n# testselectPage\n Insert 98 User";
  System.out.println(msg);
  String str_Sql="";
  try{
   
   for(int i=1;i<=98;i++){
    str_Sql="Insert into TestTable" + m_id + " (member_id,member_name) values('" + m_id  + i + "','" + m_name + "_" + i + "')";
    int result=dbio.executeUpdate(str_Sql,null,false);
    if(result<=0){
     fail(msg + "\n\n" + str_Sql + "\n\nResult:" + result);
    }
   }
   str_Sql="";
   ArrayList<Object[]> result=dbio.selectPage("member_id,member_name", "TestTable" + m_id, null, "member_id", 10, 10, null, true);
   if(result.size()<=0){
    fail(msg + "\n\n" + str_Sql + "\n\nResult:" + result);
   }else{
    for(int i=0;i<result.size();i++){
     for(int j=0;j<result.get(i).length;j++){
      System.out.print(result.get(i)[j] + "\t");
     }
     System.out.println();
    }
   }
  }catch(Exception e){
   fail(msg + "\n\n" + str_Sql + "\n\nResult:" + e.getMessage());
  }
  
  
 }
 

 @Test
 public void testExecuteUpdateStringObjectArray() {
  m_name+="_Updateed";
  String msg="\n# testExecuteUpdateStringObjectArray\n Update :\tID=" + m_id + "\tName=" + m_name;
  System.out.println(msg);
  String str_Sql="Update TestTable" + m_id + " Set member_name=? WHERE member_id=?";
  Object[] param={m_name,m_id};
  try{
   int result=dbio.executeUpdate(str_Sql,param);
   if(result<=0){
    fail(msg + "\n\n" + str_Sql + "\n\nResult:" + result);
   }
  }catch(Exception e){
   fail(msg + "\n\n" + str_Sql + "\n\nResult:" + e.getMessage());
  }  
 }

 @Test
 public void testExecuteQueryStringObjectArray() {
  String msg="\n# testExecuteQueryStringObjectArray\n Select :\tID=" + m_id;
  System.out.println(msg);
  String str_Sql="Select * from TestTable" + m_id + " where member_id=?";
  Object[] param={m_id}; 
  try{
   ArrayList<Object[]> result=dbio.executeQuery(str_Sql,param);
   if(result.size()<=0){
    fail(msg + "\n\n" + str_Sql + "\n\nResult:" + result);
   }else{
    for(int i=0;i<result.size();i++){
     for(int j=0;j<result.get(i).length;j++){
      System.out.print(result.get(i)[j] + "\t");
     }
     System.out.println();
    }
   }
  }catch(Exception e){
   fail(msg + "\n\n" + str_Sql + "\n\nResult:" + e.getMessage());
  }
 }

 @Test
 public void testExecuteUpdateStringObjectArrayBoolean() {
  String msg="\n# testExecuteUpdateStringObjectArrayBoolean\n Delete :\tID=" + m_id + "\tName=" + m_name;
  System.out.println(msg);
  String str_Sql="Delete from TestTable" + m_id + " WHERE member_id=?";
  Object[] param={m_id};
  try{
   int result=dbio.executeUpdate(str_Sql,param,false);
   if(result<=0){
    fail(msg + "\n\n" + str_Sql + "\n\nResult:" + result);
   }
  }catch(Exception e){
   fail(msg + "\n\n" + str_Sql + "\n\nResult:" + e.getMessage());
  }finally{
   dbio.CloseConn();
  }
 }

 @Test
 public void testExecuteQueryStringObjectArrayBoolean() {
  String msg="\n# testExecuteQueryStringObjectArrayBoolean\n Select :\tID=" + m_id;
  System.out.println(msg);
  String str_Sql="Select * from TestTable" + m_id + " where member_id=?";
  Object[] param={m_id};
  try{
   ArrayList<Object[]> result=dbio.executeQuery(str_Sql,param,false);
   if(result.size()>0){
    for(int i=0;i<result.size();i++){
     for(int j=0;j<result.get(i).length;j++){
      System.out.print(result.get(i)[j] + "\t");
     }
     System.out.println();
    }
    fail(msg + "\n\n" + str_Sql + "\n\nResult:" + result);
   }
  }catch(Exception e){
   fail(msg + "\n\n" + str_Sql + "\n\nResult:" + e.getMessage());
  }finally{
   dbio.CloseConn();
  }
 }



 

 @Test
 public void testExecuteStringObjectArrayBoolean() {
  String msg="\n# testExecuteStringObjectArrayBoolean\n Drop :\t TestTable_" + m_id;
  System.out.println(msg);
  String str_Sql="DROP TABLE IF EXISTS TestTable" + m_id + ";" ;
  
  try{
   dbio.execute(str_Sql,null,false);
   
  }catch(Exception e){
   fail(msg + "\n\n" + str_Sql + "\n\nResult:" + e.getMessage());
  }finally{
   dbio.CloseConn();
  }
 }

 

}

總結

我在開發時採用ArrayList把資料給回傳回來，因此相反的就沒有辦法回傳欄位名稱(不過我想你在寫SQL時應該已經可以指定自己要用的欄位名稱了吧)。

[程式]VB.Net2.0資料庫通用存取函式

[JAAS] JBoss下動態網站使用資料庫設定認證授權

2010-01-25T01:06:00.000-08:00

序言

雖說我以前一直很不想再Try Java Tool弄很久~因為開發速度還是微軟順手些，但看來我還是逃脫不了。
總之~這篇是最近我實作時的紀錄，主要是要用Java預設的安全機制，完成網站的認證授權(也就是登入登出、 Login and Logout)。
通常書到用時方恨少，這句話這時就應驗了，腦中有的資訊太少，所以這個東西花了我不少功夫。
如果有任何不標準的用法，請見諒，很多都是我從網路找來的資訊組合而成的，我很懶得去查官方的英文文件(官方文件有很多其實也沒寫的很詳細...)。
歡迎有更標準的用法的話，請留下文章、連結等資料指正我。

開發環境

Java Runtime: JDK 6 update 17
Java IDE: Eclipse Java EE IDE for Web Developers
Application Server: JBoss 5.1.0 GA
Database: MySQL 5.1.42 win32
DB Cconnector: mysql-connector-java-5.1.10

JBoss設定

資料庫連接器：將資料庫連接器【mysql-connector-java-5.1.10-bin.jar】放在Jboss的伺服器函式庫資料夾，如【jboss\server\default\lib】

資料庫連線設定：連線設定檔是用xml定義的，可直接複製JBoss提供的範本(位於【jboss\docs\examples\jca\mysql-ds.xml】)到【jboss\server\default\deploy】，並將資料庫設為你的MySQL連線設定。(如果用其他資料庫的話，在範本資料夾裡大都有範例)
這邊比較需要注意的是等下要用到的名稱

jndi-name：等下設定驗證方式時會用到的名稱，例如下面範例的【MySqlDS】

<?xml version="1.0" encoding="UTF-8"?>

<!-- See http://www.jboss.org/community/wiki/Multiple1PC for information about local-tx-datasource -->
<!-- $Id: mysql-ds.xml 88948 2009-05-15 14:09:08Z jesper.pedersen $ -->
<!--  Datasource config for MySQL using 3.0.9 available from:
http://www.mysql.com/downloads/api-jdbc-stable.html
-->

<datasources>
  <local-tx-datasource>
    <jndi-name>MySqlDS</jndi-name>
    <connection-url>jdbc:mysql://mysql-hostname:3306/jbossdb</connection-url>
    <driver-class>com.mysql.jdbc.Driver</driver-class>
    <user-name>x</user-name>
    <password>y</password>
    <exception-sorter-class-name>org.jboss.resource.adapter.jdbc.vendor.MySQLExceptionSorter</exception-sorter-class-name>
    <!-- should only be used on drivers after 3.22.1 with "ping" support
    <valid-connection-checker-class-name>org.jboss.resource.adapter.jdbc.vendor.MySQLValidConnectionChecker</valid-connection-checker-class-name>
    -->
    <!-- sql to call when connection is created
    <new-connection-sql>some arbitrary sql</new-connection-sql>
      -->
    <!-- sql to call on an existing pooled connection when it is obtained from pool - MySQLValidConnectionChecker is preferred for newer drivers
    <check-valid-connection-sql>some arbitrary sql</check-valid-connection-sql>
      -->

    <!-- corresponding type-mapping in the standardjbosscmp-jdbc.xml (optional) -->
    <metadata>
       <type-mapping>mySQL</type-mapping>
    </metadata>
  </local-tx-datasource>
</datasources>

另外，如果覺得連線密碼這樣寫明碼太危險，可參考JBoss community的文件加密儲存

驗證方式設定：在JBoss的設定目錄下【jboss\server\default\conf】，有個【login-config.xml】，這個就是設定帳號驗證的方式(如果沒有這個檔也可以自己新增)
裡面的參數
- UserAA: 我設定的驗證來源名稱，這個在專案中會做對應的設定。
- dsJndiName: 這邊就會對應到上一個設定的資料庫來源名稱MySqlDS
- principalsQuery:這邊要寫查詢帳號密碼的SQL
- rolesQuery:這邊要寫使用者角色的查詢SQL，角色會關係到後面網站權限的設定，第一個資料【roleName】所查詢出來的值我們這邊假設可能會有admin與guest，第二個資料是群組，我目前也不清楚是做什麼的，先依據官方範例給固定文字
```
<?xml version='1.0'?>
<policy>
 <application-policy name="UserAA"> 
 <authentication> 
 <login-module code="org.jboss.security.auth.spi.DatabaseServerLoginModule" flag = "required"> 
 <module-option name = "dsJndiName">java:/MySqlDS</module-option> 
 <module-option name = "principalsQuery">SELECT passwd FROM userdb.usersTab where userID=?</module-option> 
 <module-option name = "rolesQuery">SELECT roleName,'Roles' FROM userdb.userRolesTab where userID=?</module-option> 
 </login-module> 
 </authentication> 
</application-policy>
</policy>
```

MySQL

以下使用SQL script建立所需的資料庫與資料表，我將同時產生兩個預設的帳號分別屬於不同的權限角色，以下比較需要注意的部份是

主要用到的資料來源是UsersTab資料表中的兩個欄位userID、passwd，還有UserRolesTab的兩個欄位userID、roleName，這部份不知道是不是有型態限制或是長度限制的問題，我用別的規格下去可能就無法認證。
往下的Trigger是可有可無的，是我建立還方便管理資料庫用的
最下面的insert是預設帳號與角色資料的建立

boss/0000：角色為admin
test/0000：角色為guest

CREATE DATABASE  IF NOT EXISTS `userdb` /*!40100 DEFAULT CHARACTER SET utf8 */;


DROP TABLE IF EXISTS `userdb`.`UsersTab`;
CREATE TABLE  `userdb`.`UsersTab` (
  `userID` varchar(64) NOT NULL,
  `passwd` varchar(64) NOT NULL,
  `createtime` datetime DEFAULT NULL,
  `updatetime` datetime DEFAULT NULL,
  PRIMARY KEY (`userID`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8;


DROP TABLE IF EXISTS `userdb`.`UserRolesTab`;
CREATE TABLE  `userdb`.`UserRolesTab` (
  `userID` varchar(64) NOT NULL,
  `roleName` varchar(32) NOT NULL DEFAULT 'guest',
  `createtime` datetime DEFAULT NULL,
  PRIMARY KEY (`userID`,`roleName`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8;


DELIMITER $$
drop TRIGGER IF EXISTS `userdb`.UsersTab_Insert$$
CREATE TRIGGER `userdb`.UsersTab_Insert BEFORE INSERT ON `userdb`.UsersTab FOR EACH ROW
BEGIN
    if new.createtime is null then
      Set new.createtime = now();
    end if;
    if new.updatetime is null then
      Set new.updatetime = now();
    end if;
END$$

drop TRIGGER IF EXISTS `userdb`.UsersTab_Update$$
CREATE TRIGGER `userdb`.UsersTab_Update BEFORE UPDATE ON `userdb`.UsersTab FOR EACH ROW
BEGIN
    if new.updatetime is null or old.updatetime=new.updatetime then
      Set new.updatetime = now();
    end if;
END$$

drop TRIGGER IF EXISTS `userdb`.UsersTab_Delete$$
CREATE TRIGGER `userdb`.UsersTab_Delete AFTER DELETE ON `userdb`.UsersTab FOR EACH ROW
BEGIN
    delete from `userdb`.UserRolesTab where userID=old.userID;
END$$

drop TRIGGER IF EXISTS `userdb`.UserRolesTab_Insert$$
CREATE TRIGGER `userdb`.UserRolesTab_Insert BEFORE INSERT ON `userdb`.UserRolesTab FOR EACH ROW
BEGIN
    if new.createtime is null then
      Set new.createtime = now();
    end if;
END$$
DELIMITER ;

insert into userdb.UsersTab (userID,passwd) values('boss','0000');
insert into userdb.UserRolesTab (userID,roleName) values('boss','admin');

insert into userdb.UsersTab (userID,passwd) values('test','0000');
insert into userdb.UserRolesTab (userID,roleName) values('test','guest');

Dynmic Web Project

動態網站的設定主要是在【WEB-INF】資料夾中新增一個【jboss-web.xml】，內容如下

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE jboss-web PUBLIC "-//JBoss//DTD Web Application 2.3V2//EN" "http://www.jboss.org/j2ee/dtd/jboss-web_3_2.dtd">

<jboss-web>
   <security-domain>java:/jaas/UserAA</security-domain> 
</jboss-web>

然後修改【web.xml】。這邊我採用Form認證的方式，也就是用網頁提供Login的介面。

security-constraint：這一段是設定哪些路徑可由哪些Role來存取，也就是權限設定。這部份有用到的角色一定要在下面的【security-role】有定義到。另外如果想設定成只有有登入的人才能存取，可將【role-name】設定成【*】。
login-config：這一段就是定義Login的方式與參照頁面(另依種方式設定為BASIC)

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5">
  ...
  <security-constraint>
    <web-resource-collection>
      <web-resource-name></web-resource-name>
      <url-pattern>/test/*</url-pattern>
    </web-resource-collection>
    <auth-constraint>
      <role-name>admin</role-name>
    </auth-constraint>
  </security-constraint>
  <security-constraint>
    <web-resource-collection>
      <web-resource-name></web-resource-name>
      <url-pattern>/Login</url-pattern>
      <url-pattern>/Logout</url-pattern>
    </web-resource-collection>
    <auth-constraint>
      <role-name>*</role-name>
    </auth-constraint>
  </security-constraint>
  <login-config>
    <auth-method>FORM</auth-method>
    <realm-name></realm-name>
    <form-login-config>
      <form-login-page>/login.jsp</form-login-page>
      <form-error-page>/login.jsp?msg=Incorrect</form-error-page>
    </form-login-config>
  </login-config>
  <security-role>
    <role-name>admin</role-name>
  </security-role>
  <security-role>
    <role-name>guest</role-name>
  </security-role>
  ...
</web-app>

JSP & Servlet

再來我針對登入部份的網頁進行開發，主要會建立JSP：login.jsp與Servlet：Login、Logout。
實際上真正的登入網頁會是login.jsp，但因為如果使用者直接輸入login.jsp的網址後，進行登入成功後系統會不知該導到哪一頁(似乎也沒辦法設定預設導頁，網路上是有另一種作法如果有需要可自行參考)。
我這邊是自己想了個比較簡單的邏輯性解法，就是做一個Login的Servlet裡面直接會跳到首頁作為預設網頁，
然後將這個Login servlet設定必須登入才能存取(也就是上一步的web.xml中設定的)，讓登入的連結以這個Servlet為主就會自動導自login.jsp。

<%@ page language="java" contentType="text/html; charset=UTF-8"
    pageEncoding="UTF-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<title>Login</title>
</head>
<body>

 <h2 align="center">Login</h2> 
 <table border="0" align="center">
  <tr>
   <td>
    <form method="POST" action="j_security_check">
     <div>User ID :
      <input type="text"
       name="j_username">
       </div>
     <div>Password :
       <input type="password"
        name="j_password">
        </div>
    <div><input type="submit" value="Log In"></div>
    
    <div style="color: red;"><%=(request.getParameter("msg")!=null)?request.getParameter("msg"):"" %></div>
    
    </form>
   </td>
  </tr>
 </table>

</body>
</html>

package view;

import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

/**
 * Servlet implementation class Login
 */
public class Login extends HttpServlet {
 private static final long serialVersionUID = 1L;
       
    /**
     * @see HttpServlet#HttpServlet()
     */
    public Login() {
        super();
        // TODO Auto-generated constructor stub
    }

 /**
  * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
  */
 protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
  response.sendRedirect(request.getContextPath() + "/index.jsp");
 }
}

Logout servlet

package view;

import java.io.IOException;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;


public class Logout extends HttpServlet {
 private static final long serialVersionUID = 1L;
       
    /**
     * @see HttpServlet#HttpServlet()
     */
    public Logout() {
        super();
    }

    protected void service(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
     request.getSession().invalidate();
        response.sendRedirect(request.getContextPath() + "/");
      }
}

總結

以上設定完成後，就可以進到你的應用程式，然後存取Login servlet看看能不能正常登入登出了。
在這邊補充一些資訊，如果要在程式中取得登入者後的帳號，可以用【request.getUserPrincipal()】來取得Principal物件，如果不是null就可以呼叫該物件的getName()方法。
不過我個人比較喜歡用另外一個物件【org.jboss.security.SecurityAssociation】中的【getPrincipal()】也可以。
如果是要判斷使用者的角色，可使用【request.isUserInRole("admin")】方法來知道該使用者是否屬於admin這個角色。

參考資料

Declarative J2EE authentication and authorization with JAAS

[分享]PHP版網頁原始碼處理函式

2009-10-31T19:44:00.000-07:00

序言

這是我依VB.Net的網頁原始碼處理函式翻過來的PHP版程式，可以取得網頁後，再針對特定標簽進行切割處理。

函式原始碼

我將以下原始碼存在【myClass】目錄的【HTMLParser.php】檔

<?php
 Class HTMLParser{
  function getHTML($url,$method="GET",$param=NULL,$noCashe=False){
   //$param = array("name" => 'tim',"content" => 'test');
   
   if($noCashe){
    $cashe="Cache-Control: no-cache\r\n";
   }else{
    $cashe="";
   }
   if($method=="GET" and $param!=NULL){
    $data="";
    foreach ($param as $k => $v) {
     if($data!="") $data.="&";
     $data.= "$k=".htmlentities($v);
    }
    $url.="?".$data;
   }
   
   if($method=="POST" and $param!=NULL){
    $data = http_build_query($param);  
    $contentLength="Content-length:".strlen($data)."\r\n";
    $opts = array(
      'http'=>array(
      'method'=>$method,
      'header'=>"User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.2; SV1; .NET CLR 1.1.4322; .NET CLR 2.0.50727)\r\n"
        . "Accept-language: zh-tw\r\n"
        . "Content-Typ: application/x-www-form-urlencoded\r\n"
        . $cashe . $contentLength,  
      'content' => $data
      )
    );
   }else{
    $opts = array(
      'http'=>array(
      'method'=>$method,
      'header'=>"User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.2; SV1; .NET CLR 1.1.4322; .NET CLR 2.0.50727)\r\n"
        . "Accept-language: zh-tw\r\n"
        . "Content-Typ: application/x-www-form-urlencoded\r\n"
        . $cashe
      )
    );

   }   
   $context = stream_context_create($opts);
   // Open the file using the HTTP headers set above
   return file_get_contents($url, false, $context);
   //return file_get_contents($url);
  }
  //取得網頁的Body區段
  function getHTMLBody($url,$postValue=NULL,$noCashe= False){
   $html=NULL;
   $htmlBody=NULL;
   if($postValue!=NULL){
    $html = $this->getHTML($url,"POST",$postValue,$noCashe);
   }else{
    $html = $this->getHTML($url,"GET", $postValue,$noCashe);
   }
   If(html!=NULL) $this->getHTMLTagContain($html, "body", $htmlBody);
   
   return $htmlBody;
  }
  //取得HTML中第一個符合的標籤內容的指標，並將取得的標籤內容寫入參數中
  function getHTMLTagContain($html,$tag,&$contain=NULL,&$indexEnd= -1){
   $tag = strtolower($tag);
   $contain = NULL;   
   $indexBegin= -1;
   $indexEnd = -1;
   $indexbBegin= -1;
   If($html !=NULL){    
    $indexBegin = strpos(strtolower($html),"<" . $tag);
    if (gettype($indexBegin)!="integer") $indexBegin=-1;
    If($indexBegin > -1){
     $indexbBegin = strpos($html,">",$indexBegin);
     if (gettype($indexbBegin)!="integer"){
      $indexbBegin=-1;
     }else{
      $indexbBegin+=1;
     }
     $findTag=False;
     $indexEnd=$indexbBegin;
     $lastStart=$indexbBegin;
     $stopLimit2 = 9999;
     do{
      $indexEnd=strpos(strtolower($html),"</" . $tag,$indexEnd);
      if(gettype($indexEnd)!="integer") $indexEnd=-1;
      If ($indexEnd > -1){
       if(gettype(strpos(substr($html,$lastStart, $indexEnd - $lastStart),"<" . $tag))=="integer"){
        $lastStart=$indexEnd;
        $indexEnd=$indexEnd+strlen("</" . $tag);       
        $findTag=True;
       }else{
        $findTag=False;
       }
      }else{
       $findTag=False;
      }
      $stopLimit2--;
     }while($findTag AND $stopLimit2>0);
     If ($indexEnd > -1){
      $contain = substr($html,$indexbBegin, $indexEnd - $indexbBegin);
      
      $indexEnd= strpos($html,">",$indexEnd);
      if(gettype($indexEnd)!="integer"){
       $indexEnd=-1;
      }else{
       $indexEnd+=1;
      }
     }
    }
   }
   //echo $contain;
   Return $indexbBegin;
  }
  //取得HTML中第一個符合的標籤屬性的指標，並將取得的標籤內容與該屬性內容寫入參數中
  function getHTMLTagAtt($html,$tag,$attName,&$att=NULL,&$contain=NULL,&$indexEnd= -1){
   $tag = strtolower($tag);
   $attName = strtolower($attName);
   $contain = NULL;
   $att = NULL;
   $indexEnd = -1;  
   $indexBegin= -1;
   $indexaBegin= -1; 
   $indexbEnd = -1;
   If($html !=NULL){
    $indexBegin = 0;
    $stopLimit1 = 9999;
    do{
     $indexbEnd = -1;
     $indexBegin = strpos(strtolower($html),"<" . $tag,$indexBegin);
     if (gettype($indexBegin)!="integer") $indexBegin=-1;
     If($indexBegin > -1){
      $indexbEnd= strpos($html,">",$indexBegin);
      if (gettype($indexbEnd)!="integer") $indexbEnd=-1;
      If($indexbEnd > -1){
       $indexaBegin = strpos(strtolower(str_replace("\"", "'",substr($html,0, $indexbEnd))),$attName . "='",$indexBegin);
       if(gettype($indexaBegin)!="integer") $indexaBegin=-1;
       If($indexaBegin > -1){
        $sign = substr($html,$indexaBegin + strlen($attName . "="), 1);
        $indexaBegin+=strlen($attName . "='");
        $indexaEnd= strpos(substr($html,0, $indexbEnd),$sign,$indexaBegin);
        if(gettype($indexaEnd)!="integer") $indexaEnd=-1;
        If($indexaEnd > -1){
         $att = substr($html,$indexaBegin, $indexaEnd - $indexaBegin);
        }
       }else{
        $indexBegin = $indexbEnd + 1;
        continue;
       }
       $indexbEnd+=1;
      }
      
      $findTag=False;
      $indexEnd=$indexbEnd;
      $lastStart=$indexbEnd;
      $stopLimit2 = 9999;
      do{
       $indexEnd=strpos(strtolower($html),"</" . $tag,$indexEnd);
       if(gettype($indexEnd)!="integer") $indexEnd=-1;
       If ($indexEnd > -1){
        if(gettype(strpos(substr($html,$lastStart, $indexEnd - $lastStart),"<" . $tag))=="integer"){
         $lastStart=$indexEnd;
         $indexEnd=$indexEnd+strlen("</" . $tag);       
         $findTag=True;
        }else{
         $findTag=False;
        }
       }else{
        $findTag=False;
       }
       $stopLimit2--;
      }while($findTag==True AND $stopLimit2>0);    
      If ($indexEnd > -1){
       $contain = substr($html,$indexbEnd, $indexEnd - $indexbEnd);
       $indexEnd= strpos($html,">",$indexEnd);
       if(gettype($indexEnd)!="integer"){
        $indexEnd=-1;
       }else{
        $indexEnd+=1;
       }
      }
     }else{
      break;
     }
     $stopLimit1--;
    }while($att == NULL AND $stopLimit1>0); 
   }
   Return $indexbEnd;
  }
 }
?>

使用範例

<?php include 'myClass/HTMLParser.php'; $htmlParser=new HTMLParser(); $url = "http://allen080.blogspot.com/2009/05/vbnet20.html"; //取得整個網頁的HTML $htmlAll = $htmlParser->getHTML($url); //取得網頁Body的部份 $htmlBody = $htmlParser->getHTMLBody($url); If ($htmlBody!=NULL){ $indexEnd = strpos($htmlBody,""); if(gettype($indexEnd)!="integer") $indexEnd=-1; $valueAttribute = NULL; $valueContain = NULL; If($indexEnd > 0){ $htmlBody = substr($htmlBody,$indexEnd); //取得a標籤1的內容 $htmlParser->getHTMLTagContain($htmlBody, "span", $valueContain, $indexEnd); echo "span標籤的內容: " . $valueContain ." \n"; //$htmlBody = substr($htmlBody,$indexEnd); //取得a標籤2的內容與href的屬性 $htmlParser->getHTMLTagAtt($htmlBody, "a", "onclick", $valueAttribute, $valueContain, $indexEnd); echo "a標籤的內容與onclick的屬性: " . $valueAttribute ."\t" . ",內容:" . $valueContain; } } ?>

執行結果

總結

這是我為了練習php時寫出的東西~

我個人是覺得滿好用的~

不過有部份邏輯滿複雜的~所以我也不敢保證完全正確或是適用於各種網頁~

如果有人用有發現更好的改進方式請跟我說。

[PHP]字串處理函式

2009-10-29T22:16:00.000-07:00

序言

字串處理是常用的功能，大多數語言對這部份也有許多大同小異的函式，以下列出比較常用或我覺得特別需注意的函式。

尋找字串

strpos($string,$find[,$start])：尋找第一個在字串中出現的字詞，傳回0開始的數字位置。【$string】是被找的字串，【$find】是尋找的目標字詞，【$start】是代表尋找的起始位置。→官方文件
這個函式有一個極需注意的部份，就在於它的回傳值，找到的話會回傳位置，也就是個0開始的數字；但沒找到的話就機車了，以VB為例的IndexOf函式是類似這個函式的功能，如果沒找到會回傳【-1】，但在PHP不同版本中，會回傳的值居然是False，那就算了，聽說這是4.0b3版以後的PHP是這樣，更早之前的PHP甚至聽說回傳的連False都不是。於是就有人想出了判斷型態的方法，具體實現方式如下

<?php //尋找第一個在字串中出現的字詞 function str_indexof($string,$find,$start=0){ $index=strpos($string,$find,$start); if(gettype($index)!="integer") $index=-1; return $index; } $string='abcdefghijk'; $find='l'; echo str_indexof($string,$find) . "\n"; //-1 $find='a'; echo str_indexof($string,$find,3) . "\n"; //-1 $find='i'; echo str_indexof($string,$find,3) . "\n"; //8 ?>

子字串

substr($string[[,$start],$length])：取得子字串，傳回子字串內容。【$string】是來源字串，【$start】是代表尋找的起始位置，【$length】是子字串長度。→官方文件
這個函式需注意的部份在於它對中文字(UTF-8)會以每個字3字元的方式計算，所以切割時如果是中文字就要以3的倍數遞增。有另外的函式可對含中文的函式做計算找子字串，但如果是用上面談到的strpos函式來找指標，那就可以不用擔心這個問題。具體實現方式如下

<?php $string = '這是substr的測試'; echo substr($string,0,13) . "\n"; //這是substr� $string = '這是mb_substr的測試'; echo mb_substr($string,0,13,'UTF-8') . "\n"; //這是mb_substr的測 ?>

字串長度

strlen($string)：傳回字串長度。【$string】是來源字串。→官方文件
這個函式與上面一樣對中文字(UTF-8)會以每個字3字元的方式計算。

轉換大小寫

strtoupper($string)：回傳轉換為英文大寫字串。strtolower($string)：取得轉換為英文小寫字串。【$string】是來源字串。→官方文件
這個函式與上面一樣對中文字(UTF-8)會以每個字3字元的方式計算。

文字切割

split($pattern,$string[,$limit])：將字串依分割條件切割為陣列，回傳結果陣列。【$pattern】是分割條件，可為字串或是正規表達式。【$string】是來源字串。【$limit】最多切出幾個元素。
這個函式較直得注意的有兩點，一個是參數順序，居然不是來源字串...；第二個是分割條件【$pattern】可用正規表達式，有關於正規表達式可參考相關連結。→官方文件

文字驗證

ereg($pattern,$string[,&$arrResult])：依正規表達式驗證字串格式(比對字串時有大小寫之分)，回傳True符合或False不符合。→官方文件
eregi($pattern,$string[,&$arrResult])：功能同上，但比對字串時沒有大小寫之分。
【$pattern】是驗證條件正規表達式。【$string】是來源字串。【$arrResult】符合的文字。
這個函式較直得注意的一樣有兩點，一個是參數順序；第二個是驗證條件【$pattern】為正規表達式，如【^[a-z0-9-]{3,8}$】如果要完整比對字串的話，要記得開頭用與結尾分別用【^】與【$】把條件框住，【[a-z0-9-]】代表小寫a~z與0~9及減號都是可用的字元，【{3,8}】代表上數字元可重複的次數為3~8次，可參考相關連結。
相關連結

PHP官方開發手冊：英文開發手冊。
W3School：簡體中文的網站開發程式語言文件，雖然有些不夠完整，不過很適合當工具書或初學參考(除了PHP，其他還有許多網頁語言)。

[PHP]陣列、檔案讀寫

2009-10-29T20:25:00.000-07:00

陣列

PHP的Array也是我覺得很特別的東西，感覺有點像VB中HashTable的機制。
從程式中可注意到，要取得Array中的元素個數可用【count($dataArr)】。
新增元素的方法也很多元，也能動態新增。→官方文件

<?php echo "\nArray 1 \n"; $dataArr = array('abc','test'); for($i=0;$i<count($dataArr);$i++){ echo $i."\t".$dataArr[$i] . " \n"; } echo "\nArray 2 \n"; $dataArr = array(); $dataArr[]='abc'; $dataArr[]='test'; for($i=0;$i<count($dataArr);$i++){ echo $i."\t".$dataArr[$i] . " \n"; } echo "\nArray 3 \n"; $dataArr = array(); $dataArr['name']='abc'; $dataArr['content']='test'; for($i=0;$i<count($dataArr);$i++){ echo $i."\t".$dataArr[$i] . " \n"; } foreach($dataArr as $value){ echo $value . " \n"; } foreach($dataArr as $key => $value){ echo $key."\t".$value . " \n"; } echo "\nArray 4 \n"; $dataArr = array('name' => 'abc','content' => 'test'); foreach($dataArr as $key => $value){ echo $key."\t".$value . " \n"; } ?>

結果：

Array 1 0 abc 1 test Array 2 0 abc 1 test Array 3 0 1 abc test name abc content test Array 4 name abc content test 

檔案存取

檔案存取是我常會用的功能，以下列出我的寫法與常用函式：官方文件

<?php //存文字檔，如果檔案不存在會建立檔案，如果存在會覆蓋檔案 function saveText($filename,$fText){ try{ $fh = fopen($filename, "w"); fwrite($fh, $fText); fclose($fh); }catch(Exception $e){ echo 'Error addText: ' .$e->getMessage(); } } //增加文字到文字檔最後面，如果檔案不存在會建立檔案 function addText($filename,$fText){ try{ $fh = fopen($filename, "a"); fwrite($fh, $fText); fclose($fh); }catch(Exception $e){ echo 'Error addText: ' .$e->getMessage(); } } //讀取文字檔內容 function loadText($filename){ $fText=NULL; try{ if(file_exists($filename)) $fText=file_get_contents($filename); }catch(Exception $e){ echo 'Error loadText: ' .$e->getMessage(); } return $fText; } //刪除檔案 function deleteFile($filename){ return unlink($filename); } //建立資料夾 function createDir($dirname){ return mkdir($dirname); } //刪除資料夾 function deleteDir($dirname){ return rmdir($dirname); } ?>

[初學]PHP入門心得

2009-10-29T20:17:00.000-07:00

序言

雖然寫了許久的程式，但一直沒花時間去練習PHP。
最近花了點時間試試PHP，增長了些見聞，後續幾篇會一一記錄下我開發時注意到的事。

開發環境

Windows 2003
TWAMPs(Tiny Windows Apache MySQL PHP Portable Web Server)V1.3.3中文版
我開發的時候雖然已經有V1.3.5版，但執行的時候不知道為什麼我的整個作業系統會出現很多衝突的現象，很多程式都受影響，所以就往回推用舊的版本。V1.3.4版無法下載，就改用V1.3.3。以下是這個免安裝的環境提供的版本：

Apache:2.2.11
PHP:5.2.10
MySQL:5.1.36-community
phpMyAdmin:3.2.0.1
Drupal:6.13

Notepad++ 5.4.4
我沒有特地找PHP的編輯器，所以編輯起來比較費工，不過Notepad還是有用顏色標亮特定的語法，所以還是有點用的。

環境設定

啟動前可以看一下根目錄的【README.txt】來找到對應的Port或其他值的更改地點，但有些部分【README.txt】沒有寫的很正確，所以可能還是要靠經驗與人工找找實際的目錄，如：

Apache PORT更改，README.txt說【edit httpd.conf in TWAMP\Apache\conf】，但實際路徑會在【 TWAMPd\app\conf】下的httpd.conf，找到並更改【Listen 80】
php.ini的位置，README.txt說【Edit php.ini in TWAMPd\PHP】，但實際路徑會在【TWAMPd\app\bin】
【TWAMPd\htdocs】目錄下會是所有網頁文件所在的地方。

Apache 目錄存取限制設定

【.htaccess】是一個文字檔，可以自己建立後，放在要限制/保護的目錄下，Apache就會依裡面的設定內容對使用者的存取進行限制或保護。
例如我對目錄要完全不給人進來存取檔案，就在文字檔內寫入以下內容

order allow,deny deny from all

基本上這只是最簡單的功能，但很常用。如果需要更多設定，其實這個檔也可以設定的很複雜，網路上還有人專門做出設定工具：htaccessEditor，在此就不詳述了。

PHP開發兩三事

基本語法
<?php echo "123"; ?>
【<?php ... ?>】指的是裡面的code【...】是php，以副檔名為*.php的檔案放在【TWAMPd\htdocs】目錄下，就可以被編譯執行。【echo】會將後面帶的文字顯示在頁面這段程式所在的位置上。→官方文件-基本語法、官方文件-echo
include
<?php include 'myClass/HTMLParser.php'; ?>
include 的寫法，會將include的PHP程式如同嵌入在宣告的位置一樣，我想使用方法應該就如同C一樣，欲使用前必先宣告。→官方文件
變數、單引號與雙引號
<?php $value="123"; echo "1: " . $value . "\r\n "; echo "2: " . "abc\t$valuedef\r\n "; echo "3: " . 'abc$valuedef\r\n '; echo "4: " . "abc\t$value def\r\n "; echo "5: " . 'abc$value def \r\n '; echo "6: " . 'abc' . $value . 'def\r\n '; echo "7: " . '"' . $value . "'\r\n "; ?>
結果：
1: 123 2: abc 3: abc$valuedef\r\n 4: abc 123 def 5: abc$value def \r\n 6: abc123def\r\n 7: "123' 
上面的程式中可以看到幾個現象：變數的前面用【$】來標示它是個變數，而且不用先行宣告，隨使用就會產生。以下逐行來看
1. 字串的組合是用點【.】來標示兩字串要串聯起來。【雙引號】中的特殊文元【\】標示了後面帶了特殊字元【\r\n】，這都是換行符號，如果用VB來形容就是【vbCrLf】，這個特殊字元可以單獨使用，如【\n】。(PS:按「Enter」鍵實際產生兩個字元換行和回到開頭（ASCII編碼10:\n和13:\r）)
2. 【雙引號】中的變數被編譯成顯示，但因為英文字連再一起，所以編譯後是顯示【valuedef】變數的值。因為根本沒有宣告【valuedef】變數的值，所以最後產生的時候是空值，就什麼都沒有。
3. 【單引號】直接輸出文字內容，所以特殊字元或變數都無效。
4. 【雙引號】中的變數被編譯成顯示，此字串內容中，還有用到特殊字元【\t】來出現tab的字元。
5. 【單引號】直接輸出文字內容，所以特殊字元或變數都無效。
6. 【單引號】直接輸出文字內容，所以特殊字元或變數都無效。
7. 雙引號內容中可以出現單引號，反過來說也行，如果雙引號內容中要出現雙引號，需要加上特殊字元\。
PHP 會解譯【雙引號】內容中的變數，而【單引號】則視為純字串出，PHP 不會再處理單引號內的內容。所以單引號與雙引號在使用時會有時機上的差異。
常數
<?php define('myValue','1234'); echo myValue; ?>
常數的寫法與變數不同，定義後名稱前面不需要再加上【$】號。→官方文件
脫逸 (Escape)字
<?php //去除get_magic_quotes_gpc on 時針對特殊字做脫逸 (Escape)的影響 if (get_magic_quotes_gpc()) { $HTTP_GET_VARS = array_map('stripslashes', $HTTP_GET_VARS); $HTTP_POST_VARS = array_map('stripslashes', $HTTP_POST_VARS); $HTTP_COOKIE_VARS = array_map('stripslashes', $HTTP_COOKIE_VARS); $_GET = array_map('stripslashes', $_GET); $_POST = array_map('stripslashes', $_POST); $_COOKIE = array_map('stripslashes', $_COOKIE); $_REQUEST = array_map('stripslashes', $_REQUEST); } ?>
這個部份是比較與執行環境設定有關的。在PHP.ini中有個設定【get_magic_quotes_gpc on】(官方文件)，可以讓使用者輸入的字元中一些特殊的字元加上【\】，如單引號【'】、雙引號【"】、斜線【\】，以防程式處理時會造成意想不到的錯誤。但這樣的設定可能反而會讓我們在處理資料時更加棘手，所以這串程式能判斷當這個設定開啟時，讓這些特殊的字元不經過加上【\】的畜哩，直接取得使用者輸入的內容。

相關連結

TWAMP：免安裝的中英文伺服器執行環境。
PHP官方開發手冊：英文開發手冊。
W3School：簡體中文的網站開發程式語言文件，雖然有些不夠完整，不過很適合當工具書或初學參考(除了PHP，其他還有許多網頁語言)。

[程式]VB.Net2.0網頁原始碼取得函式

2009-05-10T23:34:00.000-07:00

序言

我因為學術需求，要取得某些網址的網頁原始碼進行分析，因此寫了以下函式，貼出來與大家分享吧~

*2009/10/29 更新函式，加強切割網頁函式、抓網頁標頭。

開發環境

VB.Net 2.0 (VS2005)

專案設定

建立專案後預設的專案屬性下，參考的元件如下圖：
下面的程式中會用到【Web】這個物件，所以我們需要加入【System.Web】這個元件：

點選加入，在.Net分頁下找到【System.Web】這個元件

網頁原始碼函式類別

Imports System.Net
Imports System.io
Imports System.Reflection

Public Class WebPageGenFunc
    Private Shared rd As New Random(Now.Second)
    Private Shared sec As Integer
    Private Shared lastsec As Integer = -1
    Public Shared Function sleepTime(Optional ByVal minimatime As Integer = 2600, Optional ByVal rangeSecond As Integer = 5) As Integer
        sec = (rd.Next Mod rangeSecond) * 1000 + minimatime
        While sec = lastsec
            sec = (rd.Next Mod rangeSecond) * 1000 + minimatime
        End While
        lastsec = sec
        System.Threading.Thread.Sleep(sec)
        Return sec
    End Function


    Private Shared Sub SetAllowUnsafeHeaderParsing20()
        Dim a As New System.Net.Configuration.SettingsSection
        Dim aNetAssembly As System.Reflection.Assembly = Assembly.GetAssembly(a.GetType)
        Dim aSettingsType As Type = aNetAssembly.GetType("System.Net.Configuration.SettingsSectionInternal")
        Dim args As Object() = Nothing
        Dim anInstance As Object = aSettingsType.InvokeMember("Section", BindingFlags.Static Or BindingFlags.GetProperty Or BindingFlags.NonPublic, Nothing, Nothing, args)
        Dim aUseUnsafeHeaderParsing As FieldInfo = aSettingsType.GetField("useUnsafeHeaderParsing", BindingFlags.NonPublic Or BindingFlags.Instance)
        aUseUnsafeHeaderParsing.SetValue(anInstance, True)
    End Sub


    ''' <summary>
    ''' 使用Get方法取得網頁內容
    ''' </summary>
    ''' <param name="url">網址</param>
    ''' <param name="noCashe">不使用快取</param>
    ''' <returns>網頁的HTML</returns>
    ''' <remarks>使用Get方法取得網頁內容</remarks>
    Public Shared Function getHTMLGet(ByVal url As String, Optional ByVal noCashe As Boolean = False) As String
        getHTMLGet = Nothing
        SetAllowUnsafeHeaderParsing20()
        Dim wRs As HttpWebResponse
        Dim wRq As HttpWebRequest
        ' Create the request using the WebRequestFactory.

        wRq = CType(WebRequest.Create(url), HttpWebRequest)
        With wRq
            .UserAgent = "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.2; SV1; .NET CLR 1.1.4322; .NET CLR 2.0.50727)"
            .ContentType = "application/x-www-form-urlencoded"
            .Headers.Add("Accept-Language", "zh-tw")
            .Method = "GET"
            .Timeout = 10000
            If noCashe Then
                Dim policy As New Cache.HttpRequestCachePolicy(Cache.HttpRequestCacheLevel.NoCacheNoStore)
                .CachePolicy = policy
                .Headers.Add("Cache-Control", "no-cache")
            End If
        End With

        Try
            ' Return the response stream.
            wRs = CType(wRq.GetResponse(), HttpWebResponse)
            Dim streamResponse As Stream = wRs.GetResponseStream()
            Dim streamRead As New StreamReader(streamResponse)
            Dim responseString As String = streamRead.ReadToEnd()
            getHTMLGet = responseString
            ' Close Stream object.
            streamResponse.Close()
            streamRead.Close()
            ' Release the HttpWebResponse.
            wRs.Close()
        Catch ex As Exception
            Console.WriteLine(ex.ToString)
        End Try
    End Function

    ''' <summary>
    ''' 使用Post方法取得網頁內容
    ''' </summary>
    ''' <param name="url">網址</param>
    ''' <param name="postdata">傳遞參數，如a=123&b=456</param>
    ''' <param name="noCashe">不使用快取</param>
    ''' <returns>網頁的HTML</returns>
    ''' <remarks>使用Post方法取得網頁內容</remarks>
    Public Shared Function getHTMLPost(ByVal url As String, Optional ByVal postdata As String = Nothing, Optional ByVal noCashe As Boolean = False) As String
        getHTMLPost = Nothing
        SetAllowUnsafeHeaderParsing20()
        Dim wRs As HttpWebResponse
        Dim wRq As HttpWebRequest
        ' Create the request using the WebRequestFactory.
        wRq = CType(WebRequest.Create(url), HttpWebRequest)
        With wRq
            .UserAgent = "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.2; SV1; .NET CLR 1.1.4322; .NET CLR 2.0.50727)"
            .Headers.Add("Accept-Language", "zh-tw")
            .Method = "POST"
            .Timeout = 10000
            .KeepAlive = False
            If noCashe Then
                Dim policy As New Cache.HttpRequestCachePolicy(Cache.HttpRequestCacheLevel.NoCacheNoStore)
                .CachePolicy = policy
                .Headers.Add("Cache-Control", "no-cache")
            End If
            If Not postdata Is Nothing Then
                .Timeout = 60000
                Dim encoding As New System.Text.ASCIIEncoding()
                Dim byte1 As Byte() = encoding.GetBytes(postdata)
                .ContentType = "application/x-www-form-urlencoded"
                .ContentLength = byte1.Length
                .GetRequestStream().Write(byte1, 0, byte1.Length)
            End If
        End With
        wRq.GetRequestStream().Close()
        Try
            ' Return the response stream.
            wRs = CType(wRq.GetResponse(), HttpWebResponse)
            Dim streamResponse As Stream = wRs.GetResponseStream()
            Dim streamRead As New StreamReader(streamResponse)
            Dim responseString As String = streamRead.ReadToEnd()
            getHTMLPost = responseString
            ' Close Stream object.
            streamResponse.Close()
            streamRead.Close()
            ' Release the HttpWebResponse.
            wRs.Close()

        Catch ex As Exception
            Console.WriteLine(ex.ToString)
        End Try
    End Function
    ''' <summary>
    ''' 使用WebClient取得網頁內容
    ''' </summary>
    ''' <param name="url">網址</param>
    ''' <param name="postdata">傳遞的參數</param>
    ''' <param name="method">使用的方法，預設為POST</param>
    ''' <param name="noCashe">不使用快取</param>
    ''' <returns>網頁的HTML</returns>
    ''' <remarks>使用WebClient取得網頁內容</remarks>
    Public Shared Function getHTMLWebClient(ByVal url As String, ByRef postdata As Specialized.NameValueCollection, Optional ByVal method As String = "POST", Optional ByVal noCashe As Boolean = False) As String
        getHTMLWebClient = Nothing
        Try
            SetAllowUnsafeHeaderParsing20()
            Dim myWebClient As New WebClient()
            If noCashe Then
                Dim policy As New Cache.HttpRequestCachePolicy(Cache.HttpRequestCacheLevel.NoCacheNoStore)
                myWebClient.CachePolicy = policy
                myWebClient.Headers.Add("Cache-Control", "no-cache")
            Else
                Dim rheaders As WebHeaderCollection = myWebClient.ResponseHeaders
                If Not rheaders Is Nothing Then
                    Dim header As String = rheaders("Set-Cookie")
                    If Not header Is Nothing Then
                        myWebClient.Headers.Add("Cookie", header)
                    End If
                End If
            End If
            myWebClient.Headers.Add("User-Agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.2; SV1; .NET CLR 1.1.4322; .NET CLR 2.0.50727)")
            myWebClient.Headers.Add("Content-Type", "application/x-www-form-urlencoded")
            myWebClient.Headers.Add("Accept-Language", "zh-tw")
            If postdata Is Nothing Then postdata = New Specialized.NameValueCollection
            Dim responseArray As Byte() = myWebClient.UploadValues(url, method, postdata)
            Dim encoding As New System.Text.UTF8Encoding
            getHTMLWebClient = encoding.GetString(responseArray)
        Catch ex As Exception
            Console.WriteLine(ex.ToString)
        End Try
    End Function

    ''' <summary>
    ''' 取得網頁的Body區段
    ''' </summary>
    ''' <param name="url">網址</param>
    ''' <param name="postdata">傳遞的參數，若有值會使用getHTMLPost取得</param>
    ''' <param name="postValue">傳遞的參數，若有值會使用getHTMLWebClient取得</param>
    ''' <param name="noCashe">不使用快取</param>
    ''' <returns>網頁的HTML</returns>
    ''' <remarks>取得網頁的Body區段</remarks>
    Public Shared Function getHTMLBody(ByVal url As String, Optional ByVal postdata As String = Nothing, Optional ByVal postValue As Specialized.NameValueCollection = Nothing, Optional ByVal noCashe As Boolean = False, Optional ByVal useWebClient As Boolean = False) As String
        getHTMLBody = Nothing
        Dim html As String
        If Not postValue Is Nothing Then
            html = getHTMLWebClient(url, postValue, , noCashe)
        ElseIf Not postdata Is Nothing Then
            html = getHTMLPost(url, postdata, noCashe)
        Else
            If useWebClient Then
                html = getHTMLWebClient(url, Nothing, "GET", noCashe)
            Else
                html = getHTMLGet(url, noCashe)
            End If

        End If
        If Not html Is Nothing Then
            getHTMLTagContain(html, "body", getHTMLBody)
        End If
    End Function
    ''' <summary>
    ''' 取得HTML中第一個符合的標籤內容的指標，並將取得的標籤內容寫入參數中
    ''' </summary>
    ''' <param name="html">HTML</param>
    ''' <param name="tag">標籤</param>
    ''' <param name="contain">取得的標籤內容</param>
    ''' <param name="indexEnd">此標籤結束於HTML的指標</param>
    ''' <returns>標籤內容的指標</returns>
    ''' <remarks>取得HTML中第一個符合的標籤內容的指標，並將取得的標籤內容寫入參數中</remarks>
    Public Shared Function getHTMLTagContain(ByVal html As String, ByVal tag As String, Optional ByRef contain As String = Nothing, Optional ByRef indexEnd As Integer = -1) As Integer
        tag = tag.ToLower
        contain = Nothing
        indexEnd = -1
        Dim indexBegin As Integer = -1
        Dim indexbBegin As Integer = -1
        If Not html Is Nothing Then
            indexBegin = html.ToLower.IndexOf("<" & tag)
            If indexBegin > -1 Then
                indexbBegin = html.IndexOf(">", indexBegin)
                If indexbBegin > -1 Then
                    indexbBegin += 1
                End If
                Dim findTag As Boolean = False
                indexEnd = indexbBegin
                Dim lastStart As Integer = indexbBegin
                Dim stopLimit2 As Integer = 9999
                Do
                    indexEnd = html.ToLower.IndexOf("</" & tag, indexEnd)
                    If indexEnd > -1 Then
                        If html.Substring(lastStart, indexEnd - lastStart).IndexOf("<" & tag) > -1 Then
                            lastStart = indexEnd
                            indexEnd = indexEnd + ("</" & tag).Length
                            findTag = True
                        Else
                            findTag = False
                        End If
                    Else
                        findTag = False
                    End If
                    stopLimit2 -= 1
                Loop While findTag And stopLimit2 > 0

                If indexEnd > -1 Then
                    contain = html.Substring(indexbBegin, indexEnd - indexbBegin)

                    indexEnd = html.IndexOf(">", indexEnd)
                    If indexEnd > -1 Then
                        indexEnd += 1
                    End If
                End If

            End If
        End If
        Return indexbBegin
    End Function
    ''' <summary>
    ''' 取得HTML中第一個符合的標籤屬性的指標，並將取得的標籤內容與該屬性內容寫入參數中
    ''' </summary>
    ''' <param name="html">HTML</param>
    ''' <param name="tag">標籤</param>
    ''' <param name="attName">屬性名稱</param>
    ''' <param name="att">取得的屬性內容</param>
    ''' <param name="contain">取得的標籤內容</param>
    ''' <param name="indexEnd">此標籤結束於HTML的指標</param>
    ''' <returns></returns>
    ''' <remarks>取得HTML中第一個符合的標籤屬性的指標，並將取得的標籤內容與該屬性內容寫入參數中</remarks>
    Public Shared Function getHTMLTagAtt(ByVal html As String, ByVal tag As String, ByVal attName As String, Optional ByRef att As String = Nothing, Optional ByRef contain As String = Nothing, Optional ByRef indexEnd As Integer = -1) As Integer
        att = Nothing
        contain = Nothing
        tag = tag.ToLower
        attName = attName.ToLower
        indexEnd = -1
        Dim indexBegin As Integer = -1
        Dim indexaBegin As Integer = -1
        Dim indexbEnd As Integer = -1
        Dim findTag As Boolean = False
        Dim sign As String

        If Not html Is Nothing Then
            indexBegin = 0
            Dim stopLimit1 As Integer = 9999
            Do
                indexbEnd = -1
                indexBegin = html.ToLower.IndexOf("<" & tag, indexBegin)
                If indexBegin > -1 Then
                    indexbEnd = html.IndexOf(">", indexBegin)
                    If indexbEnd > -1 Then
                        indexaBegin = html.Substring(0, indexbEnd).Replace("""", "'").ToLower.IndexOf(attName & "='", indexBegin)
                        If indexaBegin > -1 Then
                            sign = html.Substring(indexaBegin + (attName & "=").Length, 1)
                            indexaBegin += (attName & "='").Length
                            Dim indexaEnd As Integer = html.Substring(0, indexbEnd).IndexOf(sign, indexaBegin)
                            If indexaEnd > -1 Then
                                att = html.Substring(indexaBegin, indexaEnd - indexaBegin)
                            End If
                        Else
                            indexBegin = indexbEnd + 1
                            Continue Do
                        End If
                        indexbEnd += 1
                    End If

                    findTag = False
                    indexEnd = indexbEnd
                    Dim lastStart As Integer = indexbEnd

                    Dim stopLimit2 As Integer = 9999
                    Do
                        indexEnd = html.ToLower.IndexOf("</" & tag, indexEnd)
                        If indexEnd > -1 Then
                            If html.Substring(lastStart, indexEnd - lastStart).IndexOf("<" & tag) > -1 Then
                                lastStart = indexEnd
                                indexEnd = indexEnd + ("</" & tag).Length
                                findTag = True
                            Else
                                findTag = False
                            End If
                        Else
                            findTag = False
                        End If
                        stopLimit2 -= 1
                    Loop While findTag And stopLimit2 > 0

                    If indexEnd > -1 Then
                        contain = html.Substring(indexbEnd, indexEnd - indexbEnd)
                        indexEnd = html.IndexOf(">", indexEnd)
                        If indexEnd > -1 Then
                            indexEnd += 1
                        End If
                    End If
                Else
                    Exit Do
                End If
                stopLimit1 -= 1
            Loop While att Is Nothing And stopLimit1 > 0
        End If
        Return indexbEnd
    End Function
    ''' <summary>
    ''' Url參數值編碼
    ''' </summary>
    ''' <param name="value">參數值</param>
    ''' <returns>編碼結果</returns>
    ''' <remarks>Url參數值編碼</remarks>
    Public Shared Function getEncodeStr(ByVal value As String)
        Return Web.HttpUtility.UrlEncode(value)
    End Function
    ''' <summary>
    ''' Url參數值解碼
    ''' </summary>
    ''' <param name="value">參數值</param>
    ''' <returns>解碼結果</returns>
    ''' <remarks>Url參數值解碼</remarks>
    Public Shared Function getDecodeStr(ByVal value As String)
        Return Web.HttpUtility.UrlDecode(value)
    End Function
End Class

使用範例程式

Dim indexEnd As Integer Dim valueAttribute As String Dim valueContain As String Dim url As String = "http://allen080.blogspot.com/2009/05/vbnet20.html" '使用WebRequest的Get方法取得整個網頁的HTML 'Dim htmlAll As String = WebPageGenFunc.getHTMLGet(url) '取得網頁Body的部份 Dim htmlBody As String = WebPageGenFunc.getHTMLBody(url) If Not htmlBody Is Nothing Then indexEnd = htmlBody.IndexOf("") valueAttribute = Nothing valueContain = Nothing If indexEnd > 0 Then htmlBody = htmlBody.Substring(indexEnd) '取得a標籤1的內容 WebPageGenFunc.getHTMLTagContain(htmlBody, "span", valueContain, indexEnd) Console.WriteLine("span標籤的內容: " & valueContain) 'htmlBody = htmlBody.Substring(indexEnd) '取得a標籤2的內容與href的屬性 WebPageGenFunc.getHTMLTagAtt(htmlBody, "a", "onclick", valueAttribute, valueContain, indexEnd) Console.WriteLine("a標籤的內容與onclick的屬性: " & valueAttribute & vbTab & ",內容:" & valueContain) End If End If '使用WebClient的Post方法取得資料 url = "http://al080.summerhost.info/invoiceMe/index.php" Dim searchStr As String = "123" Dim postdata As New Specialized.NameValueCollection postdata.Add("ddlYear", "2009") postdata.Add("ddlMonth", "7-8") postdata.Add("txtInvNO", searchStr) postdata.Add("btnMatchInv", "對獎") htmlBody = WebPageGenFunc.getHTMLBody(url, , postdata) If Not htmlBody Is Nothing Then indexEnd = htmlBody.IndexOf("<div class=""DivRight"">") If indexEnd > 0 Then htmlBody = htmlBody.Substring(indexEnd) '取得div標籤的內容 WebPageGenFunc.getHTMLTagContain(htmlBody, "div", valueContain, indexEnd) Console.WriteLine("使用WebClient的Post方法取得資料: " & valueContain) End If End If '使用WebRequest的Post方法取得資料 searchStr = String.Empty '在組合參數時要同時編碼 For i As Integer = 0 To postdata.Count - 1 searchStr &= "&" & postdata.GetKey(i) & "=" & WebPageGenFunc.getEncodeStr(postdata(i)) Next searchStr = searchStr.Substring(1) htmlBody = WebPageGenFunc.getHTMLBody(url, searchStr) If Not htmlBody Is Nothing Then indexEnd = htmlBody.IndexOf("<div class=""DivRight"">") If indexEnd > 0 Then htmlBody = htmlBody.Substring(indexEnd) '取得div標籤的內容 WebPageGenFunc.getHTMLTagContain(htmlBody, "div", valueContain, indexEnd) Console.WriteLine("使用WebRequest的Post方法取得資料: " & valueContain) End If End If

執行結果

span標籤的內容: <a class='quickedit' href='http://www.blogger.com/rearrange?blogID=2698062899592178296&widgetType=HTML&widgetId=HTML1&action=editWidget' onclick='return _WidgetManager._PopupConfig(document.getElementById("HTML1"));' target='configHTML1' title='編輯'> <img alt='' height='18' src='http://img1.blogblog.com/img/icon18_wrench_allbkg.png' width='18'/> </a> a標籤的內容與onclick的屬性: return _WidgetManager._PopupConfig(document.getElementById("HTML1")); ,內容: <img alt='' height='18' src='http://img1.blogblog.com/img/icon18_wrench_allbkg.png' width='18'/> 使用WebClient的Post方法取得資料: 對獎結果： <div class="DivResult"> 無中獎發票... </div> 使用WebRequest的Post方法取得資料: 對獎結果： <div class="DivResult"> 無中獎發票... </div>

[程式]VB.Net2.0資料庫通用存取函式

2009-04-20T22:25:00.000-07:00

序言

在VS2005建立VB專案(或Web網站)後，若要進行資料庫存取，我個人比較習慣將連線字串寫在設定檔app.config(或web.config)下。

不過VB專案預設是不會產生這個檔，而且在程式中若要取得連線字串的設定也要對專案的參考進行設定。

以下記錄下我做的設定，並把資料庫存取程式簡化為函式。

開發環境

VB.Net 2.0 (VS2005)
MSSQL2005 Express

專案設定

建立專案後預設的專案屬性下，參考的元件如下圖：
下面的程式中會用到【ConfigurationManager】這個物件來取得設定檔的連線字串，所以我們需要加入【System.Configuration】這個元件：

點選加入，在.Net分頁下找到【System.Configuration】這個元件
再來要在專案加入新項目【應用程式組態】，名稱用預設的【app.config】就可以了：
編輯app.config，在【configuration】標籤內加入連線字串的設定如：

<?xml version="1.0" encoding="utf-8" ?> <configuration> ... <connectionStrings> <add name="MSSQLDB1" connectionString="Data Source=localhost;Initial Catalog=MyTestDB;Integrated Security=True" providerName="System.Data.SqlClient" /> <add name="MSSQLDB2" connectionString="Data Source=127.0.0.1;Initial Catalog=MyTestDB;User ID=sa;Password=1234" providerName="System.Data.SqlClient" /> </connectionStrings> ...

通用存取函式類別

Imports System.Data.SqlClient Imports System.Configuration Public Class DBAccessFunc ''' <summary> ''' 從ConfigurationManager中的ConnectionStrings找出Initial Catalog ''' </summary> ''' <param name="ConnName">ConnectionStrings名稱(String)</param> ''' <returns>回傳資料庫名稱</returns> ''' <remarks>從ConfigurationManager中的ConnectionStrings找出Initial Catalog</remarks> Public Shared Function getDBName(ByVal ConnName As String) As String Dim val As String = "" Dim ConnString As String = ConfigurationManager.ConnectionStrings(ConnName).ConnectionString Dim i As Integer = ConnString.IndexOf("Initial Catalog=") If i > -1 Then val = ConnString.Substring(i + "Initial Catalog=".Length) i = val.IndexOf(";") If i > -1 Then val = val.Substring(0, i) End If End If Return val End Function Public Shared Function getConnString(ByVal ConnName As String) As String Return ConfigurationManager.ConnectionStrings(ConnName).ConnectionString End Function Public Shared Function getConn(ByVal ConnName As String) As SqlConnection Return New SqlConnection(getConnString(ConnName)) End Function ''' <summary> ''' 查詢資料庫 ''' </summary> ''' <param name="cn">連線</param> ''' <param name="sql">查詢內容</param> ''' <returns>回傳查詢結果的DataTable</returns> ''' <remarks>查詢資料庫並回傳查詢結果的DataTable</remarks> Public Shared Function getTable(ByRef cn As SqlConnection, ByRef sql As String, Optional ByVal isColseConn As Boolean = True) As Data.DataTable Dim da As New SqlDataAdapter(sql, cn) Dim dt As New Data.DataTable("dt_xml") Try If cn.State = ConnectionState.Closed Then cn.Open() da.SelectCommand.CommandTimeout = 36000000 da.Fill(dt) Catch ex As Exception If isColseConn And cn.State = ConnectionState.Open Then cn.Close() Throw ex End Try If isColseConn And cn.State = ConnectionState.Open Then cn.Close() Return dt End Function ''' <summary> ''' 執行命令 ''' </summary> ''' <param name="cn">連線</param> ''' <param name="sql">查詢內容</param> ''' <returns>回傳受影響的資料筆數</returns> ''' <remarks>執行命令並回傳受影響的資料筆數</remarks> Public Shared Function doCmd(ByRef cn As SqlConnection, ByRef sql As String, Optional ByRef param() As SqlParameter = Nothing, Optional ByVal isColseConn As Boolean = True) As Integer Dim result As Integer = 0 Dim cmd As New SqlCommand Try cmd.Connection = cn cmd.CommandText = sql If Not param Is Nothing Then cmd.Parameters.AddRange(param) End If cmd.CommandTimeout = 36000000 If cn.State = ConnectionState.Closed Then cn.Open() result = cmd.ExecuteNonQuery() Catch ex As Exception cmd.Parameters.Clear() If isColseConn And cn.State = ConnectionState.Open Then cn.Close() Throw ex Finally cmd.Parameters.Clear() If isColseConn And cn.State = ConnectionState.Open Then cn.Close() End Try Return result End Function ''' <summary> ''' 取得單一資料 ''' </summary> ''' <param name="cn">連線</param> ''' <param name="sql">查詢內容</param> ''' <returns>回傳受影響的資料筆數</returns> ''' <remarks>執行命令並回傳受影響的資料筆數</remarks> Public Shared Function doScalar(ByRef cn As SqlConnection, ByRef sql As String, Optional ByRef param() As SqlParameter = Nothing, Optional ByVal isColseConn As Boolean = True) As Object Dim result As Object = Nothing Dim cmd As New SqlCommand Try cmd.Connection = cn cmd.CommandText = sql If Not param Is Nothing Then cmd.Parameters.AddRange(param) End If cmd.CommandTimeout = 36000000 If cn.State = ConnectionState.Closed Then cn.Open() result = cmd.ExecuteScalar() Catch ex As Exception cmd.Parameters.Clear() If isColseConn And cn.State = ConnectionState.Open Then cn.Close() Throw ex Finally cmd.Parameters.Clear() If isColseConn And cn.State = ConnectionState.Open Then cn.Close() End Try Return result End Function Public Function executeStoredProcedure(ByRef cn As SqlConnection, ByVal procedure As String, Optional ByRef param As SqlParameter() = Nothing, Optional ByRef output As SqlParameter() = Nothing, Optional ByVal isColseConn As Boolean = True) As Integer Dim result As Integer = 0 Dim cmd As New SqlCommand(procedure, cn) Try cmd.CommandText = procedure cmd.CommandTimeout = 36000000 cmd.CommandType = CommandType.StoredProcedure If Not param Is Nothing Then cmd.Parameters.AddRange(param) If Not output Is Nothing Then For Each o As SqlParameter In output o.Direction = ParameterDirection.Output Next cmd.Parameters.AddRange(output) End If '開啟資料庫連線 If cn.State = ConnectionState.Closed Then cn.Open() '設定變數儲存受影響資料列 result = cmd.ExecuteNonQuery() Catch ex As Exception cmd.Parameters.Clear() If isColseConn And cn.State = ConnectionState.Open Then cn.Close() Throw ex Finally cmd.Parameters.Clear() If isColseConn And cn.State = ConnectionState.Open Then cn.Close() End Try Return result End Function End Class

使用範例程式

Dim connStr1 As String = DBGenFunc.getConnStr("MSSQLDB1") Dim sourceTable As String() = {"[" & DBGenFunc.getDBName("MSSQLDB1") & "].[dbo].[" & "MyTestTab" & "]", _ "[" & DBGenFunc.getDBName("MSSQLDB1") & "].[dbo].[" & "MyContentTab" & "]"} Dim param() As SqlClient.SqlParameter = {New SqlClient.SqlParameter("P0", SqlDbType.VarChar)} Dim sql As String Dim title As String Console.WriteLine("doCmdScalar Start:") sql = "SELECT Title" & vbCrLf & _ " FROM " & sourceTable(0) & "" & vbCrLf & _ " WHERE SN=@P0" param(0).Value = 1 title = DBGenFunc.doCmdScalar(connStr1, sql, param) Console.WriteLine("doCmdScalar" & vbTab & title) Console.WriteLine("getTable Start:") sql = "SELECT Title" & vbCrLf & _ " FROM " & sourceTable(0) & "" & vbCrLf Dim dt As DataTable = DBGenFunc.getTable(connStr1, sql) For Each r As DataRow In dt.Rows title = r.Item(0) Console.WriteLine("getTable" & vbTab & title) Next Console.WriteLine("getTableToArray Start:") Dim data As String() = DBGenFunc.dataTableToArray(Of String)(dt, 0) For Each r As String In data title = r Console.WriteLine("getTable" & vbTab & title) Next Console.WriteLine("doCmd Start:") sql = "INSERT INTO " & sourceTable(0) & "" & vbCrLf & _ "VALUES(@P0,@P1)" param = New SqlClient.SqlParameter() {New SqlClient.SqlParameter("P0", SqlDbType.VarChar), _ New SqlClient.SqlParameter("P1", SqlDbType.VarChar)} param(0).Value = "TNew" param(1).Value = "SNew" title = DBGenFunc.doCmd(connStr1, sql, param) Console.WriteLine("doCmd" & vbTab & title) Console.WriteLine("getReader Start:") sql = "SELECT Title, Subject" & vbCrLf & _ " FROM " & sourceTable(0) & "" & vbCrLf Dim dr As SqlClient.SqlDataReader = DBGenFunc.getReader(connStr1, sql) While dr.Read() title = dr.Item(0) Console.WriteLine("getReader" & vbTab & title & vbTab & dr.Item(1)) End While DBGenFunc.closeReader()

執行結果

doCmdScalar Start: doCmdScalar T1 getTable Start: getTable T1 getTable T2 getTable T3 getTable TNew getTableToArray Start: getTable T1 getTable T2 getTable T3 getTable TNew doCmd Start: doCmd 1 getReader Start: getReader T1 S1 getReader T2 S2 getReader T3 S3 getReader TNew SNew getReader TNew SNew

[筆記]我的FireFox愛用套件

2009-03-12T20:23:00.000-07:00

序言

此篇記下我常用的套件相關連結，方便安裝使用。

清單

FireFox主程式(我都用Portable版不用安裝)：
FireFox Portable by portableapps.com
Foxmarks：官網。書籤同步，可至官網直接登入瀏覽你的書籤。
FireGestures：滑鼠手式(控制上一頁下一頁等)。
QuickDrag：用拖曳手勢更容易地在新分頁裡打開連結、搜尋文字和儲存圖片。
新同文堂：官網。中文繁簡體互轉工具。
Tab Mix Plus：官網。分頁加強版。
Mozilla Archive Format：MHT (MHTML) 檔案開啟外掛。
Copy Links：方便複製連結。
FacePad：Facebook相簿下載(安裝後於相簿連結點右鍵可以看到功能)。
Greasemonkey：官網。客製化網頁Script功能。搭配以下Script。

Plurk Smile：plurk表情外掛。
RePlurk：plurk轉發。
RS_Bundle：方便下載Rapidshare。
MU Bundle：方便下載Megaupload。
Download ANY Video from YouTube：方便下載YouTube。
其他熱門Script

FlashGot：官網。搭配其他下載工具用。
PCmanfx：官網。上BBS。
Profile Manager and Synchronizer ：多帳號登入。

[教學]設定MSN防毒為小紅傘

2008-12-06T06:29:00.000-08:00

序言

不想廢話(這篇應該是目前我在這個Blog最短的一篇文章)，總之這樣設定MSN(Live Messenger)傳檔案時就會用小紅傘(Avira AntiVir)掃毒。

步驟

於MSN的【工具】→【選項】→【檔案傳輸】勾選【使用下列軟體進行病毒掃描】
在下面的路徑欄位填上：
"C:\Program Files\AntiVir PersonalEdition Classic\avscan.exe" /GUIMODE=2 /PATH=%FILE%

[教學]重灌/換主機板超好用技術-MergeIDE

2008-10-25T10:43:00.000-07:00

序言

雖然廢話一堆的教學文章是不行的~不過我還是習慣開場說說我研究這個免重灌的原因~

就是當每天都有修不完的電腦~而且還每台都要做差不多的設定與軟體安裝後~

我就開始想找出可以不用每次都重灌的方法~

最終試的結果就是用我下面談的MergeIDE來設定囉~

當然，這個方法也可以用在換電腦時，不過我在下面第一步就回提到換電腦時用這個方法不一定會成功的原因。

工作大綱

挑電腦來安裝Windows
將Windows該裝軟體該設定的都弄好
刪掉不必要的檔案(非必要)
進裝置管理員變更電腦與匯流排驅動為標準，並刪除不必要裝置
執行MergeIDE，並覆蓋4個IDE硬體驅動檔
關機後即可製作Ghost檔(非必要)
在新電腦開機後，更新第一個標準電腦的驅動再重新開機
安裝新電腦的驅動
關機後再製作Ghost檔(非必要)

1.挑電腦來安裝Windows

這時候又要廢話一下了~為什麼要挑電腦勒?

因為根據我手邊供我試驗的很多很多台電腦的使用經驗，

A主機板所安裝的Windows使用MergeIDE法可使轉移到B主機板運作時，

B主機板所安裝的Windows卻不一定能以同樣方式轉移到A主機板~

因此，挑主機板就十分運氣了~

以我為例，我目前挑到相容性最高的主機是HP Compaq dc5750的套裝主機，它內建的是AMD64位元的CPU~

但我建議如果沒有很多主機可以試，也可以試試使用VMWare建立雙CPU的虛擬主機來裝Windows，效果可能也不錯~

2.將Windows該裝軟體該設定的都弄好

這不用說，當然就是裝上各電腦你需要的軟體與設定~

也可以把所有的更新更新完(手動下載更新檔可參考下載Windows更新檔的工具by EcStart PHP 技術討論論壇)

3.刪掉不必要的檔案(非必要)

因為要減小Ghost後的大小，可以刪除些非必要的檔案:

到【控制台】→【系統】→【系統還原】把系統還原關閉。

刪掉所有暫存區的檔案(可參考大掃除~用批次檔清理電腦)

清除系統文件保護暫存檔，以命令提示字元執行【sfc.exe /purgecache】

4.進裝置管理員變更電腦與匯流排驅動為標準，並刪除不必要裝置

【開始】→【執行】→輸入【devmgmt.msc】/或至【控制台】→【系統管理工具】→【電腦管理】，開啟【裝置管理員】

展開【IDE ATA/ATAPI控制器】分類，如果裡面的IDE控制器不是【標準的雙通道 PCI IDE控制器】，請更新驅動為標準的雙通道 PCI IDE控制器。以右鍵點選IDE控制器的【更新驅動程式】，在打開的【硬體更新精靈】裡選【從列表或指定位置安裝（進階）】選項，並選【不要搜索，我要自己選擇要安裝的驅動程式】，然後選【雙通道 PCI IDE控制器】。再選【否】不重開機。

展開【電腦】分類，以右鍵點選ACPI選【更新驅動程式】，在打開的【硬體更新精靈】裡選【從列表或指定位置安裝（進階）】選項，並選【不要搜索，我要自己選擇要安裝的驅動程式】，然後選【標準電腦】(Standard PC)

同上述方法將【處理器】分類下的CPU改為【處理器】

刪除其他普通驅動程式，如網絡介面卡，滑鼠右鍵單擊其下的網路設備名稱，在彈出菜單上單擊【解除安裝】選項，再用類似的方法卸載通用序列匯流排控制器、音效視訊遊戲控制器、顯示卡、音效卡等設備驅動程式。這裡要注意的是，如果系統提示需要重新啟動，一定【不要】重啟機器

5.執行MergeIDE，並覆蓋4個IDE硬體驅動檔

從將 Windows XP 系統磁片移到另一部電腦之後，收到 Stop 0x0000007B 錯誤(By Microsoft技術支援服務)

這篇文章就可以看到MergeIDE檔的製作方式，網路上也有人用批次檔寫說可以直接將windows裡面的4個IDE硬體驅動檔複製出來用的方法。

而我這邊比較偏好直接用下載後的4個IDE硬體驅動檔來覆蓋，因為有的Windows會找不到這四個檔的原始檔。

我將所有需要的檔案與解壓縮路徑預設好，只要下載Winxpsys執行就可以了。

6.關機後即可製作硬碟映象檔(非必要)

這個映像檔理論上在新電腦就可以用了，不過如同第1部所言，這要看運氣。

7.在新電腦開機後，更新第一個標準電腦的驅動再重新開機

開機後他會開始裝各硬體的驅動程時，如果中間有跳出要求驅動程式的視窗，直接取消不用理他~

因為下一步驟重開後他還是會再重新裝一次驅動程式。

【開始】→【執行】→輸入【devmgmt.msc】，開啟裝置管理員
展開【電腦】分類，會有兩個標準電腦。以右鍵點選第一個標準電腦，選【更新驅動程式】，依直按下一步讓它安裝適合這台電腦的ACPI

重新開機

8.安裝新電腦的驅動

到裝置管理員移除第二個標準電腦，並且安裝所有這台電腦的驅動後，就完成移機了。

9.關機後再製作硬碟映象檔(非必要)

為什麼之前做過硬碟映象，現在又做一次?

根據我的試驗，這時候的作業系統就變成拿到別台還是能開機來用，所以感覺很像能到處使用，不過我還沒能完整驗證。

所以大家有興趣可以直接拿這個版本的映像檔來玩玩看，就可以再少掉每次到新電腦還要作第7步的動作了。

結論

如前面所言，這是我試過n台電腦後的結果，歡迎大家告訴我更好的做法~

我想這個技術對好人卡收很多的人也有用~哈哈~

[教學]Windows初始安裝設定

2008-10-24T01:28:00.000-07:00

(此篇文章於2006/11/11首次發表，最後一次修改於2008/10/24)

序

雖然身為資工人，Windows的安裝簡直是如同喝水一般~

不過我還滿想記下一些我常做的動作，當做提醒自己還有哪些動作忘了做~

PS.常用工具的部分我從這篇分離了

Windows XP安裝過程中

網路上看到了安裝過程的簡介，如果第一次安裝可參考這篇【淺談Windows新安裝】
在安裝過程中預設會要求輸入第一個使用者帳號。如果要跳過這個動作，只要按【Shift+F10】就會跳出命令提示字元的視窗。然後輸入【taskmgr】叫出工作管理員，就可以把這個初始設定的程式關掉，讓Windows預設以Administrator帳號進入。
一般而言，如果懂得保養，系統碟給個15~20G就很夠用了，其他的可能分割為備份與資料碟
設定網路通訊協定時，新增【IPX】通訊協定，如此比較容易找到附近的網芳
開啟防火牆

剛安裝完Windows XP

使用Windows Update先更新所有需要更新的修正，以防被病毒攻擊
統一暫存資料夾，方便未來刪除更改暫存檔儲存目錄，清理磁碟機更容易~ 滑鼠右點〔我的電腦〕→〔內容〕→〔進階〕→〔環境變數〕將〔用戶名的使用者變數〕及〔系統變數〕中的〔temp〕及〔tmp〕的變數選〔編輯〕將〔變數值〕統一改為〔%SystemRoot%\Temp〕日後所有暫存檔將統一存放在 X:\Windows\Temp 的目錄下
安裝防毒軟體，並設定每日更新：檔案→排程更新
移動IE的暫存資料夾選擇IE的【工具】→【網際網路選項】→Temporary Internet files【設定】→【移動資料夾】→選到【X:\Windows\Temp】
我通常重視效能多過外觀，所以設定【系統】→【進階】→效能【設定】→【調整成最佳效能】
【控制台】→【新增及移除程式】→【新增/移除Windows元件】→取消勾選【Windows Messenger】
如果常會用記事本開檔，可下載這個，執行後，右鍵點檔案會多個用記事本開啟
移動特殊資料夾有些資料夾可利用此方式不要放在系統碟。預設的桌面、我的最愛等，放在【%USERPROFILE%】中。只要在檔案總管選擇這些資料夾，然後選擇【編輯】→【移到資料夾】，然後找個資料碟的資料夾就可以了。

遠端桌面

設定【系統】→【遠端】→【允許使用者遠端連線到這部電腦】
【控制台】→【Windows 防火牆】→【例外】→勾【遠端桌面】
更改遠端連線連接埠：
1. 【開始】→【執行】輸入【regedit】啟動「登錄編輯程式」。
2. 找出並按一下下列登錄子機碼：【HKEY_LOCAL_MACHINE\System\CurrentControlSet\Control\TerminalServer\WinStations\RDP-Tcp\PortNumber】
3. 在 [編輯] 功能表上，按一下 [修改]，再按一下 [十進位]。
4. 輸入新的連接埠編號(預設是3389)，然後按一下 [確定]。
5. 結束「登錄編輯器」。
6. 【控制台】→【Windows 防火牆】→【例外】→【新增連接埠】→輸入妳設定的port
如果在比較舊的Windows上沒有遠端連線工具如，Win2000，請參考
連線時如果有改Port，就在IP後加【:port】，如【a.b.c.d:1234】

用XP架IIS與FTP

擴充連線數量
安裝IIS
安裝.Net framework 2.0
【控制台】→【Windows 防火牆】→【例外】→【新增程式】 C:\WINDOWS\system32\inetsrv\inetinfo.exe
安裝SQL 2005 Express
安裝FTP Server(我目前覺得Gene6 FTP Server最好用，可惜不是Freeware)
【控制台】→【Windows 防火牆】→【例外】→【新增程式】 ftp server的路徑
如果是動態IP，可用NO-IP(教學)

參考連結

[教學]給我Live Spaces訪客留言的RSS吧(用Feed43把網頁轉RSS)

2008-10-10T10:27:00.000-07:00

此文首發於2007/07/11 20:27 於2008/10/10更新內容

序

首先，雖然不知道RSS融入了多少人的生活~不過我真的覺得RSS是我取得最新資訊的好工具~

話說身為RSS重度使用者的我，把生活與心情的東西用微軟的Live Spaces記錄。

姑且不論Live Spaces速度有點慢這個問題~也不論沒辦法用RSS訂閱最新的文章回應~~(因為上一篇有談到國良大大用Yahoo Pipes解決了這個問題)~~(Yahoo Pipes中可搜尋到有人有解決的pipe)~但是它新推出的訪客留言功能居然沒有提供RSS~這樣我怎麼知道有新留言呢~我可不想一直按那個重新整理的按鈕~

所以我就試了幾個免費的服務~最後找到了Feed43這個網站來把我的訪客留言變成RSS Feed~

PS. 最近頁面html有修改~我更新了一下語法~圖沒更新

怎麼做

首先到Feed43選擇【Create your own feed】

輸入要轉為RSS Feed的網址，如我的留言板：http://al080.spaces.live.com/guestbook/

然後點選【Reload】

這時下面會出現網頁的原始碼給大家參考

再來的步驟為輸入轉換的規則，目前Live Spaces的訪客留言板規則如下，將下面這傳碼複製到【Item (repeatable) Search Pattern】

<input type="hidden" id="sn_ccIdCommentControl{%}" value={*}<span dir='ltr'>{%}</span>{*}<div class="Comment" id="sn_ccHtmlCommentControl{*}">{%}</div>{_}</div>{_}<div class="ccDateBox{*}">{*}<span class="ccColor2">{%}</span>

輸入後點選【Extract】，下面就會出現分析的結果

接著到【RSS item properties】下輸入以下欄位內容：

Item Title Template：【{%4} (author: {%2})】

Item Link Template：【http://留言板網址/#sn_ccIdCommentControl{%1}】，如【http://al080.spaces.live.com/guestbook/#sn_ccIdCommentControl{%1}】

Item Content Template：

<div>{%3}</div>

<div>&nbsp;</div>

<div align="right">{%4}</div>

然後點選【Preview】，就可以看到產生的RSS Feed結果

最後你就可以看到Feed的網址，你可以點選【Change file name】讓Feed的網址比較容易記

並且要記得選【Change feed edit password】來設定這個Feed的修改密碼~

結語

雖然這樣就能擁有RSS Feed，不過這樣的做法是治標不治本~

首先因為Feed43產生的Feed沒有時間的欄位~而且如果哪天Live Spaces改掉訪客留言的版面~我們也要跟著修改轉換的規則~

所以還是請大家有需要的人多寫幾封建議信去給網站讓他們提供RSS吧~

用 Feed43 服務作三少四壯集的 feed by Reflection

將 Web 轉為 RSS - Feed43.com by 藍魚昕屋

倫倫3號Beta-Log

[MS-SQL]不具自動容錯移轉的鏡像設定

序

環境

SQL Server服務啟動帳號設定

主體伺服器備份

還原資料到鏡像伺服器

於主體伺服器啟動鏡像服務

[C#]MS-SQL資料庫存取函式

序言

環境

存取函式類別

[C++]Oracle資料庫存取函式(OCCI)

開發環境

下載OCCI函式庫

設定開發專案

資料庫連線函式庫

使用範例

[C++]MySQL資料庫存取函式(MySQL++)

序言

環境

編譯MySQL++函式庫

設定開發專案

資料庫連線函式庫

使用範例

[C++]Http Get與Post函式(Curl)

序言

開發環境

編譯Curl函式庫

設定開發專案

Http連線函式庫

使用範例程式

[Java]Http Get與Post函式2(HttpURLConnection)

序言

函式原始碼

使用範例程式

[CentOS]JBoss5.1安裝

序言

環境

安裝步驟

[CentOS]JDK(Java)安裝

序言

環境

安裝步驟

[CentOS]MySQL安裝

序言

環境

安裝步驟

[4Shared]網路硬碟上傳下載教學(Desktop程式版)

序言

服務限制

桌面程式安裝與帳號申請

上傳教學

下載教學

總結

相關連結

[Java]Http Get與Post函式(Apache HttpClient)

序言

下載套件

函式原始碼

使用範例程式

總結

[JBoss]Java的工作排程套件-Quartz

序言

開發環境

JBoss設定

Quartz設定檔

工作類別

排程工作

在應用程式第一次被呼叫時排程工作

總結

參考資料

[Java]MySQL/Oracle資料庫存取函式

序言

原始碼函式類別

使用範例程式

總結

相關文章

[JAAS] JBoss下動態網站使用資料庫設定認證授權

序言