public int ExecuteUpdate(String sql){ //·μ???μ?aó°?ìêy?Y?a????μ?êyá??£è?£o·μ???a0£?óD?é?ü?üD??ò2?è?2?3é1|?£è?1?í?ê±DT??3é1|100ì?????£??ò·μ???á1??a100 int r = 0; try{ Statement stmt = (Statement)conn.createStatement(); r = stmt.executeUpdate(sql); System.out.println("execute result:"+r); }catch(Exception e){ System.out.println("ExecuteUpdate error "); System.out.println(e);
}
return r; } public void closeDB() throws SQLException{ conn.close(); }
DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=AdressList","sa","123");
sql=con.createStatement();
rs=sql.executeQuery("select * from ld_test");
这些是关键的东西
去看看书就知道了
package JavaBean;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.mysql.jdbc.Statement;public class DBConn {
private static Connection conn = null;
public DBConn(){
try{
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
conn=DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=AdressList","sa","123");
}catch(Exception e){
System.out.println("Connect error");
System.out.println(e);
}
} public static ResultSet ExecuteQuery(String sql){
ResultSet returnRs = null;
try{
Statement stmt=(Statement) conn.createStatement();
returnRs = stmt.executeQuery(sql);
}catch(Exception e){
System.out.println("Execute Query error");
System.out.println(e);
}
return returnRs;
}
public int ExecuteUpdate(String sql){
//·μ???μ?aó°?ìêy?Y?a????μ?êyá??£è?£o·μ???a0£?óD?é?ü?üD??ò2?è?2?3é1|?£è?1?í?ê±DT??3é1|100ì?????£??ò·μ???á1??a100
int r = 0;
try{
Statement stmt = (Statement)conn.createStatement();
r = stmt.executeUpdate(sql);
System.out.println("execute result:"+r);
}catch(Exception e){
System.out.println("ExecuteUpdate error ");
System.out.println(e);
}
return r;
}
public void closeDB() throws SQLException{
conn.close();
}
// public static void main(String[] args) {
// try {
//
//// Class.forName("org.gjt.mm.mysql.Driver").newInstance();
//// Connection con22=DriverManager.getConnection("jdbc:mysql://localhost/metrics","root","123456");
//// Statement sql=(Statement) con22.createStatement();
//// ResultSet rs = sql.executeQuery("select * from ts_role");
//// while (rs.next())
//// {
//// System.out.print(rs.getString("M1_ROLE"));
//// }
//
//
// }
// catch (Exception ex) {
// System.out.println(ex);
// }
// } }
import java.io.*;
public class L_j {
public static void main(String args[])
{ try
{
String driver="com.microsoft.jdbc.sqlserver.SQLServerDriver";
String con="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=test";
//"test"是你的数据库的名字
String user="sa";
String password="";//sa密码具体情况自己把握
Class.forName(driver);
System.out.println("驱动加载成功!");
Connection conn = DriverManager.getConnection(con,user,password);
System.out.println("已经连接上了数据库");
Statement stmt=conn.createStatement();
String sql="select * from table";//在数据库test下创建的表名table
ResultSet rs = stmt.executeQuery(sql);
ResultSetMetaData rsmd = rs.getMetaData(); int colCount = rsmd.getColumnCount();
while(rs.next()){
for(int i = 0; i < colCount; i++){
System.out.print(rs.getString(i+1) + "\t");
}System.out.println();
}
}
catch(Exception ex)
{
System.err.println(ex.getMessage());
}}
}
我以前写的代码应该没什么问题!