把代码帖出来看看!~```我们都是用Javabean连接数据库的```很方便的呀!
解决方案 »
- 能不能像移动更换套餐实现当月修改下月生效
- 不知道在eclipse里边有没有这样一个小工具...
- WebWork 如何显示BLOG内容?
- 我是一个从.Net转Java方向的码农
- wsad5.1连接Oracle9i数据源的问题,不知道是测试程序错误还是连接错误,敬请高手指教
- j2ee教程上The Duke's Bank Application,部署成功后,转帐和取款会出现错误,请教~
- 为什么tomcat单独启动能用,而在eclipse启动后浏览页面就有错误那?
- 大家都把自己认为好的关于j2ee的文章地址贴出来,以便交流,我先开个头!
- mdb接收到信息并处理完毕后怎么样把成功信息返回到发送信息的程序,并在界面中反应出来?
- 在Solaris下,使用xalan对XML转换时,出现错误,怎么办?同样程序在Windows可正常运行。
- 请问有谁做过在unix环境下用JAVA连接同网段windows环境下共享access数据库?
- Hibernate的精髓是什么
仔细看看!
public class DBConnection {
public static Connection getConnection()throws Exception{
Class.forName("oracle.jdbc.driver.OracleDriver");
Connection conn=DriverManager.getConnection(
"jdbc:oracle:thin:@localhost:1521:nitpro2","scott","tiger");
return conn;
}
}
这个就是javabean 连接方法 你看一下
/*
*@title:ConnBean.java
*@author:admin 2005-12-10
*@description:连接数据javabean
*@version:1.0
*/
import java.sql.*;
import java.text.SimpleDateFormat;
import java.util.Calendar;
public class ConnBean
{
/* String sDBDriver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
String sConnStr = "jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=twjs";
String user = "kd";
String password = "kd";*/
String sDBDriver = "com.mysql.jdbc.Driver";
String sConnStr = "jdbc:mysql://192.168.1.254:3306/ConfigCenter";
String user = "root";
String password = "admin";
Connection connect = null;
static ResultSet rs = null;
Statement stmt = null;
public ConnBean()
{
try{
Class.forName(sDBDriver);
System.out.println( "类实例化成功!" );
}
catch(ClassNotFoundException e){
System.err.println(e.getMessage());
}
}
/*
* 查询数据
*/
public ResultSet executeQuery(String sql)
{
try{
connect = DriverManager.getConnection(sConnStr,user,password);
System.out.println( "创建连接对像成功!" );
stmt = connect.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
System.out.println( "创建Statement成功!" );
rs = stmt.executeQuery(sql);
System.out.println( "操作数据表成功!" );
}
catch(SQLException ex){
System.err.println("connbean.executeQuery:" +ex.getMessage());
}
return rs;
}
/*
* 对数据库的数据进行更新
*/
public int executeUpdate(String sql)
{
int result = 0;
try{
connect = DriverManager.getConnection(sConnStr,user,password);
stmt = connect.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
result = stmt.executeUpdate(sql);
System.out.println("数据更新成功!");
}
catch(SQLException ex){
System.err.println("connbean.executeUpdate:" +ex.getMessage());
}
return result;
}
/*
* 向数据库中添加数据
*/
public int executeInsert(String sql)
{
int result = 0;
try{
connect = DriverManager.getConnection(sConnStr,user,password);
stmt = connect.createStatement();
result = stmt.executeUpdate(sql);
System.out.println("数据添加成功!");
}
catch(SQLException ex)
{System.err.println("connbean.executeInsert:"+ex.getMessage());
}
return result;
}
/*
* 删除数据库中的数据
*/
public int executeDelete(String sql)
{
int result = 0;
try{
connect = DriverManager.getConnection(sConnStr,user,password);
stmt = connect.createStatement();
result = stmt.executeUpdate(sql);
System.out.println("数据删除成功!");
}
catch(SQLException ex)
{
System.err.println("connbean.executeDelete:"+ex.getMessage());
}
return result;
}
/**
* 关闭数据库连接
*
*/
public void closeStmt() {
try {
if (stmt != null) {
stmt.close();
stmt = null; }
} catch (SQLException e) {
e.printStackTrace();
}
} public void closeConn() {
try {
if (connect != null) {
connect.close();
connect = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public static String GBToUnicode(String strIn) {
String strOut = null;
if (strIn == null || (strIn.trim()).equals(""))
return strIn;
try {
byte[] b = strIn.getBytes("ISO8859_1");
strOut = new String(b, "GBK");
} catch (Exception e) {
}
return strOut;
}
public void setAutoCommit(boolean bAuto) throws SQLException{
if(connect != null){
connect.setAutoCommit(bAuto);
}
}
public void commit() throws SQLException{
if(connect !=null){
connect.commit();
}
}
public void rollback()throws SQLException{
if(connect != null){
connect.rollback();
}
}
public boolean getAutoCommit() throws SQLException
{
boolean bAuto = false;
if(connect != null){
bAuto = connect.getAutoCommit();
}
return bAuto;
}
public static void main(String[] args){
String sql = "insert into userInfo(nUserNo,sUserName) values('1000','admin')";
try {
conn.setAutoCommit(false);
for(int i=0;i<100;++i){
conn.executeInsert(sql);
}
conn.commit();
} catch (SQLException e1) {
// TODO Auto-generated catch block
try {
conn.rollback();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}finally{
conn.closeConn();
}
}
}