wizard ⓝ think...

| 웹프로그래밍

WRITTEN BY : 윤영식 | URL : http://wizard.ncafe.net

2006-11-02 14:10:46 | 조회 : 4,631

[FEED]

Weblogic + Oracle 로 개발된 시스템을
Tomcat + sybase 로 바꾸며 "Weblogic으로 개발할때 쓰던 DBConnction Class 소스" 를 바꾼것...

그땐 열심히 oracle로만 개발하다가 전 회사에서 퇴사를 맘먹고 있을쯔음.. Sybase로 바꿔야 한다해서 급조된 소스...


import java.sql.*;

import java.io.*;

import java.util.*;

import com.sybase.jdbc2.jdbc.*;

import com.sybase.jdbc2.*;



/**    

    Sybase DBconnection Class<br>

    Developer : wizard <br>

    Email : <a href="mailto:wizard@ncafe.net">wizard@ncafe.net</a> <br>

    Personal Homepi : <a href="http://wizard.ncafe.net" target="_blank">http://wizard.ncafe.net</a> <br>

    Last UpDate : November. 15. 2001. Thursday */

    

public class DBconn {

    private Connection connection;

    private Statement statement;

    private LogFile log;

    

    public DBconn(){

        log = new LogFile();

        try {

            Class.forName("com.sybase.jdbc2.jdbc.SybDriver");

        } catch(Exception me) {

            log.errLog("Err Class : DBconn.class");

            log.errLog("DriverManager Error : "+me.getMessage());

        }

        

        try {

            connection = DriverManager.getConnection("jdbc:sybase:Tds:10.1.1.1:3800/xbi","id","pwd");

            try {

                statement=connection.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);

            } catch(SQLException e) {

                log.errLog("Err Class : DBconn.class");

                log.errLog("createStatement Error : "+e.getMessage());

                if (connection!=null) {

                    try {

                        connection.close();

                    } catch(SQLException ce) {

                        log.errLog("Err Class : DBconn.class");

                        log.errLog("Connection Close Error : "+ce.getMessage());

                    }

                }

            }

        } catch(SQLException e){

            log.errLog("Err Class : DBconn.class");

            log.errLog("getConnection Error : "+e.getMessage());

        }

    }



    /** ResultSet 을 구함 */

    public ResultSet executeQuery(String sql) throws SQLException{

        return statement.executeQuery(sql);

    }

    

    /** Update 나 Delete, Create, Drop 등을 위한 Methed */

    public int executeUpdate(String sql) throws SQLException{

        return statement.executeUpdate(sql);

    }

    

    /** 항상 clean() 을 해줘야 합니다. */

    public void clean(){

        if (statement!=null) {

            try {

                statement.close();

            } catch(SQLException e) {

                log.errLog("Err Class : DBconn.class");

                log.errLog("statement Close Error : "+e.getMessage());

            }

        }

        if (connection!=null) {

            try {

                connection.close();

            } catch(SQLException e) {

                log.errLog("Err Class : DBconn.class");

                log.errLog("Connection Close Error : "+e.getMessage());

            }

        }

    }

}


	이 저작물은 정보공유 라이센스 2.0 : 영리금지·개작금지에 따라 이용하실수 있습니다.

태그 : Sybase, DBConn, Java, JSP

| 댓글(0) | 엮인글(0) | 삭제 | 수정 |

※ 트랙백 주소 : http://wizard.ncafe.net/wt/tb/2310 [주소복사]

※ 댓글을 남겨주세요.

(☜ Password : 삭제시 필요합니다.)

(※ 보안글자를 입력해 주세요!)

| 웹프로그래밍

WRITTEN BY : 윤영식 | URL : http://wizard.ncafe.net

2006-11-02 13:30:38 | 조회 : 4,139

[FEED]

언제쩍 소스인가? 헐....

Weblogic 으로 개발할때 쓰던 DBConnection Class 소스...


import java.sql.*;



/**    DBConnection <br>

    Last UpDate :August. 7. 2001. Tuesday.<br>

    Developer : Young Sick. Yoon <<a href="mailto:wizard@ncafe.net">wizard@ncafe.net</a>><br>*/

    

public class DBconn {

    private Connection connection;

    private Statement statement;

    private LogFile log;

    

    public DBconn(){

        log = new LogFile();

        try {

            Class.forName("weblogic.jdbc20.pool.Driver").newInstance();

        } catch(Exception me) {

            log.errLog("Err Class : DBconn.class");

            log.errLog("DriverManager Error : "+me.getMessage());

        }

        

        try {

            connection = DriverManager.getConnection("jdbc20:weblogic:pool:irisPool");

            try {

                statement=connection.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);

            } catch(SQLException e) {

                log.errLog("Err Class : DBconn.class");

                log.errLog("createStatement Error : "+e.getMessage());

                if (connection!=null) {

                    try {

                        connection.close();

                    } catch(SQLException ce) {

                        log.errLog("Err Class : DBconn.class");

                        log.errLog("Connection Close Error : "+ce.getMessage());

                    }

                }

            }

        } catch(SQLException e){

            log.errLog("Err Class : DBconn.class");

            log.errLog("getConnection Error : "+e.getMessage());

        }

    }



    /** ResultSet 을 구함 */

    public ResultSet executeQuery(String sql) throws SQLException{

        return statement.executeQuery(sql);

    }

    

    /** Update 나 Delete, Create, Drop 등을 위한 Methed */

    public int executeUpdate(String sql) throws SQLException{

        return statement.executeUpdate(sql);

    }

    

    /** 항상 clean() 을 해줘야 합니다. */

    public void clean(){

        if (statement!=null) {

            try {

                statement.close();

            } catch(SQLException e) {

                log.errLog("Err Class : DBconn.class");

                log.errLog("statement Close Error : "+e.getMessage());

            }

        }

        if (connection!=null) {

            try {

                connection.close();

            } catch(SQLException e) {

                log.errLog("Err Class : DBconn.class");

                log.errLog("Connection Close Error : "+e.getMessage());

            }

        }

    }

}


	이 저작물은 정보공유 라이센스 2.0 : 영리금지·개작금지에 따라 이용하실수 있습니다.

태그 : 웹로직, weblogic, Java, JSP, DBConn

| 댓글(0) | 엮인글(0) | 삭제 | 수정 |

※ 트랙백 주소 : http://wizard.ncafe.net/wt/tb/2307 [주소복사]

※ 댓글을 남겨주세요.

(☜ Password : 삭제시 필요합니다.)

(※ 보안글자를 입력해 주세요!)

| 웹프로그래밍

WRITTEN BY : 윤영식 | URL : http://wizard.ncafe.net

2006-10-18 17:49:59 | 조회 : 5,514

[FEED]

현재 본페이지에서 쓰이고 있는 나만의 DB Connection Class

주석이 없다.. 나만 쓸려고 만들어 놓은거라서...
관련되서 공부하고자 하는 분들이 있으면 참고하시라...

#DBConn.Class.php


<?

    /***************************************************************

    프로그램명    : DBConn Class

    작성자        : 윤영식 (2006-02-17 오후 5:07)

    설명            : DataBase Connection Class (Oracle, MySQL)

    ***************************************************************/



    Class DBConn {



        const MYSQL = 1;

        const ORACLE = 2;



        private $connection;



        private $dbType;

        private $dbHost;

        private $dbPort;

        private $dbSID;

        private $dbName;

        private $dbUser;

        private $dbPassword;

        private $dbCharset;





        function __construct($URI) {

    

            $this->parseURI($URI);



            try {

                $this    ->Connection();



            } catch (Exception $e) {

                echo $e->getMessage();



                $this->__destruct();

            }

        }



        function __destruct() {



            if ($this->dbType==MYSQL) {

                @mysql_close($this->connection);

            } else if ($this->dbType==ORACLE) {

                @oci_close($this->connection);

            }

        }



        private function parseURI($URI) {



            $URI = str_replace("#","_sp_",$URI);

            //$mysql_uri = "mysql://localhost:3306/?dbname=meris&username=meris&password=meris&charset=euckr";

            //$oracle_uri = "oracle://localhost:1521/?sid=ora10g&username=meris&password=meris&charset=";



            $exp = parse_url ($URI);



            if (strtolower($exp[scheme])=="mysql") {

                $this->dbType=MYSQL;

            } else if (strtolower($exp[scheme])=="oracle") {

                $this->dbType=ORACLE;

            }



            $this->dbHost = $exp[host];

            $this->dbPort = $exp[port];



            parse_str($exp[query]);



            $this->dbSID = str_replace("_sp_","#",$dbsid);

            $this->dbName = str_replace("_sp_","#",$dbname);

            $this->dbUser = str_replace("_sp_","#",$username);

            $this->dbPassword = str_replace("_sp_","#",$password);

            $this->dbCharset = str_replace("_sp_","#",$charset);

        }



        function freeStatement($stmt) {

            if ($this->dbType==MYSQL) {

                @mysql_free_result($stmt);

            } else if ($this->dbType==ORACLE) {

                @oci_free_statement($stmt);

            }

        }



        private function Connection() {

            if ($this->dbType==MYSQL) {

                if (!$this->connection=@mysql_connect($this->dbHost,$this->dbUser,$this->dbPassword)) {

                    throw new Exception(mysql_error());

                }

                

                if(!mysql_select_db($this->dbName,$this->connection)){

                    throw new exception(mysql_error());

                }  

                

                if ($this->dbCharset) {

                    @mysql_query("set session character_set_connection=".$this->dbCharset.";");

                    @mysql_query("set session character_set_results=".$this->dbCharset.";");

                    @mysql_query("set session character_set_client=".$this->dbCharset.";");



                }



            } else if ($this->dbType==ORACLE) {

                if (!$this->connection = @oci_connect($this->dbUser,$this->dbPassword,$this->dbSID,$this->dbCharset)) {

                    $error = oci_error();

                    throw new Exception($error[message]);

                }



            } else {

                throw new Exception("No such DB Type".$this->dbType);

            }

        }



        function getConnection() {

            return $this->connection;

        }



        function destroyConnection() {

            if ($this->dbType==MYSQL) {

                @mysql_close($this->connection);

            } else if ($this->dbType==ORACLE) {

                @oci_close($this->connection);

            }

        }



        function execute($sql,$flag=OCI_COMMIT_ON_SUCCESS) {

            if ($this->dbType==MYSQL) {

                if (!$stmt = @mysql_query($sql,$this->connection)) {

                    echo mysql_error();

                    return false;

                } else {

                    return $stmt;

                }

            } else if ($this->dbType==ORACLE) {

                if (!$stmt = @oci_parse($this->connection,$sql)) {

                    $error = oci_error($this->connection);

                    echo $error[message];

                    return false;

                }



                if (!@oci_execute($stmt,$flag)) {

                    $error = oci_error($stmt);

                    echo $error[message];

                    return false;

                } else {

                    return $stmt;

                }

            }

        }



        function fetchObject(&$obj,$stmt) {

            if ($this->dbType==MYSQL) {

                if ($obj=@mysql_fetch_object($stmt)) {

                    return true;

                }

            } else if ($this->dbType==ORACLE) {



                if ($row = @oci_fetch_assoc($stmt)) {

                    $rows = Array();

                    while(list($key,$val)=each($row)) {

                        $rows[strtolower($key)] = $val;

                    }

                    $obj = (object)$rows;

                    return true;

                }

            }

            return false;

        }



        function fetchAssoc(&$obj,$stmt) {

            if ($this->dbType==MYSQL) {

                if ($obj = @mysql_fetch_assoc($stmt)) {

                    return true;

                }

            } else if ($this->dbType==ORACLE) {

                if ($row = @oci_fetch_assoc($stmt)) {

                    $obj = Array();

                    while(list($key,$val)=each($row)) {

                        $obj[strtolower($key)] = $val;

                    }

                    return true;

                }

            }



            return false;

        }



        function fetchRow(&$obj,$stmt) {

            if ($this->dbType==MYSQL) {

                if ($obj = @mysql_fetch_row($stmt)) {

                    return true;

                }

            } else if ($this->dbType==ORACLE) {

                if ($obj = @oci_fetch_row($stmt)) {

                    return true;

                }

            }



            return false;

        }



        function fetchArray(&$obj,$stmt) {

            if ($this->dbType==MYSQL) {

                if ($obj = @mysql_fetch_array($stmt)) {

                    return true;

                }

            } else if ($this->dbType==ORACLE) {



                if ($row = @oci_fetch_array($stmt)) {

                    $obj = Array();

                    while(list($key,$val)=each($row)) {

                        $obj[strtolower($key)] = $val;

                    }

                    return true;

                }

            }



            return false;

        }



        function commit() {

            if ($this->dbType==ORACLE) {

                return oci_commit($this->connection);

            } else {

                return true;

            }

        }



        function rollback() {

            if ($this->dbType==ORACLE) {

                return oci_rollback($this->connection);

            } else {

                return true;

            }

        }



        function getAffectedRows($obj="") {

            if ($this->dbType==MYSQL) {

                if ($obj=="") {

                    return mysql_affected_rows();

                } else {

                    return mysql_affected_rows($obj);

                }

            }



            return false;

        }

        

        function getNumRows($stmt) {

            if ($this->dbType==MYSQL) {

                return mysql_num_rows($stmt);

            }

            return false;

        }



        ## 계속 추가 예정

    }

?>

사용방법
Oracle DB 사용시 #oracle.php


<?php

    /***************************************************************

    프로그램명    : Oracle 예제

    작성자        : 윤영식 (2006-10-18 오후 5:44)

    ***************************************************************/

    $uri = "oracle://localhost:1521/?sid=ora10g&username=meris&password=meris&charset=";



    // Class 호출

    $conn = new DBConn($uri);



    $sql = "SELECT name FROM ttable";



    // 쿼리 실행

    $stmt = $conn->execute($sql);



    // $obj 오브젝트로 Fetch

    $conn->fetchObject(&$obj,$stmt);



    // $obj->컬럼명 하면 데이터 나옴

    $name = $obj->name;



    $obj=null;



    // Statment Free

    $conn->freeStatement($stmt);

?>

MySQL DB 사용시 #mysql.php


<?php

    /***************************************************************

    프로그램명    : MySQL 예제

    작성자        : 윤영식 (2006-10-18 오후 5:47)

    ***************************************************************/

    $uri = "mysql://localhost:3306/?dbname=meris&username=meris&password=meris&charset=euckr";



    // Class 호출

    $conn = new DBConn($uri);



    $sql = "SELECT name FROM ttable";



    // 쿼리 실행

    $stmt = $conn->execute($sql);



    // $obj 오브젝트로 Fetch

    $conn->fetchObject(&$obj,$stmt);



    // $obj->컬럼명 하면 데이터 나옴

    $name = $obj->name;



    $obj=null;



    // Statment Free

    $conn->freeStatement($stmt);

?>

눈치 빠른 분들은 벌써 눈치 쳈겠지만...
$uri 값만 바까줌으로써.. MySQL 이든 Oracle 이든 모두 사용가능 하다.
Sybase 및 기타 다른 DB도 해보고 싶지만 설치 되어 있는 환경이 없어서 테스트 불가.


	이 저작물은 정보공유 라이센스 2.0 : 영리금지·개작금지에 따라 이용하실수 있습니다.

태그 : PHP5, Class, DBConn, Oracle, MySQL, PHP

| 댓글(2) | 엮인글(0) | 삭제 | 수정 |

※ 트랙백 주소 : http://wizard.ncafe.net/wt/tb/2296 [주소복사]

※ 댓글을 남겨주세요.

(☜ Password : 삭제시 필요합니다.)

(※ 보안글자를 입력해 주세요!)

:: 댓글 ::


ㅡ,.ㅡ	:: 2006-10-19 15:11:00	댓글 \| 삭제

	그냥 Base Class 만들고 그걸 상속해서 MySqlConnection과 OracleConnection으로 놓은 다음에 DBConnection xx = new MySqlConnection 등으로 하는게 나을 것 같은데..



윤영식	:: URL : http://wizard.ncafe.net \| 2006-10-19 15:15:46	댓글 \| 삭제

	ㅋ.. 좋은 지적입니다. 걍 만들다 보니 저렇게 만들어 놓아 버렸네요. 상속^^ 이놈으로 다시 수정해야겠슴당. 시간날때...