首页 文章 精选 留言 我的

精选列表

搜索[应用接续],共10012篇文章
优秀的个人博客,低调大师

sqlite ORMLite 框架应用

bean package com.test.deamo.bean; import android.os.Parcel; import android.os.Parcelable; import com.j256.ormlite.field.DatabaseField; import com.j256.ormlite.table.DatabaseTable; /** * author: yhf * Description: * date: 2016/04/20 18:22 */ @DatabaseTable(tableName = "tb_account") public class Account implements Parcelable { @DatabaseField(generatedId = true) private int id; @DatabaseField(columnName = "user_name") private String userName;// 用户姓名 @DatabaseField(columnName = "password") private String password;//密码 @DatabaseField(columnName = "token") private String token;// token值 public int getId() { return id; } public void setId(int id) { this.id = id; } public String getUserName() { return userName; } public void setUserName(String userName) { this.userName = userName; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } public String getToken() { return token; } public void setToken(String token) { this.token = token; } @Override public int describeContents() { return 0; } @Override public void writeToParcel(Parcel dest, int flags) { dest.writeInt(this.id); dest.writeString(this.userName); dest.writeString(this.password); dest.writeString(this.token); } public Account() { } protected Account(Parcel in) { this.id = in.readInt(); this.userName = in.readString(); this.password = in.readString(); this.token = in.readString(); } public static final Creator<Account> CREATOR = new Creator<Account>() { @Override public Account createFromParcel(Parcel source) { return new Account(source); } @Override public Account[] newArray(int size) { return new Account[size]; } }; } DatabaseHelper package com.test.deamo.utils.db; import android.content.Context; import android.database.sqlite.SQLiteDatabase; import com.j256.ormlite.android.apptools.OrmLiteSqliteOpenHelper; import com.j256.ormlite.dao.Dao; import com.j256.ormlite.support.ConnectionSource; import com.j256.ormlite.table.TableUtils; import com.test.deamo.bean.Account; import java.sql.SQLException; import java.util.HashMap; import java.util.Map; /** * Created by administrator * Description 数据库操作封装 * 2016/4/27 9:06. */ public class DatabaseHelper extends OrmLiteSqliteOpenHelper { private static final String TABLE_NAME = "test.db"; private Map<String, Dao> daos = new HashMap<String, Dao>(); private DatabaseHelper(Context context) { super(context, TABLE_NAME, null, 4); } @Override public void onCreate(SQLiteDatabase database, ConnectionSource connectionSource) { try { TableUtils.createTable(connectionSource, Account.class); } catch (SQLException e) { e.printStackTrace(); } } @Override public void onUpgrade(SQLiteDatabase database, ConnectionSource connectionSource, int oldVersion, int newVersion) { try { TableUtils.dropTable(connectionSource, Account.class, true); onCreate(database, connectionSource); } catch (SQLException e) { e.printStackTrace(); } } private static DatabaseHelper instance; /** * 单例获取该Helper * * @param context * @return */ public static synchronized DatabaseHelper getHelper(Context context) { context = context.getApplicationContext(); if (instance == null) { synchronized (DatabaseHelper.class) { if (instance == null) instance = new DatabaseHelper(context); } } return instance; } public synchronized Dao getDao(Class clazz) throws SQLException { Dao dao = null; String className = clazz.getSimpleName(); if (daos.containsKey(className)) { dao = daos.get(className); } if (dao == null) { dao = super.getDao(clazz); daos.put(className, dao); } return dao; } /** * 释放资源 */ @Override public void close() { super.close(); for (String key : daos.keySet()) { Dao dao = daos.get(key); dao = null; } } } dao类 package com.test.deamo.dao; import android.content.Context; import com.j256.ormlite.dao.Dao; import com.j256.ormlite.stmt.QueryBuilder; import com.j256.ormlite.stmt.Where; import com.test.deamo.bean.Account; import com.test.deamo.utils.db.DatabaseHelper; import java.sql.SQLException; public class AccountDao { private Context context; private Dao<Account, Integer> accountDao; private DatabaseHelper databaseHelper; public AccountDao(Context context) { this.context = context; try { databaseHelper = DatabaseHelper.getHelper(this.context); accountDao = databaseHelper.getDao(Account.class); } catch (SQLException e) { e.printStackTrace(); } } /** * 添加用户信息 * @param account */ public void add(Account account){ try { accountDao.create(account); } catch (SQLException e) { e.printStackTrace(); } } /** * 更新用户信息 * @param account */ public void update(Account account){ try { accountDao.update(account); } catch (SQLException e) { e.printStackTrace(); } } /** * 根据token获取account实体 * @param token * @return Account account */ public Account getAccountWithToken(String token){ return getAccountWithFiled("token", token); } /** * 根据字段名和值获取账号实体 * @param fieldName * @param fieldVal * @return */ public Account getAccountWithFiled(String fieldName, String fieldVal){ Account account = null; try { QueryBuilder<Account, Integer> queryBuilder = accountDao.queryBuilder(); Where<Account, Integer> where = queryBuilder.where(); where.eq(fieldName, fieldVal); account = where.queryForFirst(); } catch (SQLException e) { e.printStackTrace(); } return account; } } 本文转自秋楓博客园博客,原文链接:http://www.cnblogs.com/rwxwsblog/p/5448565.html,如需转载请自行联系原作者

优秀的个人博客,低调大师

hadoop jetty的应用

在hadoop中很多地方都用到了servlet,并且使用jetty作为servlet的容器来提供http的服务,其主要是通过org.apache.hadoop.http.HttpServer类实现的,HttpServer类是对Jetty的简单封装,通过调用HttpServer类的addServlet方法增加可以实现增加servlet到jetty的功能: 1 2 3 4 5 public void addServlet(Stringname,StringpathSpec, Class<? extends HttpServlet>clazz){ //名称,url访问路径,处理类 addInternalServlet(name,pathSpec,clazz, false ); addFilterPathMapping(pathSpec,webAppContext); } 默认在HttpServer的构造函数中,会调用addDefaultServlets添加需要增加的servlets: 1 2 3 4 5 6 7 8 9 10 11 public HttpServer(Stringname,StringbindAddress, int port, boolean findPort,Configurationconf,AccessControlListadminsAcl, Connectorconnector,String[]pathSpecs) throws IOException{ .... webAppContext= new WebAppContext(); webAppContext.setDisplayName(name); webAppContext.setContextPath( "/" ); webAppContext.setWar(appDir+ "/" +name); .... addDefaultServlets(); .... 启动addDefaultServlets定义了默认加载的servlet: 1 2 3 4 5 6 7 8 protected void addDefaultServlets(){ //setupdefaultservlets addServlet( "stacks" , "/stacks" ,StackServlet. class ); addServlet( "logLevel" , "/logLevel" ,LogLevel.Servlet. class ); addServlet( "metrics" , "/metrics" ,MetricsServlet. class ); addServlet( "jmx" , "/jmx" ,JMXJsonServlet. class ); addServlet( "conf" , "/conf" ,ConfServlet. class ); } hadoop在多个地方都用到了HttpServer这个类: 比如在org.apache.hadoop.hdfs.server.datanode.DataNode类中: 1 DataNode的构造函数--->startDataNode-->initDataXceiver+startInfoServer 其中startInfoServer就是调用HttpServer类启动jetty的: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 private HttpServerinfoServer= null ; ... private void startInfoServer(Configurationconf) throws IOException{ //createaservlettoservefull-filecontent InetSocketAddressinfoSocAddr=DataNode.getInfoAddr(conf); StringinfoHost=infoSocAddr.getHostName(); int tmpInfoPort=infoSocAddr.getPort(); this .infoServer=(secureResources== null ) ? new HttpServer( "datanode" ,infoHost,tmpInfoPort,tmpInfoPort== 0 , conf, new AccessControlList(conf.get(DFS_ADMIN, "" ))) : new HttpServer( "datanode" ,infoHost,tmpInfoPort,tmpInfoPort== 0 , conf, new AccessControlList(conf.get(DFS_ADMIN, "" )), secureResources.getListener()); LOG.info( "Openedinfoserverat" +infoHost+ ":" +tmpInfoPort); ..... this .infoServer.addInternalServlet( null , "/streamFile/*" ,StreamFile. class ); //添加datanode专属的servlet this .infoServer.addInternalServlet( null , "/getFileChecksum/*" , FileChecksumServlets.GetServlet. class ); this .infoServer.setAttribute( "datanode" , this ); this .infoServer.setAttribute(JspHelper.CURRENT_CONF,conf); this .infoServer.addServlet( null , "/blockScannerReport" , DataBlockScanner.Servlet. class ); if (WebHdfsFileSystem.isEnabled(conf,LOG)){ infoServer.addJerseyResourcePackage(DatanodeWebHdfsMethods. class .getPackage().getName()+ ";" +Param. class .getPackage().getName(), WebHdfsFileSystem.PATH_PREFIX+ "/*" ); } this .infoServer.start(); } 小结如下: 1)HttpServer是对Jetty的简单封装 2)hadoop各个组件都会用到HttpServer,datanode/namenode,resourcemanager等 其主要功能有:Hadoop的内部状态显示,运行和管理 3)HttpServer的addDefaultServlets方法定义了通用的几个servlet(比如更改日志级别的servlet),在每个类中又会定义属于自己的servlet 本文转自菜菜光 51CTO博客,原文链接:http://blog.51cto.com/caiguangguang/1592799,如需转载请自行联系原作者

资源下载

更多资源
Nacos

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称,一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集,帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring

Spring框架(Spring Framework)是由Rod Johnson于2002年提出的开源Java企业级应用框架,旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念,提供核心容器、应用上下文、数据访问集成等模块,支持整合Hibernate、Struts等第三方框架,其适用范围不仅限于服务器端开发,绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux

Rocky Linux(中文名:洛基)是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版,作为CentOS稳定版停止维护后与RHEL(Red Hat Enterprise Linux)完全兼容的开源替代方案,由社区拥有并管理,支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性,采用模块化包装和SELinux安全架构,默认包含GNOME桌面环境及XFS文件系统,支持十年生命周期更新。

Sublime Text

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能,例如代码缩略图,Python的插件,代码段等。还可自定义键绑定,菜单和工具栏。Sublime Text 的主要功能包括:拼写检查,书签,完整的 Python API , Goto 功能,即时项目切换,多选择,多窗口等等。Sublime Text 是一个跨平台的编辑器,同时支持Windows、Linux、Mac OS X等操作系统。

用户登录
用户注册