【Java开源代码栏目提醒】:本文主要为网学会员提供ysfUserManage.java,希望对需要ysfUserManage.java网友有所帮助,学习一下!
package flashRemoting.ysf;
import java.sql.*;
import java.io.Serializable;
import java.util.*;
import javax.sql.*;
import sun.jdbc.rowset.*;
import javax.naming.*;
public class ysfUserManage
implements Serializable {
private boolean logined;
private boolean maked;
public ResultSet getUserInfo(String Para1, String Para2) throws Exception {
Connection connection = null;
PreparedStatement stmt = null;
ResultSet rs = null;
CachedRowSet crs = new CachedRowSet();
String sql = "select * from myUsers WHERE userID='" + Para1 + "' AND userPass='" + Para2 + "'";
System.out.println(sql);
try {
Context ctx = (Context) new InitialContext().lookup("java:comp/env");
DataSource ds = (DataSource) ctx.lookup("ysfDb");
connection = ds.getConnection();
stmt = connection.prepareStatement(sql);
rs = stmt.executeQuery();
crs.populate(rs);
crs.last();
System.out.println("RowSet populated.");
}
catch (Exception e) {
System.out.println(e);
}
finally {
try {
rs.close();
stmt.close();
connection.close();
}
catch (Exception e) {}
}
return crs;
}
public boolean newUser(String Para1, String Para2, String Para3, String Para4,
String Para5, String Para6, String Para7, String Para8,
String Para9, String Para10) {
String
sql = "select * from myUsers WHERE userID='" + Para1 + "'";
Connection connection = null;
PreparedStatement stmt = null;
ResultSet rs = null;
try {
Context ctx = (Context) new InitialContext().lookup("java:comp/env");
DataSource ds = (DataSource) ctx.lookup("ysfDb");
System.out.println("在这里我们使用JDBC连接的JNDI名");
System.out.println("在前面一章,我们创建名为ysfDb的JNDI名");
connection = ds.getConnection();
stmt = connection.prepareStatement(sql);
rs = stmt.executeQuery();
logined = false;
while (rs.next()) {
logined = true;
}
if (!logined) {
sql =
"INSERT INTO myUsers (userID,userPass,userName,userSex,userBirth,userEMail,userTel,userProvince,userAdd,userZIP) Values ('" +
Para1 + "','" + Para2 + "','" + Para3 + "','" + Para4 + "','" +
Para5 +
"','" + Para6 + "','" + Para7 + "','" + Para8 + "','" + Para9 +
"','" +
Para10 + "')";
stmt = connection.prepareStatement(sql);
stmt.executeUpdate();
maked = true;
}
else if (logined) {
maked = false;
}
}
catch (Exception e) {
System.out.println(e);
}
finally {
try {
rs.close();
stmt.close();
connection.close();
}
catch (Exception e) {}
}
return maked;
}
public boolean updateUserInfo(String Para1, String Para2, String Para3,
String Para4, String Para5, String Para6,
String Para7, String Para8, String Para9,
String Para10) {
//String url = "jdbc:odbc:ysfDb";
//String login = "";
//String Pass
word = "";
String sql = "UPDATE myUsers SET userID = '" + Para1 + "', userPass = '" + Para2 +
"', userName = '" + Para3 + "',userSex = '" + Para4 + "',userBirth = '" + Para5 +
"',userEMail = '" + Para6 + "',userTel = '" + Para7 + "',userProvince = '" + Para8 +
"',userAdd = '" + Para9 + "',userZIP = '" + Para10 + "' WHERE userID = '" +
Para1 + "'";
Connection connection = null;
PreparedStatement stmt = null;
try {
Context ctx = (Context) new InitialContext().lookup("java:comp/env");
DataSource ds = (DataSource) ctx.lookup("ysfDb");
System.out.println("在这里我们使用JDBC连接的JNDI名");
System.out.println("在前面一章,我们创建名为ysfDb的JNDI名");
connection = ds.getConnection();
stmt = connection.prepareStatement(sql);
stmt.executeUpdate();
maked = true;
}
catch (Exception e) {
System.out.println(e);
maked = false;
}
finally {
try {
stmt.close();
connection.close();
}
catch (Exception e) {}
}
return maked;
}
}