dbaccess.java

一个java实现的有界面的email发送程序。可以从网络上抓取email。也可以从文件中读取email

package com.code10.access;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;


import com.code10.basecomponent.Entry;

public class DbAccess {
	 private Connection conn;//数据库连接
	 private String url;//SQLServer的路径
	 private String serverName;//服务器名
	 private String portNumber;//端口号
	 private String databaseName;//数据库名
	 private String userName;//用户名
	 private String password;//密码
	
	 /**
	  * 连接字符串
	  * @return
	  */
	 public DbAccess(){
		  url="jdbc:microsoft:sqlserver://";
		  serverName="192.168.0.3";
		  portNumber="1433";
		  databaseName="email";
		  userName="sa";
		  password="123456z";
		  try{
			    try {
					Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
				} catch (ClassNotFoundException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			    conn=DriverManager.getConnection(getConnectionUrl(),userName,password);
			  }catch(SQLException e){
				  e.printStackTrace();
			  }
		 }

	 private String getConnectionUrl(){
		  
	  return url+serverName+":"+portNumber+";databaseName="+databaseName+";";
	 }
/**
 * 连接函数
 * @return
 */
	 public Connection getConnection(){
	  
	return conn;
	 }
	
	
	/**
	 * 插入到数据库
	 * @return
	 */
	public boolean insertInto(ArrayList<Entry> aryRs){
		 try{  
			 Entry enTmp = new Entry();
			 Statement  s = conn.createStatement(); ;
			 for(int i = 0; i< aryRs.size() ;i++){
				 enTmp = aryRs.get(i);
				 String email = enTmp.getEmail();
				 String username = enTmp.getUsername();
				 String insert = "insert into email values('" + username +"','" + email + "')";
				 s.executeUpdate(insert);
			 }
			  s.close();
			  conn.close();
		 }catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				
			
		}
		return false;
	}
	/**
	 * 从数据库按照指定个数提取Email信息
	 * @author Chengfeng.han
	 * @param startid
	 * @param count
	 * @return
	 */
	public ArrayList<Entry> query(int intStartId , int intCount ){
		    int idStart = intStartId;
		    int idEnd = idStart + intCount;
		    ArrayList<Entry> aryRs = new ArrayList<Entry>();
		 try{
			  Statement s = conn.createStatement(); 
			  String query = "select email,username from email where id>" + idStart +" and id<" + idEnd +"";
			  ResultSet rs = s.executeQuery(query);
			while (rs.next()) {
//			  rs.next()
				Entry enTmp = new Entry();
				enTmp.setEmail(rs.getString(1));
				enTmp.setUsername(rs.getString(2));
				aryRs.add(enTmp);
			} 
			return aryRs;
		 }catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				
			
		}
		return null;
	}
	
	/**
	 * 根据ID来删除指定对象
	 * @param entryid
	 * @return
	 */
	public boolean delete(int intEntryId ){
		 try{  
	
		
			  Statement s = conn.createStatement(); 
		
			  String del = "delete email where id= "+ intEntryId + "";
			  s.executeUpdate(del);
			  s.close();
			  conn.close();
		
		
		 }catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				
			
		}
		return false;
	
	}
	
	/**
	 *根据个数批量删除对象
	 * @param startid
	 * @param count
	 * @return
	 */
	public boolean delete(int intStartid , int intCount){
		 try{  
			  int intStart = intStartid;
			  int intEnd  = intStart + intCount;
				
			  Statement s = conn.createStatement(); 
		
			  String del = "delete email where id > "+ intStartid + " and id < "+ intEnd + "";
			  s.executeUpdate(del);
			  s.close();
			  conn.close();
		
		
		 }catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				
			
		}
		
		return false;
	}
	
public static void  main(String [] args){
		 DbAccess db = new DbAccess();
		 db.getConnection();
		 Entry e= new Entry();
		 ArrayList<Entry> aryRs = new ArrayList<Entry>();
		 e.setUsername("aaaa")  ;
		 e.setEmail("aaaassss")  ;
		 aryRs.add(e);
		 db.insertInto(aryRs);
		// for(int i = 0 ;i< aryRs.size() ; i++){
			// System.out.println(aryRs.get(i).getUsername().trim()+","+aryRs.get(i).getEmail());
			// System.out.println(aryRs.get(i).getUsername());
	}
	
}