import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
public class MySqlServer {
public Connection conn;
public String connectionString;
public MySqlServer(String connectionString,String usr,String pwd) {
// TODO Auto-generated constructor stub
this.connectionString=connectionString;
try {
// 连接数据库
conn = DriverManager.getConnection(connectionString, usr, pwd);
} catch (SQLException e) {
e.printStackTrace();
System.out.println("数据库连接失败");
}
}
public ResultSet querySql(String sql) throws SQLException {
Statement statement=conn.createStatement();
ResultSet rs=statement.executeQuery(sql);
//statement.close();
return rs;
}
public long getRsLength(ResultSet rs) throws Exception {
rs.last();
long length=rs.getRow();
rs.beforeFirst();
return length;
}
public void close() {
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
conn = null;
}
}
public static void main(String[] args) {
// TODO Auto-generated method stub
MySqlServer mySqlServer=new MySqlServer("jdbc:sqlserver://xxxxxxxxxx:1433;DatabaseName=xxxx;", "sa", "xxxxxxxxx");
try {
ResultSet rs=mySqlServer.querySql("select top 10 * from allpeople where office like '%xxxx'");
System.out.println("name\tmobile\t\twno\temail\t");
while(rs.next()) {
String line=String.format("%s\t%s\t%s\t%s\t",rs.getString("name"),rs.getString("mobile"),rs.getString("wno"),rs.getString("email"));
System.out.println(line);
}
rs.close();
mySqlServer.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
System.out.println(e.getMessage());
}
}
}