java資料庫操作通用類

⑴ 如何使用java寫一個增刪改查的通用類，不需要連接資料庫

importjava.util.LinkedList;

importjavax.swing.text.html.HTMLDocument.Iterator;

publicclassTestKnow{
	voidmain(String[]args){
		Students1=newStudent(1,"s1",15);
		Students2=newStudent(2,"s2",15);
		Students3=newStudent(3,"s3",15);
		Gradeg=newGrade(1);
		g.add(s1);g.add(s2);g.add(s3);//增
		g.delete(s1);//刪
		Students4=newStudent(4,"s4",12);
		g.change(s2,s4);//改
		Studentss=g.check(3);//查
		System.out.println(ss.name);
	}

}
classStudent{
	intnum;//學號
	Stringname;
	intage;
	publicStudent(intnum,Stringname,intage){
		this.num=num;
		this.name=name;
		this.age=age;
	}
}
classGrade{
	intgnum;
	LinkedList<Student>grade;
	publicGrade(intgnum){
		this.gnum=gnum;
		grade=newLinkedList<Student>();
	}
	publicvoidadd(Students){
		grade.add(s);
	}
	publicStudentcheck(intn){
		java.util.Iterator<Student>it=grade.iterator();
		while(it.hasNext()){
			Studenttemp=it.next();
			if(temp.num==n)
				returntemp;
		}
		returnnull;
	}
	publicvoiddelete(Students){
		if(grade!=null)
			if(check(s.num)!=null)
				grade.remove(s);
			else
				System.out.println("沒有此人");
		else
			System.out.println("班裡沒人");
	}
	publicvoidchange(Students1,Students2){
		if(grade!=null)
			if(check(s1.num)!=null)
			{
				grade.remove(s1);
				grade.add(s2);
			}
			else
				System.out.println("沒有要替換的人");
		else
		System.out.println("班裡沒人");
	}
}

⑵ 用Java怎樣訪問資料庫，用什麼代碼

1． 載入一個對應資料庫的JDBC驅動

在建立到一個資料庫的連接之前，必須先載入這個資料庫的JDBC驅動程序，載入之後此driver會自動注冊到JDBC驅動列表中。載入一個JDBC驅動有兩種方法。

a） 在命令行方式下指定驅動器或者用冒號分割驅動器列表：

具體命令如下：

C:\>java –Djdbc.drivers = com.company1.Driver:com.company2.Driver youProject

b)第二種方法，在程序中調用Class.forName（）方法。推薦使用。。。。

try

{

String driverName = 「com.imaginary.sql.msql.MsqlDriver」;

Class.forName(driverName).newInstance();

}

Catch(ClassNotFoundException e1)

{

//catch could not find database driver exception.

}

2.連接到資料庫。

根據您後台待連接的資料庫不同，而有小小的差別。

a) 連接到Oracle資料庫。

Connection connection = null ;

try

{

//load the jdbc driver ;

String driverName = 「oracle.jdbc.driver.OracleDriver」;

Class.forName(driverName).newInstance();

//create a connection to the database;

String serverName = 「127.0.0.1」;

String serverPort = 「1521」;

String serverID = 「datebase1」

String userName = 「hello」;

String userPsw = 「world」;

String url = 「jdbc:oracle.thin:@」 + serverName + 「:」 + serverPort + 「:」 + serverID ;

Connection = DriverManager.getConnection(url , userName , userPsw);

}

catch(ClassNotFoundException e1)

{

//catch could not find database driver exception.

}

catch(SQLException e2)

{

//catch could not connect to the database exception.

}

b) 連接到一個SQL Server資料庫。

Connection connection = null ;

try

{

//load the jdbc driver ;

String driverName = 「com.microsoft.jdbc.sqlserver.SQLServerDriver」;

Class.forName(driverName).newInstance();

//create a connection to the database;

String serverName = 「127.0.0.1」;

String serverPort = 「1433」;

String serverID = serverName + serverPort ;

String userName = 「hello」;

String userPsw = 「world」;

String url = 「jdbc:JSQLConnect ://」 + serverID ;

Connection = DriverManager.getConnection(url , userName , userPsw);

}

catch(ClassNotFoundException e1)

{

//catch could not find database driver exception.

}

catch(SQLException e2)

{

//catch could not connect to the database exception.

}

c) 連接到一個MySQL資料庫上。。。。

Connection connection = null ;

try

{

//load the jdbc driver ;

String driverName = 「org.gjt.mm.mysql.Driver」;

Class.forName(driverName).newInstance();

//create a connection to the database;

String serverName = 「127.0.0.1」;

String serverID = 「database」;

String userName = 「hello」;

String userPsw = 「world」;

String url = 「jdbc:mysql ://」 + serverName + 「/」 + serverID ;

Connection = DriverManager.getConnection(url , userName , userPsw);

}

catch(ClassNotFoundException e1)

{

//catch could not find database driver exception.

}

catch(SQLException e2)

{

//catch could not connect to the database exception.

}

綜合上面的三種資料庫連接方式 ， 其實大同小異。由於訪問不同的資料庫和所使用的資料庫驅動程序不同，所以導致代碼表面上有小小不同，但透過表面看來，內部都是

1． 載入一個特定的資料庫JDBC驅動。

2． 連接到一個資料庫。

3． 之後，就可以對一個特定的資料庫進行特定的操作了。

附上各種資料庫的JDBC驅動起可用信息網址：

http://java.sun.com/procts/jdbc

對於Oracle資料庫，請參考：

http://otn.oracle.com.software/content.html

對於MySQL資料庫，請參考：

http://mmMySQL.sourceforge.net

對於SQL Server資料庫，有很多的驅動可選，比較常用的：

http://www.microsoft.com/china/sql/downloads/2000/jdbc.asp

http://www.freetds.org

http://www.datadirect-technologies.com

⑶ java 向資料庫插入數據

java向資料庫中插入數據，可以使用mysql資料庫，使用statement類來操作資料庫，示例如下：

Connectionconn=null;
Statementst=null;
try{
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");//載入驅動類
conn=DriverManager.getConnection("jdbc:microsoft:sqlserver://<server_name>:<1433>","name","pwd");
conn.setAutoCommit(false);
st=conn.createStatement();
//模擬一個str[i]=nd.getNodeValue().trim()
String[]str=newString[]{"aaa","bbb","ccc","ddd","eee","fff"};
StringsqlStr=null;
for(inti=0;i<str.length;i++){
sqlStr="INSERTINTO<TABLENAME>(<COLNAME>)VALUES('"+str[i]+"')";//向資料庫中插入數據
st.executeUpdate(sqlStr);
}
conn.commit();
}catch(Exceptione){
e.printStackTrace();
}finally{//釋放資料庫的資源
try{
if(st!=null)
st.close();
if(conn!=null&&!conn.isClosed()){
conn.close();
}
}catch(SQLExceptione){
e.printStackTrace();
}
}

⑷ 在Java中如何對資料庫中的數據進行操作

//此類為連接資料庫並進行資料庫的操作
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class Conn {
private static Connection conn = null;
private static Statement st = null;
private static ResultSet rs = null;
//建立資料庫的連接
public Conn(){
String url = "jdbc:sqlserver://localhost:1433;databaseName=ZYGX";
String user = "sa";
String password = "123";
try {
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
conn = DriverManager.getConnection(url, user, password);
st = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}

// 通過不同 的sql語句，得到相應Resultset結果集
public ResultSet getRs(String sql){
try{
rs= st.executeQuery(sql);
}catch(SQLException e){
e.printStackTrace();
}
return rs;
}
// 根據不同的sql語句，執行資料庫的更新操作
public int updata(String sql){
int num=0;
try{
num = st.executeUpdate(sql);
}catch(SQLException e){
e.printStackTrace();
}
return num;
}
// 關閉資料庫連接相應的資源
public void close(){
try{
if(rs!=null){
rs.close();
rs = null;
}
if(st!=null){
st.close();
st = null;
}
if(conn!=null){
conn.close();
conn = null;
}
}catch(SQLException e){
e.printStackTrace();
}
}
}
----------------------------------------------------------------------
//可以對button里添加動作按鈕：
final JButton button = new JButton();
button.addActionListener(new ActionListener() {
public void actionPerformed(final ActionEvent e) {
Conn conn =new Conn();
String sql1="select * from aa where name='"+name+"' ";//按name值查找
ResultSet rs = conn.getRs(sql1);
try {
while(rs.next()){
int n=rs.getString("type");
}
} catch (SQLException e) {
e.printStackTrace();
}
String name=textField.getText();
String sql="update aa set tittle='"+name+"' ";//從aa表將title欄位的值改成textField里的name值
String sql2 ="delete from aa where name='"+name+"'";//從aa表將按取得name的值刪除該行數據
String sql3 = "insert into aa (name,uname) values ('"+name+"','"')"; //將name，uname值新增到aa表
if(conn.update(sql)==1){
System.out.print("修改成功");
}
if(conn.update(sql2)==1){
System.out.print("刪除成功");
}
if(conn.update(sql3)==1){
System.out.print("新增成功");
}
}
});