ArcSDE学习笔记--------增、删、改、查操作

建立连接

package org.lq.ssm.gp.controller;

import com.esri.sde.sdk.client.SeConnection;
import com.esri.sde.sdk.client.SeException;

public class SDEDBManager {

    
    
    private static String server = "";      //SDE ip地址
    private static String instance = "";    //ArcSDE服务器端口号
    private static String database = "";    //数据库名
    private static String username = "";    //数据库账户
    private static String password = "";    //数据库密码
    /**
     * 建立SDE连接
     * @date 2017-4-13
     * @return
     */
    public static SeConnection getConn() {
        SeConnection conn = null;
        if (conn == null) {
            try {
                conn = new SeConnection(server, instance, database, username, password);
                if(conn!=null){
                    System.out.println("连接SDE成功！");
                }
            } catch (SeException ex) {
                ex.printStackTrace();
            }
        }
        return conn;
    }
            
}

建立与数据库的连接

package org.lq.ssm.gp.controller;



import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.Properties;





public class DBUtil {
    
    //连接数据库的路径
        private static String url;
        //连接数据库的用户名
        private static String user;
        //连接数据库的密码
        private static String pwd;
        //用于管理不同线程所获取的连接
        private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
        //静态块
        static{
            try{
                //读取配置文件
                Properties prop = new Properties();            
                InputStream is = DBUtil.class.getClassLoader().getResourceAsStream("config.properties");
                prop.load(is);
                is.close();
        
                //获取驱动
                String driver = prop.getProperty("jdbc.className");
                
                System.out.println(driver);
                //获取地址
                url = prop.getProperty("jdbc.url");
                
                //获取用户名
                user = prop.getProperty("jdbc.username");
            
                //获取密码
                pwd = prop.getProperty("jdbc.password");
                            
                //注册驱动
                Class.forName(driver);
                
            }catch(Exception e){
                e.printStackTrace();
            }
        } 

        
        /**
         * 获取一个连接
         * @return
         * @throws Exception 
         */
        public static Connection getConnection() throws Exception{
            try{
                /*
                 * 通过DriverManager创建一个数据库的连接
                 * 并返回
                 */
                Connection conn = DriverManager.getConnection(url,user,pwd);
                /*
                 * ThreadLocal的set方法
                 * 会将当前线程作为key,并将给定的值
                 * 作为value存入内部的map中保存。
                 */
                tl.set(conn);
                return conn;
            }catch(Exception e){
                e.printStackTrace();
                //通知调用者，创建连接出错
                throw e;
            }
        }
        
        /**
         * 关闭给定的连接
         */
        public static void closeConnection(){
            try{        
                Connection conn = tl.get();
                if(conn != null){
                    conn.close();
                    tl.remove();
                }
            }catch(Exception e){
                e.printStackTrace();
            }
        }
        
        
        

}

增加操作

public int save(LandUser land) {
        SeConnection conn = SDEDBManager.getConn();
        if (conn != null) {
            try {
                
                points="1 1,2 2,3 3";//点坐标的格式是这样的。数据是随便填的
                
                SeInsert insert = new SeInsert(conn); // 使用当前的连接句柄Connection    ,创建一个SeInsert对象.        
                insert.intoTable("SDE.ztl", new String[]{"SHAPE","picid", "ybMarkNo", "ybgeometry", "dzbjh", "userId", 
                        "userName", "userZjh", "userYhkh", "userKhh", "userMobile", "userQygs", "userMs", 
                        "landDkbh", "landName"});
                
                insert.setWriteMode(true);// 开启buffer,设置SeInsert对象为可写模式
                SeLayer layer = new SeLayer(conn, "SDE.ztl", "SHAPE");
    
                SeCoordinateReference cr = layer.getCoordRef(); // 获得图层空间参考
                SeRow row = insert.getRowToSet();// 获取SeInsert对象中将要添加的SeRow对象。
                SeShape shape = new SeShape(cr);
                shape.generateFromText("POLYGON(("+points+"))"); //增加面
                               // shape.generateFromText("LINESTRING("+points+")"); //增加线
                row.setShape(0, shape);                
                row.setNString(1, land.getPicid());
                row.setNString(2, land.getYb_MarkNo());
                row.setNString(3, land.getYb_geometry());
                row.setNString(4, land.getDzbjh());
                row.setNString(5, land.getUserId());
                row.setNString(6, land.getUserName());
                row.setNString(7, land.getUserZjh());
                row.setNString(8, land.getUserYhkh());
                row.setNString(9, land.getUserKhh());
                row.setNString(10, land.getUserMobile());
                row.setNString(11, land.getUserQygs());
                row.setNString(12, land.getUserMs());
                row.setNString(13, land.getLandDkbh());
                row.setNString(14, land.getLandName());                
                            
                insert.execute();
                insert.flushBufferedWrites();
                insert.close();
                return 1;
            } catch (Exception e) {
                e.printStackTrace();
                return 0;
            } finally {
                try {
                    conn.close();
                } catch (SeException e) {
                    e.printStackTrace();
                }
            }
        }
        return 2;
    }
    

删除操作

public static int delete(String id){        
        try {
            Connection conn = DBUtil.getConnection();
            Statement state = conn.createStatement();
            String sql="delete from SDE.ztl where landDkbh='"+id+"'";
            // 执行Sql，得到结果集
            int flag = state.executeUpdate(sql);
            System.out.println("执行sql");
            state.close();
            DBUtil.closeConnection();
            
            if(flag>0){
                return 1;
            }else{
                return 0;
            }
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
        }
        
}

修改操作

public static int update(String id){        
        try {
            Connection conn = DBUtil.getConnection();
            Statement state = conn.createStatement();
                String sql="update SDE.ztl set " +
                "picid = '"+land.getPicid()+"',"+
                "ybMarkNo ='"+land.getYb_MarkNo()+"',"+
                "ybgeometry ='"+land.getYb_geometry()+"',"+
                "dzbjh ='"+land.getDzbjh()+"',"+
                "userName ='"+land.getUserName()+"',"+
                "userZjh ='"+land.getUserZjh()+"',"+
                "userYhkh ='"+land.getUserYhkh()+"',"+
                "userKhh ='"+land.getUserKhh()+"',"+
                "userMobile ='"+land.getUserMobile()+"',"+
                "userQygs ='"+land.getUserQygs()+"',"+
                "userMs ='"+land.getUserMs()+"',"+
                "landDkbh ='"+land.getLandDkbh()+"',"+
                "landName ='"+land.getLandName()+"'"+
                                " where userId = '"+land.getUserId()+"'";
            // 执行Sql，得到结果集
            int flag = state.executeUpdate(sql);
            System.out.println("执行sql");
            state.close();
            DBUtil.closeConnection();
            
            if(flag>0){
                return 1;
            }else{
                return 0;
            }
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
        }
        
}

查询操作

public static List<LandUser> selectAll(String sql){
        
        List<LandUser> list = new ArrayList<LandUser>();
        try {
            Connection conn = DBUtil.getConnection();
            Statement state = conn.createStatement();
        
            String sql="select picid,ybMarkNo,ybgeometry,dzbjh,userId," +
                "userName,userZjh,userYhkh,userKhh,userMobile,userQygs,userMs," +
                "landDkbh,landName  from SDE.ztl" ;
            // 执行Sql，得到结果集
            ResultSet rs = state.executeQuery(sql);
            while (rs.next()) {
                LandUser land = new LandUser();
                land.setPicid(rs.getString("picid"));
                land.setYb_MarkNo(rs.getString("ybMarkNo"));
                land.setYb_geometry(rs.getString("ybgeometry"));
                land.setDzbjh(rs.getString("dzbjh"));
                land.setUserId(rs.getString("userId"));
                land.setUserName(rs.getString("userName"));
                land.setUserZjh(rs.getString("userZjh"));
                land.setUserYhkh(rs.getString("userYhkh"));
                land.setUserKhh(rs.getString("userKhh"));
                land.setUserMobile(rs.getString("userMobile"));
                land.setUserQygs(rs.getString("userQygs"));
                land.setUserMs(rs.getString("userMs"));                
                land.setLandDkbh(rs.getString("landDkbh"));
                land.setLandName(rs.getString("landName"));
                                
                list.add(land);
            }
            rs.close();
            state.close();
            DBUtil.closeConnection();
            return list;
        } catch (Exception e) {
            e.printStackTrace();
            return list;
        }
        
    }